Uses of Class
com.hazelcast.jet.config.ProcessingGuarantee
Package | Description |
---|---|
com.hazelcast.jet.config |
Jet's configuration data objects.
|
com.hazelcast.jet.core |
Jet's Core API.
|
com.hazelcast.jet.core.processor |
Contains static utility classes with factories of Jet processors.
|
com.hazelcast.jet.core.test |
Utilities for writing tests of Core API Processors.
|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
-
Uses of ProcessingGuarantee in com.hazelcast.jet.config
Methods in com.hazelcast.jet.config that return ProcessingGuarantee Modifier and Type Method Description ProcessingGuarantee
JobConfig. getProcessingGuarantee()
Returns the configuredprocessing guarantee
.static ProcessingGuarantee
ProcessingGuarantee. valueOf(String name)
Returns the enum constant of this type with the specified name.static ProcessingGuarantee[]
ProcessingGuarantee. values()
Returns an array containing the constants of this enum type, in the order they are declared.Methods in com.hazelcast.jet.config with parameters of type ProcessingGuarantee Modifier and Type Method Description JobConfig
JobConfig. setProcessingGuarantee(ProcessingGuarantee processingGuarantee)
Set theprocessing guarantee
for the job. -
Uses of ProcessingGuarantee in com.hazelcast.jet.core
Methods in com.hazelcast.jet.core that return ProcessingGuarantee Modifier and Type Method Description ProcessingGuarantee
ProcessorMetaSupplier.Context. processingGuarantee()
Returns the guarantee for current job. -
Uses of ProcessingGuarantee in com.hazelcast.jet.core.processor
Methods in com.hazelcast.jet.core.processor with parameters of type ProcessingGuarantee Modifier and Type Method Description static <T> ProcessorMetaSupplier
SourceProcessors. streamJmsQueueP(SupplierEx<? extends javax.jms.Connection> newConnectionFn, FunctionEx<? super javax.jms.Session,? extends javax.jms.MessageConsumer> consumerFn, FunctionEx<? super javax.jms.Message,?> messageIdFn, FunctionEx<? super javax.jms.Message,? extends T> projectionFn, EventTimePolicy<? super T> eventTimePolicy, ProcessingGuarantee maxGuarantee)
Returns a supplier of processors forSources.jmsQueueBuilder(com.hazelcast.function.SupplierEx<? extends javax.jms.ConnectionFactory>)
.static <T> ProcessorMetaSupplier
SourceProcessors. streamJmsTopicP(SupplierEx<? extends javax.jms.Connection> newConnectionFn, FunctionEx<? super javax.jms.Session,? extends javax.jms.MessageConsumer> consumerFn, boolean isSharedConsumer, FunctionEx<? super javax.jms.Message,?> messageIdFn, FunctionEx<? super javax.jms.Message,? extends T> projectionFn, EventTimePolicy<? super T> eventTimePolicy, ProcessingGuarantee maxGuarantee)
Returns a supplier of processors forSources.jmsTopicBuilder(com.hazelcast.function.SupplierEx<? extends javax.jms.ConnectionFactory>)
. -
Uses of ProcessingGuarantee in com.hazelcast.jet.core.test
Methods in com.hazelcast.jet.core.test that return ProcessingGuarantee Modifier and Type Method Description ProcessingGuarantee
TestProcessorMetaSupplierContext. processingGuarantee()
Methods in com.hazelcast.jet.core.test with parameters of type ProcessingGuarantee Modifier and Type Method Description TestProcessorContext
TestProcessorContext. setProcessingGuarantee(ProcessingGuarantee processingGuarantee)
TestProcessorMetaSupplierContext
TestProcessorMetaSupplierContext. setProcessingGuarantee(ProcessingGuarantee processingGuarantee)
Sets the processing guarantee.TestProcessorSupplierContext
TestProcessorSupplierContext. setProcessingGuarantee(ProcessingGuarantee processingGuarantee)
-
Uses of ProcessingGuarantee in com.hazelcast.jet.pipeline
Methods in com.hazelcast.jet.pipeline with parameters of type ProcessingGuarantee Modifier and Type Method Description JmsSourceBuilder
JmsSourceBuilder. maxGuarantee(ProcessingGuarantee guarantee)
Sets the maximum processing guarantee for the source.