StreamingServiceTransExecutor { public long getWindowMaxTimeLimit() { return windowMaxTimeLimit; } StreamingServiceTransExecutor( final StreamServiceKey key, Trans serviceTrans, final String serviceStepName,
                                        final int windowMaxRowLimit, final long windowMaxTimeLimit,
                                        final Context context ); Trans getServiceTrans(); StreamServiceKey getKey(); long getWindowMaxRowLimit(); long getWindowMaxTimeLimit(); StreamExecutionListener getBuffer( String query, Consumer<List<RowMetaAndData>> windowConsumer, final IDataServiceClientService.StreamingMode windowMode,
                                            long windowSize, long windowEvery, long windowLimit ); void clearCache(); void clearCacheByKey( String key ); void stopAll(); StreamExecutionListener touchServiceListener( String key );  }
@Test public void testGetWindowMaxTimeLimit() { assertEquals( MOCK_TIME_LIMIT, serviceExecutor.getWindowMaxTimeLimit() ); }