Hierarchy For All Packages

Package Hierarchies:

• stream.scotty.core,
• stream.scotty.core.windowFunction,
• stream.scotty.core.windowType,
• stream.scotty.core.windowType.windowContext,
• stream.scotty.flinkBenchmark,
• stream.scotty.flinkBenchmark.aggregations,
• stream.scotty.flinkconnector,
• stream.scotty.flinkconnector.demo,
• stream.scotty.demo.flink.windowFunctions,
• stream.scotty.microbenchmark,
• stream.scotty.slicing,
• stream.scotty.slicing.aggregationstore,
• stream.scotty.slicing.aggregationstore.test,
• stream.scotty.slicing.aggregationstore.test.windowTest,
• stream.scotty.slicing.slice,
• stream.scotty.state,
• stream.scotty.state.memory

Class Hierarchy

• java.lang.Object
  • org.apache.flink.api.common.functions.AbstractRichFunction (implements org.apache.flink.api.common.functions.RichFunction, java.io.Serializable)
    • org.apache.flink.streaming.api.functions.KeyedProcessFunction<K,I,O>
      • stream.scotty.flinkconnector.KeyedScottyWindowOperator<Key,InputType,FinalAggregateType>
    • org.apache.flink.streaming.api.functions.ProcessFunction<I,O>
      • stream.scotty.flinkconnector.GlobalScottyWindowOperator<InputType,FinalAggregateType>
    • org.apache.flink.streaming.api.functions.source.RichSourceFunction<OUT> (implements org.apache.flink.streaming.api.functions.source.SourceFunction<T>)
      • stream.scotty.flinkconnector.demo.DemoSource (implements java.io.Serializable)
  • stream.scotty.slicing.slice.AbstractSlice<InputType,ValueType> (implements stream.scotty.slicing.slice.Slice<InputType,ValueType>)
    • stream.scotty.slicing.slice.EagerSlice<InputType,ValueType>
  • stream.scotty.core.windowType.windowContext.AddModification (implements stream.scotty.core.windowType.windowContext.WindowModifications)
  • stream.scotty.slicing.AggregateWindowState (implements stream.scotty.core.AggregateWindow<T>)
  • stream.scotty.slicing.AggregationState<InputType> (implements java.io.Serializable)
  • stream.scotty.microbenchmark.AggregationStateInline
  • stream.scotty.microbenchmark.AggregationStoreBenchmark
  • stream.scotty.flinkBenchmark.AnalyzeTool
  • stream.scotty.flinkBenchmark.AnalyzeTool.Result
  • stream.scotty.flinkBenchmark.BenchmarkConfig
  • stream.scotty.flinkBenchmark.BenchmarkConfig.SessionConfig
  • stream.scotty.flinkBenchmark.BenchmarkJob
  • stream.scotty.flinkBenchmark.BenchmarkJob.TimestampsAndWatermarks (implements org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks<T>)
  • stream.scotty.flinkBenchmark.BenchmarkRunner
  • stream.scotty.core.windowType.windowContext.DeleteModification (implements stream.scotty.core.windowType.windowContext.WindowModifications)
  • stream.scotty.flinkBenchmark.FlinkBenchmarkJob
  • stream.scotty.flinkconnector.demo.FlinkQuantileDemo (implements java.io.Serializable)
  • stream.scotty.flinkconnector.demo.FlinkSumDemo (implements java.io.Serializable)
  • stream.scotty.slicing.aggregationstore.LazyAggregateStore<InputType> (implements stream.scotty.slicing.aggregationstore.AggregationStore<InputType>)
  • stream.scotty.slicing.aggregationstore.test.LazyAggregateStoreTest
  • stream.scotty.flinkBenchmark.LoadGeneratorSource (implements org.apache.flink.streaming.api.functions.source.SourceFunction<T>)
  • stream.scotty.demo.flink.windowFunctions.MaxWindowFunction (implements stream.scotty.core.windowFunction.ReduceAggregateFunction<InputType>, java.io.Serializable)
  • stream.scotty.state.memory.MemoryListState<T> (implements stream.scotty.state.ListState<ItemType>)
  • stream.scotty.state.memory.MemoryStateFactory (implements stream.scotty.state.StateFactory)
  • stream.scotty.state.memory.MemoryValueState<T> (implements stream.scotty.state.ValueState<ValueType>)
  • stream.scotty.demo.flink.windowFunctions.MinWindowFunction (implements stream.scotty.core.windowFunction.ReduceAggregateFunction<InputType>, java.io.Serializable)
  • stream.scotty.demo.flink.windowFunctions.QuantileTreeMap (implements java.io.Serializable)
  • stream.scotty.demo.flink.windowFunctions.QuantileWindowFunction (implements stream.scotty.core.windowFunction.AggregateFunction<InputType,PartialAggregateType,FinalAggregateType>)
  • stream.scotty.core.windowType.SessionWindow (implements stream.scotty.core.windowType.ForwardContextAware)
  • stream.scotty.slicing.aggregationstore.test.windowTest.SessionWindowOperatorTest
  • stream.scotty.core.windowType.windowContext.ShiftModification (implements stream.scotty.core.windowType.windowContext.WindowModifications)
  • stream.scotty.slicing.slice.Slice.Fixed (implements stream.scotty.slicing.slice.Slice.Type)
  • stream.scotty.slicing.slice.Slice.Flexible (implements stream.scotty.slicing.slice.Slice.Type)
  • stream.scotty.slicing.slice.SliceFactory<InputType,ValueType>
  • stream.scotty.slicing.SliceManager<InputType>
  • stream.scotty.slicing.SlicingWindowOperator<InputType> (implements stream.scotty.core.WindowOperator<InputType>)
  • stream.scotty.microbenchmark.SlicingWindowOperatorBenchmark
  • stream.scotty.core.windowType.SlidingWindow (implements stream.scotty.core.windowType.ContextFreeWindow)
  • stream.scotty.slicing.aggregationstore.test.windowTest.SlidingWindowOperatorTest
  • stream.scotty.slicing.aggregationstore.test.StateFactoryMock (implements stream.scotty.state.StateFactory)
  • stream.scotty.slicing.StreamSlicer
  • stream.scotty.slicing.StreamSlicer.Edge
  • stream.scotty.flinkBenchmark.aggregations.SumAggregation (implements stream.scotty.core.windowFunction.InvertibleReduceAggregateFunction<Input>, java.io.Serializable)
  • stream.scotty.demo.flink.windowFunctions.SumWindowFunction (implements stream.scotty.core.windowFunction.InvertibleReduceAggregateFunction<Input>, java.io.Serializable)
  • stream.scotty.flinkBenchmark.ThroughputLogger<T> (implements org.apache.flink.api.common.functions.FlatMapFunction<T,O>)
  • stream.scotty.flinkBenchmark.ThroughputStatistics
  • stream.scotty.core.TimeMeasure
  • stream.scotty.core.windowType.TumblingWindow (implements stream.scotty.core.windowType.ContextFreeWindow)
  • stream.scotty.slicing.aggregationstore.test.windowTest.TumblingWindowOperatorTest
  • stream.scotty.slicing.aggregationstore.test.windowTest.WindowAssert
  • stream.scotty.core.windowType.windowContext.WindowContext<Tuple> (implements java.io.Serializable)
    • stream.scotty.core.windowType.SessionWindow.SessionContext
  • stream.scotty.core.windowType.windowContext.WindowContext.ActiveWindow (implements java.lang.Comparable<T>)
  • stream.scotty.slicing.WindowManager
  • stream.scotty.slicing.WindowManager.AggregationWindowCollector (implements java.lang.Iterable<T>, stream.scotty.core.WindowCollector)

Interface Hierarchy

• stream.scotty.slicing.aggregationstore.AggregationStore<InputType>
• stream.scotty.slicing.aggregationstore.AggregationStoreFactory
• java.io.Serializable
  • stream.scotty.core.windowFunction.AggregateFunction<InputType,PartialAggregateType,FinalAggregateType>
    • stream.scotty.core.windowFunction.CommutativeAggregateFunction<InputType,PartialAggregateType,FinalAggregateType>
    • stream.scotty.core.windowFunction.InvertibleAggregateFunction<InputType,PartialAggregateType,FinalAggregateType>
      • stream.scotty.core.windowFunction.InvertibleReduceAggregateFunction<Input> (also extends stream.scotty.core.windowFunction.ReduceAggregateFunction<InputType>)
    • stream.scotty.core.windowFunction.InvertibleReduceAggregateFunction<Input> (also extends stream.scotty.core.windowFunction.InvertibleAggregateFunction<InputType,PartialAggregateType,FinalAggregateType>, stream.scotty.core.windowFunction.ReduceAggregateFunction<InputType>)
    • stream.scotty.core.windowFunction.ReduceAggregateFunction<InputType>
      • stream.scotty.core.windowFunction.InvertibleReduceAggregateFunction<Input> (also extends stream.scotty.core.windowFunction.InvertibleAggregateFunction<InputType,PartialAggregateType,FinalAggregateType>)
  • stream.scotty.core.AggregateWindow<T>
  • stream.scotty.state.State
    • stream.scotty.state.ListState<ItemType>
    • stream.scotty.state.ValueState<ValueType>
  • stream.scotty.state.StateFactory
  • stream.scotty.core.windowType.Window
    • stream.scotty.core.windowType.ContextFreeWindow
    • stream.scotty.core.windowType.ForwardContextAware
    • stream.scotty.core.windowType.ForwardContextFree
  • stream.scotty.core.WindowOperator<InputType>
• stream.scotty.slicing.slice.Slice<InputType,ValueType>
• stream.scotty.slicing.slice.Slice.Type
• stream.scotty.core.windowType.TupleContext<Tuple>
• stream.scotty.core.WindowCollector
• stream.scotty.core.windowType.windowContext.WindowModifications

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • stream.scotty.core.windowType.WindowMeasure