@ Override protected void onCreate ( ) { logger . debug ( "PE ID {}" , getId ( ) ) ; if ( this . processor != null ) { this . processor = this . processor . newProcessor ( this . processor ) ; this . processor . onCreate ( Integer . parseInt ( getId ( ) ) ) ; } }
Methods from ProcessingElement