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

A

AbstractSlice<InputType,ValueType> - Class in stream.scotty.slicing.slice

AbstractSlice(long, long, Slice.Type) - Constructor for class stream.scotty.slicing.slice.AbstractSlice

ActiveWindow(long, long) - Constructor for class stream.scotty.core.windowType.windowContext.WindowContext.ActiveWindow

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

add(int, ItemType) - Method in interface stream.scotty.state.ListState

add(int, T) - Method in class stream.scotty.state.memory.MemoryListState

addAggregation(AggregateFunction<InputType, ?, OutputType>) - Method in interface stream.scotty.core.WindowOperator

Add a aggregation

addAggregation(AggregateFunction<InputType, ?, OutputType>) - Method in class stream.scotty.slicing.SlicingWindowOperator

addAggregation(AggregateFunction<InputType, Agg, OutputType>) - Method in class stream.scotty.slicing.WindowManager

addElement(Integer) - Method in class stream.scotty.microbenchmark.AggregationStateInline

addElement(InputType) - Method in class stream.scotty.slicing.AggregationState

addElement(InputType, long) - Method in class stream.scotty.slicing.slice.AbstractSlice

addElement(InputType, long) - Method in class stream.scotty.slicing.slice.EagerSlice

addElement(InputType, long) - Method in interface stream.scotty.slicing.slice.Slice

Add a element to the slice.

addElementToValueState(InputType, ValueState<Object>, AggregateFunction) - Method in class stream.scotty.slicing.AggregationState

AddModification - Class in stream.scotty.core.windowType.windowContext

AddModification(long) - Constructor for class stream.scotty.core.windowType.windowContext.AddModification

addNewWindow(int, long, long) - Method in class stream.scotty.core.windowType.windowContext.WindowContext

addSlice(int, Slice) - Method in interface stream.scotty.slicing.aggregationstore.AggregationStore

Add a new Slice at a specific index

addSlice(int, Slice) - Method in class stream.scotty.slicing.aggregationstore.LazyAggregateStore

addState(AggregationState) - Method in class stream.scotty.slicing.AggregateWindowState

addThrouputResult(double) - Method in class stream.scotty.flinkBenchmark.ThroughputStatistics

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

addValues(TreeMap<Integer, Integer>) - Method in class stream.scotty.demo.flink.windowFunctions.QuantileTreeMap

addWindow(Window) - Method in class stream.scotty.flinkconnector.GlobalScottyWindowOperator

Register a new @Window definition to the ActiveWindow Operator.

addWindow(Window) - Method in class stream.scotty.flinkconnector.KeyedScottyWindowOperator

Register a new @Window definition to the ActiveWindow Operator.

addWindowAssigner(Window) - Method in interface stream.scotty.core.WindowOperator

Add a window assigner to the window operator.

addWindowAssigner(Window) - Method in class stream.scotty.slicing.SlicingWindowOperator

addWindowAssigner(Window) - Method in class stream.scotty.slicing.WindowManager

addWindowFunction(AggregateFunction<InputType, Agg, OutputType>) - Method in class stream.scotty.slicing.SlicingWindowOperator

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

aggregate(WindowManager.AggregationWindowCollector, long, long) - Method in interface stream.scotty.slicing.aggregationstore.AggregationStore

Generates the window aggregates.

aggregate(WindowManager.AggregationWindowCollector, long, long) - Method in class stream.scotty.slicing.aggregationstore.LazyAggregateStore

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

AggregateWindow<T> - Interface in stream.scotty.core

aggregateWindow() - Method in class stream.scotty.slicing.aggregationstore.test.LazyAggregateStoreTest

AggregateWindowState - Class in stream.scotty.slicing

AggregateWindowState(long, long, StateFactory, List<AggregateFunction>) - Constructor for class stream.scotty.slicing.AggregateWindowState

aggregationState - Variable in class stream.scotty.microbenchmark.AggregationStoreBenchmark

AggregationState<InputType> - Class in stream.scotty.slicing

AggregationState(StateFactory, List<AggregateFunction>) - Constructor for class stream.scotty.slicing.AggregationState

AggregationStateInline - Class in stream.scotty.microbenchmark

AggregationStateInline(StateFactory) - Constructor for class stream.scotty.microbenchmark.AggregationStateInline

aggregationStateInline - Variable in class stream.scotty.microbenchmark.AggregationStoreBenchmark

AggregationStore<InputType> - Interface in stream.scotty.slicing.aggregationstore

aggregationStore - Variable in class stream.scotty.slicing.aggregationstore.test.LazyAggregateStoreTest

aggregationStore - Variable in class stream.scotty.slicing.SliceManager

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

AggregationStoreBenchmark - Class in stream.scotty.microbenchmark

AggregationStoreBenchmark() - Constructor for class stream.scotty.microbenchmark.AggregationStoreBenchmark

AggregationStoreFactory - Interface in stream.scotty.slicing.aggregationstore

aggregationStores - Variable in class stream.scotty.slicing.WindowManager.AggregationWindowCollector

AggregationWindowCollector() - Constructor for class stream.scotty.slicing.WindowManager.AggregationWindowCollector

analyze(String, List<String>) - Static method in class stream.scotty.flinkBenchmark.AnalyzeTool

AnalyzeTool - Class in stream.scotty.flinkBenchmark

AnalyzeTool() - Constructor for class stream.scotty.flinkBenchmark.AnalyzeTool

AnalyzeTool.Result - Class in stream.scotty.flinkBenchmark

appendSlice(Slice<InputType, ?>) - Method in interface stream.scotty.slicing.aggregationstore.AggregationStore

Appends a new slice as new current slice

appendSlice(Slice<InputType, ?>) - Method in class stream.scotty.slicing.aggregationstore.LazyAggregateStore

appendSlice(long, Slice.Type) - Method in class stream.scotty.slicing.SliceManager

Append a new slice.

assertContains(List<AggregateWindow>, int, int, Object) - Static method in class stream.scotty.slicing.aggregationstore.test.windowTest.WindowAssert

assertEquals(AggregateWindow, long, long, Object) - Static method in class stream.scotty.slicing.aggregationstore.test.windowTest.WindowAssert

assignContextAwareWindows(long, WindowManager.AggregationWindowCollector) - Method in class stream.scotty.slicing.WindowManager

assignContextFreeWindows(long, WindowCollector) - Method in class stream.scotty.slicing.WindowManager

assignNextWindowStart(long) - Method in interface stream.scotty.core.windowType.ContextFreeWindow

assignNextWindowStart(long) - Method in class stream.scotty.core.windowType.SessionWindow.SessionContext

assignNextWindowStart(long) - Method in class stream.scotty.core.windowType.SlidingWindow

assignNextWindowStart(long) - Method in class stream.scotty.core.windowType.TumblingWindow

assignNextWindowStart(long) - Method 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