Uses of Enum Class
com.hazelcast.jet.config.ProcessingGuarantee

Packages that use 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 configured processing guarantee.
static ProcessingGuarantee	ProcessingGuarantee.valueOf(String name)	Returns the enum constant of this class with the specified name.
static ProcessingGuarantee[]	ProcessingGuarantee.values()	Returns an array containing the constants of this enum class, 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 the processing 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(String destination, ProcessingGuarantee maxGuarantee, EventTimePolicy<? super T> eventTimePolicy, SupplierEx<? extends jakarta.jms.Connection> newConnectionFn, FunctionEx<? super jakarta.jms.Session,? extends jakarta.jms.MessageConsumer> consumerFn, FunctionEx<? super jakarta.jms.Message,?> messageIdFn, FunctionEx<? super jakarta.jms.Message,? extends T> projectionFn)	Returns a supplier of processors for Sources.jmsQueueBuilder(com.hazelcast.function.SupplierEx<? extends jakarta.jms.ConnectionFactory>).
static <T> ProcessorMetaSupplier	SourceProcessors.streamJmsTopicP(String destination, boolean isSharedConsumer, ProcessingGuarantee maxGuarantee, EventTimePolicy<? super T> eventTimePolicy, SupplierEx<? extends jakarta.jms.Connection> newConnectionFn, FunctionEx<? super jakarta.jms.Session,? extends jakarta.jms.MessageConsumer> consumerFn, FunctionEx<? super jakarta.jms.Message,?> messageIdFn, FunctionEx<? super jakarta.jms.Message,? extends T> projectionFn)	Returns a supplier of processors for Sources.jmsTopicBuilder(com.hazelcast.function.SupplierEx<? extends jakarta.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.