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

C

calculateNextFixedEdge(long) - Method in class stream.scotty.slicing.StreamSlicer

calculateNextFlexEdge(long) - Method in class stream.scotty.slicing.StreamSlicer

cancel() - Method in class stream.scotty.flinkBenchmark.LoadGeneratorSource

cancel() - Method in class stream.scotty.flinkconnector.demo.DemoSource

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

checkSliceEdges(Set<WindowModifications>) - Method in class stream.scotty.slicing.SliceManager

clean() - Method in class stream.scotty.flinkBenchmark.ThroughputStatistics

clean() - Method in class stream.scotty.state.memory.MemoryListState

clean() - Method in class stream.scotty.state.memory.MemoryValueState

clean() - Method in interface stream.scotty.state.State

clone() - Method in class stream.scotty.demo.flink.windowFunctions.QuantileTreeMap

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

Computes the combined aggregate from partial aggregates.

combine(Tuple4<String, Integer, Long, Long>, Tuple4<String, Integer, Long, Long>) - Method in class stream.scotty.flinkBenchmark.aggregations.SumAggregation

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

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

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

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

CommutativeAggregateFunction<InputType,PartialAggregateType,FinalAggregateType> - Interface in stream.scotty.core.windowFunction

compareTo(WindowContext<Tuple>.ActiveWindow) - Method in class stream.scotty.core.windowType.windowContext.WindowContext.ActiveWindow

configPath - Static variable in class stream.scotty.flinkBenchmark.BenchmarkRunner

configurations - Variable in class stream.scotty.flinkBenchmark.BenchmarkConfig

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

ContextFreeWindow - Interface in stream.scotty.core.windowType

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

count_between_edges - Variable in class stream.scotty.slicing.StreamSlicer

counter - Variable in class stream.scotty.flinkBenchmark.ThroughputStatistics

counter - Static variable in class stream.scotty.demo.flink.windowFunctions.QuantileTreeMap

counter - Variable in class stream.scotty.slicing.slice.Slice.Flexible

createAggregationStore() - Method in interface stream.scotty.slicing.aggregationstore.AggregationStoreFactory

createContext() - Method in interface stream.scotty.core.windowType.ForwardContextAware

createContext() - Method in interface stream.scotty.core.windowType.ForwardContextFree

createContext() - Method in class stream.scotty.core.windowType.SessionWindow

createListState() - Method in class stream.scotty.slicing.aggregationstore.test.StateFactoryMock

createListState() - Method in class stream.scotty.state.memory.MemoryStateFactory

createListState() - Method in interface stream.scotty.state.StateFactory

createSlice(long, long, Slice.Type) - Method in class stream.scotty.slicing.slice.SliceFactory

createValueState() - Method in class stream.scotty.slicing.aggregationstore.test.StateFactoryMock

createValueState() - Method in class stream.scotty.state.memory.MemoryStateFactory

createValueState() - Method in interface stream.scotty.state.StateFactory

currentGapIndex - Variable in class stream.scotty.flinkBenchmark.LoadGeneratorSource

currentMaxTimestamp - Variable in class stream.scotty.flinkBenchmark.BenchmarkJob.TimestampsAndWatermarks

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