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

S

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

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

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

SessionConfig() - Constructor for class stream.scotty.flinkBenchmark.BenchmarkConfig.SessionConfig

SessionContext() - Constructor for class stream.scotty.core.windowType.SessionWindow.SessionContext

SessionWindow - Class in stream.scotty.core.windowType

SessionWindow(WindowMeasure, long) - Constructor for class stream.scotty.core.windowType.SessionWindow

SessionWindow.SessionContext - Class in stream.scotty.core.windowType

SessionWindowOperatorTest - Class in stream.scotty.slicing.aggregationstore.test.windowTest

SessionWindowOperatorTest() - Constructor for class stream.scotty.slicing.aggregationstore.test.windowTest.SessionWindowOperatorTest

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

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

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

set(ValueType) - Method in interface stream.scotty.state.ValueState

setEnd(long) - Method in class stream.scotty.core.windowType.windowContext.WindowContext.ActiveWindow

setStart(long) - Method in class stream.scotty.core.windowType.windowContext.WindowContext.ActiveWindow

setTEnd(long) - Method in class stream.scotty.slicing.slice.AbstractSlice

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

setTStart(long) - Method in class stream.scotty.slicing.slice.AbstractSlice

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

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

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

Set the end of the slice

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

setup() - Method in class stream.scotty.slicing.aggregationstore.test.windowTest.SessionWindowOperatorTest

setup() - Method in class stream.scotty.slicing.aggregationstore.test.windowTest.SlidingWindowOperatorTest

setup() - Method in class stream.scotty.slicing.aggregationstore.test.windowTest.TumblingWindowOperatorTest

setupIteration() - Method in class stream.scotty.microbenchmark.AggregationStoreBenchmark

setupIteration() - Method in class stream.scotty.microbenchmark.SlicingWindowOperatorBenchmark

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

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

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

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

size - Variable in class stream.scotty.core.TimeMeasure

The size of the windows generated by this policy.

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

Size of the sliding window

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

Size of the tumbling window

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

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

Slice<InputType,ValueType> - Interface in stream.scotty.slicing.slice

Slice.Fixed - Class in stream.scotty.slicing.slice

Slice.Flexible - Class in stream.scotty.slicing.slice

Slice.Type - Interface in stream.scotty.slicing.slice

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

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

SliceFactory(WindowManager, StateFactory) - Constructor for class stream.scotty.slicing.slice.SliceFactory

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

sliceFactory - Variable in class stream.scotty.slicing.SlicingWindowOperator

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

SliceManager(SliceFactory, AggregationStore<InputType>, WindowManager) - Constructor for class stream.scotty.slicing.SliceManager

sliceManager - Variable in class stream.scotty.slicing.SlicingWindowOperator

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

slicer - Variable in class stream.scotty.slicing.SlicingWindowOperator

slices - Variable in class stream.scotty.slicing.aggregationstore.LazyAggregateStore

slicingWindowOperator - Variable in class stream.scotty.flinkconnector.GlobalScottyWindowOperator

slicingWindowOperator - Variable in class stream.scotty.slicing.aggregationstore.test.windowTest.SessionWindowOperatorTest

slicingWindowOperator - Variable in class stream.scotty.slicing.aggregationstore.test.windowTest.SlidingWindowOperatorTest

slicingWindowOperator - Variable in class stream.scotty.slicing.aggregationstore.test.windowTest.TumblingWindowOperatorTest

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

Implementation of the slicing window operator based on the Scotty technique: Scotty: Efficient AbstractWindow Aggregation for out-of-order Stream Processing: Jonas Traub, Philipp M.

SlicingWindowOperator(StateFactory) - Constructor for class stream.scotty.slicing.SlicingWindowOperator

SlicingWindowOperatorBenchmark - Class in stream.scotty.microbenchmark

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

slicingWindowOperatorMap - Variable in class stream.scotty.flinkconnector.KeyedScottyWindowOperator

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

The window slide step

SlidingWindow - Class in stream.scotty.core.windowType

SlidingWindow(WindowMeasure, long, long) - Constructor for class stream.scotty.core.windowType.SlidingWindow

SlidingWindowOperatorTest - Class in stream.scotty.slicing.aggregationstore.test.windowTest

SlidingWindowOperatorTest() - Constructor for class stream.scotty.slicing.aggregationstore.test.windowTest.SlidingWindowOperatorTest

splitSlice(int, long) - Method in class stream.scotty.slicing.SliceManager

start - Variable in class stream.scotty.core.windowType.windowContext.WindowContext.ActiveWindow

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

startTs - Variable in class stream.scotty.slicing.AggregateWindowState

state - Variable in class stream.scotty.slicing.slice.EagerSlice

State - Interface in stream.scotty.state

stateFactory - Variable in class stream.scotty.flinkconnector.GlobalScottyWindowOperator

stateFactory - Variable in class stream.scotty.flinkconnector.KeyedScottyWindowOperator

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

stateFactory - Variable in class stream.scotty.slicing.aggregationstore.test.windowTest.SessionWindowOperatorTest

stateFactory - Variable in class stream.scotty.slicing.aggregationstore.test.windowTest.SlidingWindowOperatorTest

stateFactory - Variable in class stream.scotty.slicing.aggregationstore.test.windowTest.TumblingWindowOperatorTest

stateFactory - Variable in class stream.scotty.slicing.slice.SliceFactory

stateFactory - Variable in class stream.scotty.slicing.SlicingWindowOperator

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

StateFactory - Interface in stream.scotty.state

StateFactoryMock - Class in stream.scotty.slicing.aggregationstore.test

StateFactoryMock() - Constructor for class stream.scotty.slicing.aggregationstore.test.StateFactoryMock

stateList - Variable in class stream.scotty.microbenchmark.AggregationStateInline

statistics - Static variable in class stream.scotty.flinkBenchmark.ThroughputStatistics

StreamSlicer - Class in stream.scotty.slicing

StreamSlicer(SliceManager<?>, WindowManager) - Constructor for class stream.scotty.slicing.StreamSlicer

StreamSlicer.Edge - Class in stream.scotty.slicing

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

SumAggregation - Class in stream.scotty.flinkBenchmark.aggregations

SumAggregation() - Constructor for class stream.scotty.flinkBenchmark.aggregations.SumAggregation

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

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

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