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

I

incrementCount() - Method in class stream.scotty.slicing.slice.Slice.Flexible

initWindowOperator() - Method in class stream.scotty.flinkconnector.GlobalScottyWindowOperator

initWindowOperator() - Method in class stream.scotty.flinkconnector.KeyedScottyWindowOperator

innerList - Variable in class stream.scotty.state.memory.MemoryListState

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

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

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

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

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

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

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

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

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

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

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

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

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

insertValueToCurrentSlice(InputType, long) - Method in interface stream.scotty.slicing.aggregationstore.AggregationStore

Insert the element to the current slice.

insertValueToCurrentSlice(InputType, long) - Method in class stream.scotty.slicing.aggregationstore.LazyAggregateStore

insertValueToSlice(int, InputType, long) - Method in interface stream.scotty.slicing.aggregationstore.AggregationStore

insertValueToSlice(int, InputType, long) - Method in class stream.scotty.slicing.aggregationstore.LazyAggregateStore

invert(PartialAggregateType, PartialAggregateType) - Method in interface stream.scotty.core.windowFunction.InvertibleAggregateFunction

Removes one partial aggregate from another with an incremental operation.

invert(Tuple4<String, Integer, Long, Long>, Tuple4<String, Integer, Long, Long>) - Method in class stream.scotty.flinkBenchmark.aggregations.SumAggregation

invert(Tuple2<Integer, Integer>, Tuple2<Integer, Integer>) - Method in class stream.scotty.demo.flink.windowFunctions.SumWindowFunction

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

InvertibleReduceAggregateFunction<Input> - Interface in stream.scotty.core.windowFunction

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

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

isEmpty() - Method in class stream.scotty.slicing.WindowManager.AggregationWindowCollector

isEmpty() - Method in class stream.scotty.state.memory.MemoryListState

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

isEmpty() - Method in interface stream.scotty.state.State

isInOrder(long) - Method in class stream.scotty.slicing.StreamSlicer

Checks if timestamp is >= @maxEventTime

isMergeable(AggregationState) - Method in class stream.scotty.slicing.AggregationState

isMovable() - Method in class stream.scotty.slicing.slice.Slice.Fixed

isMovable() - Method in class stream.scotty.slicing.slice.Slice.Flexible

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

iterator() - Method in interface stream.scotty.core.windowType.TupleContext

iterator(int, int) - Method in interface stream.scotty.core.windowType.TupleContext

iterator() - Method in class stream.scotty.slicing.WindowManager.AggregationWindowCollector

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