Serialized Form

Package stream.scotty.core
Package stream.scotty.core.windowFunction
Package stream.scotty.core.windowType
- Class windowType.stream.scotty.core.SessionWindow extends java.lang.Object implements Serializable
  - Serialized Fields
    - measure
```
WindowMeasure measure
```
    - gap
```
long gap
```
      The session window gap
- Class windowType.stream.scotty.core.SessionWindow.SessionContext extends WindowContext<java.lang.Object> implements Serializable
- Class windowType.stream.scotty.core.SlidingWindow extends java.lang.Object implements Serializable
  - Serialized Fields
    - measure
```
WindowMeasure measure
```
    - size
```
long size
```
      Size of the sliding window
    - slide
```
long slide
```
      The window slide step
- Class windowType.stream.scotty.core.TumblingWindow extends java.lang.Object implements Serializable
  - Serialized Fields
    - measure
```
WindowMeasure measure
```
    - size
```
long size
```
      Size of the tumbling window
Package stream.scotty.core.windowType.windowContext
- Class windowContext.windowType.stream.scotty.core.WindowContext extends java.lang.Object implements Serializable
  - Serialized Fields
    - modifiedWindowEdges
```
java.util.Set<E> modifiedWindowEdges
```
    - activeWindows
```
java.util.ArrayList<E> activeWindows
```
Package stream.scotty.flinkBenchmark
- Class flinkBenchmark.stream.scotty.BenchmarkJob.TimestampsAndWatermarks extends java.lang.Object implements Serializable
  - Serialized Fields
    - maxOutOfOrderness
```
long maxOutOfOrderness
```
    - currentMaxTimestamp
```
long currentMaxTimestamp
```
    - startTime
```
long startTime
```
- Class flinkBenchmark.stream.scotty.LoadGeneratorSource extends java.lang.Object implements Serializable
  - Serialized Fields
    - runtime
```
long runtime
```
    - throughput
```
int throughput
```
    - running
```
boolean running
```
    - gaps
```
java.util.List<E> gaps
```
    - currentGapIndex
```
int currentGapIndex
```
    - nextGapStart
```
long nextGapStart
```
    - nextGapEnd
```
long nextGapEnd
```
    - timeOffset
```
long timeOffset
```
    - random
```
java.util.Random random
```
    - backpressureCounter
```
int backpressureCounter
```
- Class flinkBenchmark.stream.scotty.ThroughputLogger extends java.lang.Object implements Serializable
  - Serialized Fields
    - totalReceived
```
long totalReceived
```
    - lastTotalReceived
```
long lastTotalReceived
```
    - lastLogTimeMs
```
long lastLogTimeMs
```
    - elementSize
```
int elementSize
```
    - logfreq
```
long logfreq
```
Package stream.scotty.flinkBenchmark.aggregations
- Class aggregations.flinkBenchmark.stream.scotty.SumAggregation extends java.lang.Object implements Serializable
Package stream.scotty.flinkconnector
- Class flinkconnector.stream.scotty.GlobalScottyWindowOperator extends org.apache.flink.streaming.api.functions.ProcessFunction<InputType,AggregateWindow<FinalAggregateType>> implements Serializable
  - Serialized Fields
    - stateFactory
```
MemoryStateFactory stateFactory
```
    - slicingWindowOperator
```
SlicingWindowOperator<InputType> slicingWindowOperator
```
    - lastWatermark
```
long lastWatermark
```
    - windowFunction
```
AggregateFunction<InputType,PartialAggregateType,FinalAggregateType> windowFunction
```
    - windows
```
java.util.List<E> windows
```
- Class stream.scotty.flinkconnector.GlobalSlicingWindowOperator extends org.apache.flink.streaming.api.functions.ProcessFunction<InputType,AggregateWindow<FinalAggregateType>> implements Serializable
  - Serialized Fields
    - stateFactory
```
MemoryStateFactory stateFactory
```
    - slicingWindowOperator
```
SlicingWindowOperator<InputType> slicingWindowOperator
```
    - lastWatermark
```
long lastWatermark
```
    - windowFunction
```
AggregateFunction<InputType,PartialAggregateType,FinalAggregateType> windowFunction
```
    - windows
```
java.util.List<E> windows
```
- Class flinkconnector.stream.scotty.KeyedScottyWindowOperator extends org.apache.flink.streaming.api.functions.KeyedProcessFunction<Key,InputType,AggregateWindow<FinalAggregateType>> implements Serializable
  - Serialized Fields
    - stateFactory
```
MemoryStateFactory stateFactory
```
    - slicingWindowOperatorMap
```
java.util.HashMap<K,V> slicingWindowOperatorMap
```
    - lastWatermark
```
long lastWatermark
```
    - windowFunction
```
AggregateFunction<InputType,PartialAggregateType,FinalAggregateType> windowFunction
```
    - windows
```
java.util.List<E> windows
```
- Class stream.scotty.flinkconnector.KeyedSlicingWindowOperator extends org.apache.flink.streaming.api.functions.KeyedProcessFunction<Key,InputType,AggregateWindow<FinalAggregateType>> implements Serializable
  - Serialized Fields
    - stateFactory
```
MemoryStateFactory stateFactory
```
    - slicingWindowOperatorMap
```
java.util.HashMap<K,V> slicingWindowOperatorMap
```
    - lastWatermark
```
long lastWatermark
```
    - windowFunction
```
AggregateFunction<InputType,PartialAggregateType,FinalAggregateType> windowFunction
```
    - windows
```
java.util.List<E> windows
```
Package stream.scotty.flinkconnector.demo
- Class flink.demo.stream.scotty.DemoSource extends org.apache.flink.streaming.api.functions.source.RichSourceFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer>> implements Serializable
  - Serialized Fields
    - key
```
java.util.Random key
```
    - value
```
java.util.Random value
```
    - canceled
```
boolean canceled
```
    - lastWatermark
```
long lastWatermark
```
- Class flink.demo.stream.scotty.FlinkQuantileDemo extends java.lang.Object implements Serializable
- Class flink.demo.stream.scotty.FlinkSumDemo extends java.lang.Object implements Serializable
Package stream.scotty.demo.flink.windowFunctions
- Class windowFunctions.flink.demo.stream.scotty.MaxWindowFunction extends java.lang.Object implements Serializable
- Class windowFunctions.flink.demo.stream.scotty.MinWindowFunction extends java.lang.Object implements Serializable
- Class windowFunctions.flink.demo.stream.scotty.QuantileTreeMap extends java.lang.Object implements Serializable
  - Serialized Fields
    - values
```
java.util.TreeMap<K,V> values
```
    - quantile
```
int quantile
```
    - lowercount
```
int lowercount
```
    - uppercount
```
int uppercount
```
    - pct
```
double pct
```
- Class windowFunctions.flink.demo.stream.scotty.QuantileWindowFunction extends java.lang.Object implements Serializable
  - Serialized Fields
    - quantile
```
double quantile
```
- Class windowFunctions.flink.demo.stream.scotty.SumWindowFunction extends java.lang.Object implements Serializable
Package stream.scotty.slicing
- Class stream.scotty.slicing.AggregateWindowState extends java.lang.Object implements Serializable
  - Serialized Fields
    - startTs
```
long startTs
```
    - endTs
```
long endTs
```
    - windowState
```
AggregationState<InputType> windowState
```
- Class stream.scotty.slicing.AggregationState extends java.lang.Object implements Serializable
  - Serialized Fields
    - windowFunctions
```
java.util.List<E> windowFunctions
```
    - valueStates
```
java.util.List<E> valueStates
```
    - empty
```
boolean empty
```
- Class stream.scotty.slicing.SlicingWindowOperator extends java.lang.Object implements Serializable
  - Serialized Fields
    - stateFactory
```
StateFactory stateFactory
```
    - windowManager
```
WindowManager windowManager
```
    - sliceFactory
```
SliceFactory<InputType,ValueType> sliceFactory
```
    - sliceManager
```
SliceManager<InputType> sliceManager
```
    - slicer
```
StreamSlicer slicer
```
Package stream.scotty.slicing.aggregationstore.test
- Class stream.scotty.slicing.aggregationstore.test.StateFactoryMock extends java.lang.Object implements Serializable
Package stream.scotty.state
Package stream.scotty.state.memory
- Class memory.state.stream.scotty.MemoryListState extends java.lang.Object implements Serializable
  - Serialized Fields
    - innerList
```
java.util.ArrayList<E> innerList
```
- Class memory.state.stream.scotty.MemoryStateFactory extends java.lang.Object implements Serializable
- Class memory.state.stream.scotty.MemoryValueState extends java.lang.Object implements Serializable
  - Serialized Fields
    - value
```
java.lang.Object value
```

Serialized Form

Package stream.scotty.core

Package stream.scotty.core.windowFunction

Package stream.scotty.core.windowType

Class windowType.stream.scotty.core.SessionWindow extends java.lang.Object implements Serializable

Serialized Fields

measure

gap

Class windowType.stream.scotty.core.SessionWindow.SessionContext extends WindowContext<java.lang.Object> implements Serializable

Class windowType.stream.scotty.core.SlidingWindow extends java.lang.Object implements Serializable

Serialized Fields

measure

size

slide

Class windowType.stream.scotty.core.TumblingWindow extends java.lang.Object implements Serializable

Serialized Fields

measure

size

Package stream.scotty.core.windowType.windowContext

Class windowContext.windowType.stream.scotty.core.WindowContext extends java.lang.Object implements Serializable

Serialized Fields

modifiedWindowEdges

activeWindows

Package stream.scotty.flinkBenchmark

Class flinkBenchmark.stream.scotty.BenchmarkJob.TimestampsAndWatermarks extends java.lang.Object implements Serializable

Serialized Fields

maxOutOfOrderness

currentMaxTimestamp

startTime

Class flinkBenchmark.stream.scotty.LoadGeneratorSource extends java.lang.Object implements Serializable

Serialized Fields

runtime

throughput

running

gaps

currentGapIndex

nextGapStart

nextGapEnd

timeOffset

random

backpressureCounter

Class flinkBenchmark.stream.scotty.ThroughputLogger extends java.lang.Object implements Serializable

Serialized Fields

totalReceived

lastTotalReceived

lastLogTimeMs

elementSize

logfreq

Package stream.scotty.flinkBenchmark.aggregations

Class aggregations.flinkBenchmark.stream.scotty.SumAggregation extends java.lang.Object implements Serializable

Package stream.scotty.flinkconnector

Class flinkconnector.stream.scotty.GlobalScottyWindowOperator extends org.apache.flink.streaming.api.functions.ProcessFunction<InputType,AggregateWindow<FinalAggregateType>> implements Serializable

Serialized Fields

stateFactory

slicingWindowOperator

lastWatermark

windowFunction

windows

Class stream.scotty.flinkconnector.GlobalSlicingWindowOperator extends org.apache.flink.streaming.api.functions.ProcessFunction<InputType,AggregateWindow<FinalAggregateType>> implements Serializable

Serialized Fields

stateFactory

slicingWindowOperator

lastWatermark

windowFunction

windows

Class flinkconnector.stream.scotty.KeyedScottyWindowOperator extends org.apache.flink.streaming.api.functions.KeyedProcessFunction<Key,InputType,AggregateWindow<FinalAggregateType>> implements Serializable

Serialized Fields

stateFactory

slicingWindowOperatorMap

lastWatermark

windowFunction

windows

Class stream.scotty.flinkconnector.KeyedSlicingWindowOperator extends org.apache.flink.streaming.api.functions.KeyedProcessFunction<Key,InputType,AggregateWindow<FinalAggregateType>> implements Serializable

Serialized Fields

stateFactory

slicingWindowOperatorMap

lastWatermark

windowFunction

windows

Package stream.scotty.flinkconnector.demo