Uses of Class
com.hazelcast.jet.core.EventTimePolicy
Package
Description
Jet's Core API.
Contains static utility classes with factories of Jet processors.
Apache Kafka reader/writer support for Hazelcast Jet.
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
This package contains various mock sources to help with pipeline testing
and development.
-
Uses of EventTimePolicy in com.hazelcast.jet.core
Modifier and TypeMethodDescriptionstatic <T> EventTimePolicy<T>
EventTimePolicy.eventTimePolicy
(ToLongFunctionEx<? super T> timestampFn, SupplierEx<? extends WatermarkPolicy> newWmPolicyFn, long watermarkThrottlingFrameSize, long watermarkThrottlingFrameOffset, long idleTimeoutMillis) Creates and returns a new event time policy.static <T> EventTimePolicy<T>
EventTimePolicy.eventTimePolicy
(ToLongFunctionEx<? super T> timestampFn, ObjLongBiFunction<? super T, ?> wrapFn, SupplierEx<? extends WatermarkPolicy> newWmPolicyFn, long watermarkThrottlingFrameSize, long watermarkThrottlingFrameOffset, long idleTimeoutMillis) Creates and returns a new event time policy.static <T> EventTimePolicy<T>
EventTimePolicy.eventTimePolicy
(ToLongFunctionEx<? super T> timestampFn, ObjLongBiFunction<? super T, ?> wrapFn, SupplierEx<? extends WatermarkPolicy> newWmPolicyFn, long watermarkThrottlingFrameSize, long watermarkThrottlingFrameOffset, long idleTimeoutMillis, byte wmKey) Creates and returns a new event time policy.static <T> EventTimePolicy<T>
EventTimePolicy.noEventTime()
Returns an event time policy that results in no timestamping.ModifierConstructorDescriptionEventTimeMapper
(EventTimePolicy<? super T> eventTimePolicy) The partition count is initially set to 0, callEventTimeMapper.addPartitions(int)
to add partitions. -
Uses of EventTimePolicy in com.hazelcast.jet.core.processor
Modifier and TypeMethodDescriptionstatic <C,
T, S> ProcessorMetaSupplier SourceProcessors.convenientTimestampedSourceP
(FunctionEx<? super Processor.Context, ? extends C> createFn, BiConsumerEx<? super C, ? super SourceBuilder.TimestampedSourceBuffer<T>> fillBufferFn, EventTimePolicy<? super T> eventTimePolicy, FunctionEx<? super C, ? extends S> createSnapshotFn, BiConsumerEx<? super C, ? super List<S>> restoreSnapshotFn, ConsumerEx<? super C> destroyFn, int preferredLocalParallelism) Returns a supplier of processors for a source that the user can create using theSourceBuilder
.static <T> SupplierEx<Processor>
Processors.insertWatermarksP
(EventTimePolicy<? super T> eventTimePolicy) Returns a supplier of processors for a vertex that insertswatermark items
into the stream.static <T,
K, V> ProcessorMetaSupplier SourceProcessors.streamCacheP
(String cacheName, PredicateEx<? super EventJournalCacheEvent<K, V>> predicateFn, FunctionEx<? super EventJournalCacheEvent<K, V>, ? extends T> projectionFn, JournalInitialPosition initialPos, EventTimePolicy<? super T> eventTimePolicy) Returns a supplier of processors forSources.cacheJournal(String, JournalInitialPosition, FunctionEx, PredicateEx)
.static <K,
V> ProcessorMetaSupplier SourceProcessors.streamCacheP
(String cacheName, JournalInitialPosition initialPos, EventTimePolicy<? super Map.Entry<K, V>> eventTimePolicy) Returns a supplier of processors forSources.cacheJournal(String, JournalInitialPosition)
.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 forSources.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 forSources.jmsTopicBuilder(com.hazelcast.function.SupplierEx<? extends jakarta.jms.ConnectionFactory>)
.static <T,
K, V> ProcessorMetaSupplier SourceProcessors.streamMapP
(String mapName, PredicateEx<? super EventJournalMapEvent<K, V>> predicateFn, FunctionEx<? super EventJournalMapEvent<K, V>, ? extends T> projectionFn, JournalInitialPosition initialPos, EventTimePolicy<? super T> eventTimePolicy) Returns a supplier of processors forSources.mapJournal(String, JournalInitialPosition, FunctionEx, PredicateEx)
.static <K,
V> ProcessorMetaSupplier SourceProcessors.streamMapP
(String mapName, JournalInitialPosition initialPos, EventTimePolicy<? super Map.Entry<K, V>> eventTimePolicy) Returns a supplier of processors forSources.mapJournal(String, JournalInitialPosition)
.static <T,
K, V> ProcessorMetaSupplier SourceProcessors.streamRemoteCacheP
(String cacheName, ClientConfig clientConfig, PredicateEx<? super EventJournalCacheEvent<K, V>> predicateFn, FunctionEx<? super EventJournalCacheEvent<K, V>, ? extends T> projectionFn, JournalInitialPosition initialPos, EventTimePolicy<? super T> eventTimePolicy) Returns a supplier of processors forSources.remoteCacheJournal(String, ClientConfig, JournalInitialPosition, FunctionEx, PredicateEx)
.static <K,
V> ProcessorMetaSupplier SourceProcessors.streamRemoteCacheP
(String cacheName, ClientConfig clientConfig, JournalInitialPosition initialPos, EventTimePolicy<? super Map.Entry<K, V>> eventTimePolicy) Returns a supplier of processors forSources.remoteCacheJournal(String, ClientConfig, JournalInitialPosition)
.static <T,
K, V> ProcessorMetaSupplier SourceProcessors.streamRemoteMapP
(String mapName, ClientConfig clientConfig, PredicateEx<? super EventJournalMapEvent<K, V>> predicateFn, FunctionEx<? super EventJournalMapEvent<K, V>, ? extends T> projectionFn, JournalInitialPosition initialPos, EventTimePolicy<? super T> eventTimePolicy) Returns a supplier of processors forSources.remoteMapJournal(String, ClientConfig, JournalInitialPosition, FunctionEx, PredicateEx)
.static <K,
V> ProcessorMetaSupplier SourceProcessors.streamRemoteMapP
(String mapName, ClientConfig clientConfig, JournalInitialPosition initialPos, EventTimePolicy<? super Map.Entry<K, V>> eventTimePolicy) Returns a supplier of processors forSources.remoteMapJournal(String, ClientConfig, JournalInitialPosition)
.Modifier and TypeMethodDescriptionstatic <T> SupplierEx<Processor>
Processors.insertWatermarksP
(FunctionEx<ProcessorSupplier.Context, EventTimePolicy<? super T>> eventTimePolicyProvider) Returns a supplier of processors for a vertex that insertswatermark items
into the stream. -
Uses of EventTimePolicy in com.hazelcast.jet.kafka
Modifier and TypeMethodDescriptionstatic <K,
V, T> ProcessorMetaSupplier KafkaProcessors.streamKafkaP
(DataConnectionRef dataConnectionRef, FunctionEx<? super org.apache.kafka.clients.consumer.ConsumerRecord<K, V>, ? extends T> projectionFn, EventTimePolicy<? super T> eventTimePolicy, String... topics) Returns a supplier of processors forKafkaSources.kafka(DataConnectionRef, FunctionEx, String...)
.static <K,
V, T> ProcessorMetaSupplier KafkaProcessors.streamKafkaP
(Properties properties, FunctionEx<? super org.apache.kafka.clients.consumer.ConsumerRecord<K, V>, ? extends T> projectionFn, EventTimePolicy<? super T> eventTimePolicy, TopicsConfig topicsConfig) Returns a supplier of processors forKafkaSources.kafka(Properties, FunctionEx, TopicsConfig)
}.static <K,
V, T> ProcessorMetaSupplier KafkaProcessors.streamKafkaP
(Properties properties, FunctionEx<? super org.apache.kafka.clients.consumer.ConsumerRecord<K, V>, ? extends T> projectionFn, EventTimePolicy<? super T> eventTimePolicy, String... topics) Returns a supplier of processors forKafkaSources.kafka(Properties, FunctionEx, String...)
. -
Uses of EventTimePolicy in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescriptionstatic <T> StreamSource<T>
Sources.streamFromProcessorWithWatermarks
(String sourceName, boolean supportsNativeTimestamps, FunctionEx<EventTimePolicy<? super T>, ProcessorMetaSupplier> metaSupplierFn) Returns an unbounded (event stream) source that will use the supplied function to create processor meta-suppliers as required by the Core API. -
Uses of EventTimePolicy in com.hazelcast.jet.pipeline.test
ModifierConstructorDescriptionParallelStreamP
(long eventsPerSecondPerGenerator, EventTimePolicy<? super T> eventTimePolicy, List<? extends GeneratorFunction<T>> generators) Creates a processor that generates items using its assigned generator functions.