Uses of Annotation Type
org.apache.storm.annotation.InterfaceStability.Unstable

Packages that use InterfaceStability.Unstable

Package	Description
org.apache.storm.kafka.spout
org.apache.storm.streams
org.apache.storm.streams.processors

Uses of InterfaceStability.Unstable in org.apache.storm.kafka.spout

Classes in org.apache.storm.kafka.spout with annotations of type InterfaceStability.Unstable

Modifier and Type	Class	Description
static enum	KafkaSpoutConfig.ProcessingGuarantee	This enum controls when the tuple with the ConsumerRecord 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

Classes in org.apache.storm.streams with annotations of type InterfaceStability.Unstable

Modifier and Type	Class	Description
class	PairStream<K,V>	Represents a stream of key-value pairs.
class	Stream<T>	Represents a stream of values.
class	StreamBuilder	A builder for constructing a StormTopology via storm streams api (DSL).

Uses of InterfaceStability.Unstable in org.apache.storm.streams.processors

Classes in org.apache.storm.streams.processors with annotations of type InterfaceStability.Unstable

Modifier and Type	Interface	Description
interface	Processor<T>	A processor processes a stream of elements and produces some result.
interface	ProcessorContext<T>	Context information passed to the Processor.