A B C D E F G H I K L M N O P Q R S T U V W

F

findSliceByEnd(long) - Method in interface stream.scotty.slicing.aggregationstore.AggregationStore

findSliceByEnd(long) - Method in class stream.scotty.slicing.aggregationstore.LazyAggregateStore

findSliceByTs() - Method in class stream.scotty.slicing.aggregationstore.test.LazyAggregateStoreTest

findSliceIndexByTimestamp(long) - Method in interface stream.scotty.slicing.aggregationstore.AggregationStore

Lookup for a slice which contains this timestamp.

findSliceIndexByTimestamp(long) - Method in class stream.scotty.slicing.aggregationstore.LazyAggregateStore

Fixed() - Constructor for class stream.scotty.slicing.slice.Slice.Fixed

flatMap(T, Collector<Integer>) - Method in class stream.scotty.flinkBenchmark.ThroughputLogger

Flexible() - Constructor for class stream.scotty.slicing.slice.Slice.Flexible

Flexible(int) - Constructor for class stream.scotty.slicing.slice.Slice.Flexible

FlinkBenchmarkJob - Class in stream.scotty.flinkBenchmark

FlinkBenchmarkJob(List<Window>, StreamExecutionEnvironment, long, int, List<Tuple2<Long, Long>>) - Constructor for class stream.scotty.flinkBenchmark.FlinkBenchmarkJob

FlinkQuantileDemo - Class in stream.scotty.flinkconnector.demo

FlinkQuantileDemo() - Constructor for class stream.scotty.flinkconnector.demo.FlinkQuantileDemo

FlinkSumDemo - Class in stream.scotty.flinkconnector.demo

FlinkSumDemo() - Constructor for class stream.scotty.flinkconnector.demo.FlinkSumDemo

ForwardContextAware - Interface in stream.scotty.core.windowType

ForwardContextFree - Interface in stream.scotty.core.windowType

A B C D E F G H I K L M N O P Q R S T U V W