Skip navigation links
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 
Skip navigation links