- gap - Variable in class stream.scotty.core.windowType.SessionWindow
-
The session window gap
- gapCount - Variable in class stream.scotty.flinkBenchmark.BenchmarkConfig.SessionConfig
-
- gaps - Variable in class stream.scotty.flinkBenchmark.LoadGeneratorSource
-
- generateSessionGaps(int, int, int, int) - Static method in class stream.scotty.flinkBenchmark.BenchmarkRunner
-
- get() - Method in interface stream.scotty.state.ListState
-
- get() - Method in class stream.scotty.state.memory.MemoryListState
-
- get() - Method in class stream.scotty.state.memory.MemoryValueState
-
- get() - Method in interface stream.scotty.state.ValueState
-
- getAggregations() - Method in class stream.scotty.slicing.WindowManager
-
- getAggState() - Method in class stream.scotty.slicing.slice.EagerSlice
-
- getAggState() - Method in interface stream.scotty.slicing.slice.Slice
-
- getAggValue() - Method in interface stream.scotty.core.AggregateWindow
-
- getAggValue() - Method in class stream.scotty.slicing.AggregateWindowState
-
- getAssigner(String) - Static method in class stream.scotty.flinkBenchmark.BenchmarkRunner
-
- getAssigners(List<String>) - Static method in class stream.scotty.flinkBenchmark.BenchmarkRunner
-
- getContextAwareWindows() - Method in class stream.scotty.slicing.WindowManager
-
- getContextFreeWindows() - Method in class stream.scotty.slicing.WindowManager
-
- getCount() - Method in class stream.scotty.slicing.slice.Slice.Flexible
-
- getCurrentSlice() - Method in interface stream.scotty.slicing.aggregationstore.AggregationStore
-
- getCurrentSlice() - Method in class stream.scotty.slicing.aggregationstore.LazyAggregateStore
-
- getCurrentWatermark() - Method in class stream.scotty.flinkBenchmark.BenchmarkJob.TimestampsAndWatermarks
-
- getEnd() - Method in class stream.scotty.core.windowType.windowContext.WindowContext.ActiveWindow
-
- getEndTs() - Method in interface stream.scotty.core.AggregateWindow
-
- getEndTs() - Method in class stream.scotty.slicing.AggregateWindowState
-
- getGap() - Method in class stream.scotty.core.windowType.SessionWindow
-
- getInstance() - Static method in class stream.scotty.flinkBenchmark.ThroughputStatistics
-
- getKey(KeyedProcessFunction<Key, InputType, AggregateWindow<FinalAggregateType>>.Context) - Method in class stream.scotty.flinkconnector.KeyedScottyWindowOperator
-
- getMaxLateness() - Method in class stream.scotty.slicing.WindowManager
-
- getMinSessionTimeout() - Method in class stream.scotty.slicing.WindowManager
-
- getQuantile() - Method in class stream.scotty.demo.flink.windowFunctions.QuantileTreeMap
-
- getSession(long) - Method in class stream.scotty.core.windowType.SessionWindow.SessionContext
-
- getSize() - Method in class stream.scotty.core.TimeMeasure
-
Gets the length of this policy's time interval.
- getSize() - Method in class stream.scotty.core.windowType.SlidingWindow
-
- getSize() - Method in class stream.scotty.core.windowType.TumblingWindow
-
- getSlice(int) - Method in interface stream.scotty.slicing.aggregationstore.AggregationStore
-
Returns slice for a given index or @IndexOutOfBoundsException
- getSlice(int) - Method in class stream.scotty.slicing.aggregationstore.LazyAggregateStore
-
- getSliceByIndex() - Method in class stream.scotty.slicing.aggregationstore.test.LazyAggregateStoreTest
-
- getSlide() - Method in class stream.scotty.core.windowType.SlidingWindow
-
- getStart() - Method in class stream.scotty.core.windowType.windowContext.WindowContext.ActiveWindow
-
- getStartTs() - Method in interface stream.scotty.core.AggregateWindow
-
- getStartTs() - Method in class stream.scotty.slicing.AggregateWindowState
-
- getTEnd() - Method in class stream.scotty.slicing.slice.AbstractSlice
-
- getTEnd() - Method in interface stream.scotty.slicing.slice.Slice
-
- getTFirst() - Method in class stream.scotty.slicing.slice.AbstractSlice
-
- getTFirst() - Method in interface stream.scotty.slicing.slice.Slice
-
timestamp of the first record in the slice
- getTLast() - Method in class stream.scotty.slicing.slice.AbstractSlice
-
- getTLast() - Method in interface stream.scotty.slicing.slice.Slice
-
timestamp of the last record in the slice
- getTStart() - Method in class stream.scotty.slicing.slice.AbstractSlice
-
- getTStart() - Method in interface stream.scotty.slicing.slice.Slice
-
- getType() - Method in class stream.scotty.slicing.slice.AbstractSlice
-
- getType() - Method in interface stream.scotty.slicing.slice.Slice
-
The measure of the slice end.
- getUnit() - Method in class stream.scotty.core.TimeMeasure
-
Gets the time unit for this policy's time interval.
- getValues() - Method in class stream.scotty.demo.flink.windowFunctions.QuantileTreeMap
-
- getValues() - Method in class stream.scotty.slicing.AggregationState
-
- getWindow(int) - Method in class stream.scotty.core.windowType.windowContext.WindowContext
-
- getWindowMeasure() - Method in class stream.scotty.core.windowType.SessionWindow
-
- getWindowMeasure() - Method in class stream.scotty.core.windowType.SlidingWindow
-
- getWindowMeasure() - Method in class stream.scotty.core.windowType.TumblingWindow
-
- getWindowMeasure() - Method in interface stream.scotty.core.windowType.Window
-
- GlobalScottyWindowOperator<InputType,FinalAggregateType> - Class in stream.scotty.flinkconnector
-
- GlobalScottyWindowOperator(AggregateFunction<InputType, ?, FinalAggregateType>) - Constructor for class stream.scotty.flinkconnector.GlobalScottyWindowOperator
-