@Test public void shouldInitializeWithPredicate () { config.set( PREDICATE_CONFIG_PARAMETER, positiveCountsPredicate ); final SchedulingStrategy strategy = operator.init( initCtx ); assertScheduleWhenTuplesAvailableStrategy( strategy, 1 ); }
@Override public SchedulingStrategy init ( final InitCtx ctx ) { final OperatorConfig config = ctx.getConfig(); this.predicate = config.getOrFail( PREDICATE_CONFIG_PARAMETER ); return scheduleWhenTuplesAvailableOnDefaultPort( DEFAULT_TUPLE_COUNT_CONFIG_VALUE ); }
FilterOperator implements Operator { @Override public SchedulingStrategy init ( final InitCtx ctx ) { final OperatorConfig config = ctx.getConfig(); this.predicate = config.getOrFail( PREDICATE_CONFIG_PARAMETER ); return scheduleWhenTuplesAvailableOnDefaultPort( DEFAULT_TUPLE_COUNT_CONFIG_VALUE ); } }
FilterOperator implements Operator { @Override public SchedulingStrategy init ( final InitCtx ctx ) { final OperatorConfig config = ctx.getConfig(); this.predicate = config.getOrFail( PREDICATE_CONFIG_PARAMETER ); return scheduleWhenTuplesAvailableOnDefaultPort( DEFAULT_TUPLE_COUNT_CONFIG_VALUE ); }  }
FilterOperator implements Operator { @Override public SchedulingStrategy init ( final InitCtx ctx ) { final OperatorConfig config = ctx.getConfig(); this.predicate = config.getOrFail( PREDICATE_CONFIG_PARAMETER ); return scheduleWhenTuplesAvailableOnDefaultPort( DEFAULT_TUPLE_COUNT_CONFIG_VALUE ); }  @Override SchedulingStrategy init( final InitCtx ctx ); @Override void invoke( final InvocationCtx ctx ); }
FilterOperator implements Operator { @Override public SchedulingStrategy init ( final InitCtx ctx ) { final OperatorConfig config = ctx.getConfig(); this.predicate = config.getOrFail( PREDICATE_CONFIG_PARAMETER ); return scheduleWhenTuplesAvailableOnDefaultPort( DEFAULT_TUPLE_COUNT_CONFIG_VALUE ); }  @Override SchedulingStrategy init( final InitCtx ctx ); @Override void invoke( final InvocationCtx ctx ); static final String PREDICATE_CONFIG_PARAMETER; }