Uses of 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 and Description
ProcessingGuarantee	JobConfig.getProcessingGuarantee() Returns the configured processing 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 and 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 and 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 and Description
static <T> ProcessorMetaSupplier	SourceProcessors.streamJmsQueueP(String destination, ProcessingGuarantee maxGuarantee, EventTimePolicy<? super T> eventTimePolicy, 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) Returns a supplier of processors for Sources.jmsQueueBuilder(com.hazelcast.function.SupplierEx<? extends javax.jms.ConnectionFactory>).
static <T> ProcessorMetaSupplier	SourceProcessors.streamJmsTopicP(String destination, boolean isSharedConsumer, ProcessingGuarantee maxGuarantee, EventTimePolicy<? super T> eventTimePolicy, 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) Returns a supplier of processors for Sources.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 and Description
ProcessingGuarantee	TestProcessorMetaSupplierContext.processingGuarantee()

Methods in com.hazelcast.jet.core.test with parameters of type ProcessingGuarantee

Modifier and Type	Method and Description
TestProcessorMetaSupplierContext	TestProcessorMetaSupplierContext.setProcessingGuarantee(ProcessingGuarantee processingGuarantee) Sets the processing guarantee.
TestProcessorContext	TestProcessorContext.setProcessingGuarantee(ProcessingGuarantee processingGuarantee)
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 and Description
JmsSourceBuilder	JmsSourceBuilder.maxGuarantee(ProcessingGuarantee guarantee) Sets the maximum processing guarantee for the source.