code: @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()));
  		}
  	}
docs: Methods from ProcessingElement