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 Description static classKafkaSpoutConfig.ProcessingGuaranteeThis enum controls when the tuple with theConsumerRecordfor 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 Description classPairStream<K,V>Represents a stream of key-value pairs.classStream<T>Represents a stream of values.classStreamBuilderA builder for constructing aStormTopologyvia 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 interfaceProcessor<T>A processor processes a stream of elements and produces some result.interfaceProcessorContext<T>Context information passed to theProcessor.
-