Hierarchy For Package edu.iu.dsc.tws.examples.task.streaming.windowing

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • edu.iu.dsc.tws.api.compute.nodes.BaseNode (implements edu.iu.dsc.tws.api.compute.modifiers.Closable, edu.iu.dsc.tws.api.compute.nodes.INode)
    • edu.iu.dsc.tws.api.compute.nodes.BaseCompute<T> (implements edu.iu.dsc.tws.api.compute.nodes.ICompute<T>)
      • edu.iu.dsc.tws.task.typed.AbstractSingleDataCompute<T>
        • edu.iu.dsc.tws.task.typed.DirectCompute<T>
          • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.DirectReceiveTask
          • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowExample.DirectReceiveTask
    • edu.iu.dsc.tws.task.window.api.BaseWindowSink<T> (implements edu.iu.dsc.tws.task.window.api.IWindowedSink<T>)
      • edu.iu.dsc.tws.task.window.core.AbstractSingleWindowDataSink<T>
        • edu.iu.dsc.tws.task.window.core.BaseWindowedSink<T> (implements edu.iu.dsc.tws.api.compute.modifiers.Closable, edu.iu.dsc.tws.task.window.IWindowCompute<T>)
          • edu.iu.dsc.tws.task.window.collectives.AggregateWindow<T>
            • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.DirectAggregateWindowedTask
            • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowExample.DirectAggregateWindowedTask
          • edu.iu.dsc.tws.task.window.collectives.FoldWindow<T,K>
            • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.DirectFoldWindowedTask
            • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowExample.DirectFoldWindowedTask
          • edu.iu.dsc.tws.task.window.collectives.ProcessWindow<T>
            • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.DirectProcessWindowedIntTask
            • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.DirectProcessWindowedTask
            • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowExample.DirectProcessWindowedTask
          • edu.iu.dsc.tws.task.window.collectives.ReduceWindow<T>
            • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.DirectReduceWindowedTask
            • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowExample.DirectReduceWindowedTask
          • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowCustomExample.DirectCustomWindowReceiver
          • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.DirectWindowedReceivingTask
          • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowExample.DirectWindowedReceivingTask
          • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowMPI.DirectWindowedReceivingTask
  • edu.iu.dsc.tws.examples.task.BenchTaskWorker (implements edu.iu.dsc.tws.api.resource.Twister2Worker)
    • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowCustomExample
    • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample
    • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowExample
    • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowMPI
  • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.AggregateFunctionImpl (implements edu.iu.dsc.tws.task.window.function.AggregateWindowedFunction<T>)
  • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.FoldFunctionImpl (implements edu.iu.dsc.tws.task.window.function.FoldWindowedFunction<T,K>)
  • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.ProcessFunctionImpl (implements edu.iu.dsc.tws.task.window.function.ProcessWindowedFunction<T>)
  • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.ProcessFunctionIntImpl (implements edu.iu.dsc.tws.task.window.function.ProcessWindowedFunction<T>)
  • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowEventTimeExample.ReduceFunctionImpl (implements edu.iu.dsc.tws.task.window.function.ReduceWindowedFunction<T>)
  • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowExample.AggregateFunctionImpl (implements edu.iu.dsc.tws.task.window.function.AggregateWindowedFunction<T>)
  • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowExample.FoldFunctionImpl (implements edu.iu.dsc.tws.task.window.function.FoldWindowedFunction<T,K>)
  • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowExample.ProcessFunctionImpl (implements edu.iu.dsc.tws.task.window.function.ProcessWindowedFunction<T>)
  • edu.iu.dsc.tws.examples.task.streaming.windowing.STWindowExample.ReduceFunctionImpl (implements edu.iu.dsc.tws.task.window.function.ReduceWindowedFunction<T>)