Class Hierarchy
- java.lang.Object
- org.apache.storm.topology.base.BaseComponent (implements org.apache.storm.topology.IComponent)
- org.apache.storm.topology.base.BaseBasicBolt (implements org.apache.storm.topology.IBasicBolt)
- org.apache.storm.lambda.LambdaBiConsumerBolt
- org.apache.storm.lambda.LambdaConsumerBolt
- org.apache.storm.topology.base.BaseRichSpout (implements org.apache.storm.topology.IRichSpout)
- org.apache.storm.lambda.LambdaSpout
- org.apache.storm.topology.base.BaseBasicBolt (implements org.apache.storm.topology.IBasicBolt)
- org.apache.storm.topology.base.BaseComponent (implements org.apache.storm.topology.IComponent)
Interface Hierarchy
- java.util.function.BiConsumer<T,
U> - org.apache.storm.lambda.SerializableBiConsumer<T,
U> (also extends java.io.Serializable)
- org.apache.storm.lambda.SerializableBiConsumer<T,
- java.util.concurrent.Callable<V>
- org.apache.storm.lambda.SerializableCallable<R> (also extends java.io.Serializable)
- java.util.function.Consumer<T>
- org.apache.storm.lambda.SerializableConsumer<T> (also extends java.io.Serializable)
- java.io.Serializable
- org.apache.storm.lambda.SerializableBiConsumer<T,
U> (also extends java.util.function.BiConsumer<T, U>) - org.apache.storm.lambda.SerializableCallable<R> (also extends java.util.concurrent.Callable<V>)
- org.apache.storm.lambda.SerializableConsumer<T> (also extends java.util.function.Consumer<T>)
- org.apache.storm.lambda.SerializableSupplier<T> (also extends java.util.function.Supplier<T>)
- org.apache.storm.lambda.SerializableBiConsumer<T,
- java.util.function.Supplier<T>
- org.apache.storm.lambda.SerializableSupplier<T> (also extends java.io.Serializable)