VWAPAggregatorOperator implements Operator { @Override public SchedulingStrategy init ( final InitCtx ctx ) { this.windowSize = ctx.getConfig().getOrFail( WINDOW_SIZE_CONfIG_PARAMETER ); this.slideFactor = ctx.getConfig().getOrDefault( SLIDE_FACTOR_CONfIG_PARAMETER, 1 ); this.outputSchema = ctx.getOutputPortSchema( 0 ); return scheduleWhenTuplesAvailableOnDefaultPort( 1 ); }  @Override SchedulingStrategy init( final InitCtx ctx ); @Override void invoke( final InvocationCtx ctx ); static final String WINDOW_SIZE_CONfIG_PARAMETER; static final String SLIDE_FACTOR_CONfIG_PARAMETER; static final String TICKER_SYMBOL_FIELD; static final String SINGLE_VWAP_FIELD; static final String SINGLE_VOLUME_FIELD; static final String TUPLE_INPUT_VWAP_FIELD; static final String TUPLE_VOLUME_FIELD; static final String TIMESTAMP_FIELD; static final String TUPLE_COUNT_FIELD; static final String WINDOW_KEY; static final String VWAPS_FIELD; static final String VOLUMES_FIELD; }
@Test( expected = IllegalArgumentException.class ) public void shouldFailToInitWithNoWindowSize () { operator.init( initCtx ); }