Uses of Class
org.apache.storm.kafka.spout.KafkaSpoutConfig.ProcessingGuarantee
-
Packages that use KafkaSpoutConfig.ProcessingGuarantee Package Description org.apache.storm.kafka.spout org.apache.storm.kafka.spout.internal -
-
Uses of KafkaSpoutConfig.ProcessingGuarantee in org.apache.storm.kafka.spout
Fields in org.apache.storm.kafka.spout declared as KafkaSpoutConfig.ProcessingGuarantee Modifier and Type Field Description static KafkaSpoutConfig.ProcessingGuaranteeKafkaSpoutConfig. DEFAULT_PROCESSING_GUARANTEEMethods in org.apache.storm.kafka.spout that return KafkaSpoutConfig.ProcessingGuarantee Modifier and Type Method Description KafkaSpoutConfig.ProcessingGuaranteeKafkaSpoutConfig. getProcessingGuarantee()static KafkaSpoutConfig.ProcessingGuaranteeKafkaSpoutConfig.ProcessingGuarantee. valueOf(String name)Returns the enum constant of this type with the specified name.static KafkaSpoutConfig.ProcessingGuarantee[]KafkaSpoutConfig.ProcessingGuarantee. values()Returns an array containing the constants of this enum type, in the order they are declared.Methods in org.apache.storm.kafka.spout with parameters of type KafkaSpoutConfig.ProcessingGuarantee Modifier and Type Method Description KafkaSpoutConfig.Builder<K,V>KafkaSpoutConfig.Builder. setProcessingGuarantee(KafkaSpoutConfig.ProcessingGuarantee processingGuarantee)Specifies which processing guarantee the spout should offer. -
Uses of KafkaSpoutConfig.ProcessingGuarantee in org.apache.storm.kafka.spout.internal
Constructors in org.apache.storm.kafka.spout.internal with parameters of type KafkaSpoutConfig.ProcessingGuarantee Constructor Description CommitMetadataManager(TopologyContext context, KafkaSpoutConfig.ProcessingGuarantee processingGuarantee)Create a manager with the given context.
-