Uses of Annotation Type
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. when the offset can be committed to Kafka. -
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