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

M

main(String[]) - Static method in class stream.scotty.flinkBenchmark.AnalyzeTool

main(String[]) - Static method in class stream.scotty.flinkBenchmark.BenchmarkRunner

main(String[]) - Static method in class stream.scotty.flinkconnector.demo.FlinkQuantileDemo

main(String[]) - Static method in class stream.scotty.flinkconnector.demo.FlinkSumDemo

main(String[]) - Static method in class stream.scotty.microbenchmark.AggregationStoreBenchmark

main(String[]) - Static method in class stream.scotty.microbenchmark.SlicingWindowOperatorBenchmark

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

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

maxGapTime - Variable in class stream.scotty.flinkBenchmark.BenchmarkConfig.SessionConfig

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

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

MaxWindowFunction - Class in stream.scotty.demo.flink.windowFunctions

MaxWindowFunction() - Constructor for class stream.scotty.demo.flink.windowFunctions.MaxWindowFunction

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

measure - Variable in class stream.scotty.core.windowType.SessionWindow

measure - Variable in class stream.scotty.core.windowType.SlidingWindow

measure - Variable in class stream.scotty.core.windowType.TumblingWindow

MemoryListState<T> - Class in stream.scotty.state.memory

MemoryListState() - Constructor for class stream.scotty.state.memory.MemoryListState

MemoryStateFactory - Class in stream.scotty.state.memory

MemoryStateFactory() - Constructor for class stream.scotty.state.memory.MemoryStateFactory

MemoryValueState<T> - Class in stream.scotty.state.memory

MemoryValueState() - Constructor for class stream.scotty.state.memory.MemoryValueState

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

Merges another quantile into this one.

merge(AggregationState<InputType>) - Method in class stream.scotty.slicing.AggregationState

merge(Slice) - Method in class stream.scotty.slicing.slice.AbstractSlice

merge(Slice) - Method in interface stream.scotty.slicing.slice.Slice

mergeSlice(int) - Method in interface stream.scotty.slicing.aggregationstore.AggregationStore

Merging two slices A and B happens in three steps: 1.

mergeSlice(int) - Method in class stream.scotty.slicing.aggregationstore.LazyAggregateStore

mergeWithPre(int) - Method in class stream.scotty.core.windowType.windowContext.WindowContext

milliseconds(long) - Static method in class stream.scotty.core.TimeMeasure

Creates a new TimeMeasure that represents the given number of milliseconds.

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

minGapTime - Variable in class stream.scotty.flinkBenchmark.BenchmarkConfig.SessionConfig

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

minutes(long) - Static method in class stream.scotty.core.TimeMeasure

Creates a new TimeMeasure that represents the given number of minutes.

MinWindowFunction - Class in stream.scotty.demo.flink.windowFunctions

MinWindowFunction() - Constructor for class stream.scotty.demo.flink.windowFunctions.MinWindowFunction

modifiedWindowEdges - Variable in class stream.scotty.core.windowType.windowContext.WindowContext

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