Uses of Annotation Interface
org.apache.storm.annotation.InterfaceStability.Unstable
Package
Description
-
Uses of InterfaceStability.Unstable in org.apache.storm.kafka.spout
Modifier and TypeClassDescriptionstatic enum
This enum controls when the tuple with theConsumerRecord
for an offset is marked as processed, i.e. -
Uses of InterfaceStability.Unstable in org.apache.storm.streams
Modifier and TypeClassDescriptionclass
PairStream<K,
V> Represents a stream of key-value pairs.class
Stream<T>
Represents a stream of values.class
A builder for constructing aStormTopology
via storm streams api (DSL). -
Uses of InterfaceStability.Unstable in org.apache.storm.streams.processors