Uses of Class
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 and Description
static class	KafkaSpoutConfig.ProcessingGuarantee This enum controls when the tuple with the ConsumerRecord for an offset is marked as processed, i.e.

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 and 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 and Description
interface	Processor<T> A processor processes a stream of elements and produces some result.
interface	ProcessorContext Context information passed to the Processor.