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

L

lastLogTimeMs - Variable in class stream.scotty.flinkBenchmark.ThroughputLogger

lastTotalReceived - Variable in class stream.scotty.flinkBenchmark.ThroughputLogger

lastWatermark - Variable in class stream.scotty.flinkconnector.demo.DemoSource

lastWatermark - Variable in class stream.scotty.flinkconnector.GlobalScottyWindowOperator

lastWatermark - Variable in class stream.scotty.flinkconnector.KeyedScottyWindowOperator

lastWatermark - Variable in class stream.scotty.slicing.WindowManager

LazyAggregateStore<InputType> - Class in stream.scotty.slicing.aggregationstore

A lazy in memory aggregation store implementation.

LazyAggregateStore() - Constructor for class stream.scotty.slicing.aggregationstore.LazyAggregateStore

LazyAggregateStoreTest - Class in stream.scotty.slicing.aggregationstore.test

LazyAggregateStoreTest() - Constructor for class stream.scotty.slicing.aggregationstore.test.LazyAggregateStoreTest

lift(InputType) - Method in interface stream.scotty.core.windowFunction.AggregateFunction

Transforms a tuple to a partial aggregate.

lift(InputType) - Method in interface stream.scotty.core.windowFunction.ReduceAggregateFunction

lift(Tuple2<Integer, Integer>) - Method in class stream.scotty.demo.flink.windowFunctions.QuantileWindowFunction

ListState<ItemType> - Interface in stream.scotty.state

loadConfig() - Static method in class stream.scotty.flinkBenchmark.BenchmarkRunner

LoadGeneratorSource - Class in stream.scotty.flinkBenchmark

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

LOG - Static variable in class stream.scotty.flinkBenchmark.LoadGeneratorSource

LOG - Static variable in class stream.scotty.flinkBenchmark.ThroughputLogger

logfreq - Variable in class stream.scotty.flinkBenchmark.ThroughputLogger

lookup(int) - Method in interface stream.scotty.core.windowType.TupleContext

lower(PartialAggregateType) - Method in interface stream.scotty.core.windowFunction.AggregateFunction

Transforms a partial aggregate to a final aggregate.

lower(InputType) - Method in interface stream.scotty.core.windowFunction.ReduceAggregateFunction

lower(Tuple2<Integer, QuantileTreeMap>) - Method in class stream.scotty.demo.flink.windowFunctions.QuantileWindowFunction

lowercount - Variable in class stream.scotty.demo.flink.windowFunctions.QuantileTreeMap

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