# Hierarchy For Package org.apache.storm.streams.processors

Package Hierarchies:

- All Packages

## Class Hierarchy

- java.lang.Object
  - org.apache.storm.streams.processors.AggregateByKeyProcessor<K,V,A,R> (implements org.apache.storm.streams.processors.BatchProcessor)
  - org.apache.storm.streams.processors.AggregateProcessor<T,A,R> (implements org.apache.storm.streams.processors.BatchProcessor)
  - org.apache.storm.streams.processors.BranchProcessor<T>
  - org.apache.storm.streams.processors.ChainedProcessorContext (implements org.apache.storm.streams.processors.ProcessorContext)
  - org.apache.storm.streams.processors.CoGroupByKeyProcessor<K,V1,V2> (implements org.apache.storm.streams.processors.BatchProcessor)
  - org.apache.storm.streams.processors.EmittingProcessorContext (implements org.apache.storm.streams.processors.ProcessorContext)
  - org.apache.storm.streams.processors.FilterProcessor<T>
  - org.apache.storm.streams.processors.FlatMapProcessor<T,R>
  - org.apache.storm.streams.processors.FlatMapValuesProcessor<K,V,R>
  - org.apache.storm.streams.processors.ForEachProcessor<T>
  - org.apache.storm.streams.processors.ForwardingProcessorContext (implements org.apache.storm.streams.processors.ProcessorContext)
  - org.apache.storm.streams.processors.JoinProcessor<K,R,V1,V2> (implements org.apache.storm.streams.processors.BatchProcessor)
  - org.apache.storm.streams.processors.MapProcessor<T,R>
  - org.apache.storm.streams.processors.MapValuesProcessor<K,V,R>
  - org.apache.storm.streams.processors.MergeAggregateByKeyProcessor<K,V,A,R> (implements org.apache.storm.streams.processors.BatchProcessor)
  - org.apache.storm.streams.processors.MergeAggregateProcessor<T,A,R> (implements org.apache.storm.streams.processors.BatchProcessor)
  - org.apache.storm.streams.processors.PeekProcessor<T>
  - org.apache.storm.streams.processors.ReduceByKeyProcessor<K,V> (implements org.apache.storm.streams.processors.BatchProcessor)
  - org.apache.storm.streams.processors.ReduceProcessor<T> (implements org.apache.storm.streams.processors.BatchProcessor)
  - org.apache.storm.streams.processors.StateQueryProcessor<K,V> (implements org.apache.storm.streams.processors.StatefulProcessor<K,V>)
  - org.apache.storm.streams.processors.UpdateStateByKeyProcessor<K,V,R> (implements org.apache.storm.streams.processors.StatefulProcessor<K,V>)

## Interface Hierarchy

- org.apache.storm.streams.processors.BatchProcessor
- java.io.Serializable
  - org.apache.storm.streams.processors.Processor<T>
  - org.apache.storm.streams.processors.ProcessorContext
- org.apache.storm.streams.processors.StatefulProcessor<K,V>

## Enum Hierarchy

- java.lang.Object
  - java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    - org.apache.storm.streams.processors.JoinProcessor.JoinType

Copyright © 2021 The Apache Software Foundation. All rights reserved.