Uses of Interface
com.hazelcast.jet.core.Processor.Context
Package
Description
Jet's Core API.
Contains static utility classes with factories of Jet processors.
Utilities for writing tests of Core API Processors.
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 Processor.Context in com.hazelcast.jet.core
Modifier and TypeMethodDescriptionfinal void
AbstractProcessor.init
(Outbox outbox, Processor.Context context) protected void
AbstractProcessor.init
(Processor.Context context) Method that can be overridden to perform any necessary initialization for the processor.default void
Processor.init
(Outbox outbox, Processor.Context context) Initializes this processor with the outbox that the processing methods must use to deposit their output items. -
Uses of Processor.Context in com.hazelcast.jet.core.processor
Modifier and TypeMethodDescriptionstatic <C,
T, S> ProcessorMetaSupplier SourceProcessors.convenientSourceP
(FunctionEx<? super Processor.Context, ? extends C> createFn, BiConsumerEx<? super C, ? super SourceBuilder.SourceBuffer<T>> fillBufferFn, FunctionEx<? super C, ? extends S> createSnapshotFn, BiConsumerEx<? super C, ? super List<S>> restoreSnapshotFn, ConsumerEx<? super C> destroyFn, int preferredLocalParallelism, boolean isBatch, Permission permission) Returns a supplier of processors for a source that the user can create using theSourceBuilder
.static <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 <W,
T> SupplierEx<Processor> SinkProcessors.writeBufferedP
(FunctionEx<? super Processor.Context, ? extends W> createFn, BiConsumerEx<? super W, ? super T> onReceiveFn, ConsumerEx<? super W> flushFn) Shortcut forSinkProcessors.writeBufferedP(FunctionEx, BiConsumerEx, ConsumerEx, ConsumerEx)
with a no-opdestroyFn
.static <W,
T> SupplierEx<Processor> SinkProcessors.writeBufferedP
(FunctionEx<? super Processor.Context, ? extends W> createFn, BiConsumerEx<? super W, ? super T> onReceiveFn, ConsumerEx<? super W> flushFn, ConsumerEx<? super W> destroyFn) Returns a supplier of processors for a vertex that drains all the items from the inbox to an internal writer object and then does a flush. -
Uses of Processor.Context in com.hazelcast.jet.core.test
Modifier and TypeClassDescriptionclass
Processor.Context
implementation suitable to be used in tests. -
Uses of Processor.Context in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescriptionBiFunctionEx<? super Processor.Context,
? super C, ? extends S> ServiceFactory.createServiceFn()
Returns the function that creates the service object.Modifier and TypeMethodDescriptionstatic <C> SourceBuilder<C>.Batch<Void>
SourceBuilder.batch
(String name, FunctionEx<? super Processor.Context, ? extends C> createFn) Returns a fluent-API builder with which you can create a batch source for a Jet pipeline.static <S> ServiceFactory<?,
S> ServiceFactories.nonSharedService
(FunctionEx<? super Processor.Context, ? extends S> createServiceFn) A variant ofnonSharedService(createFn, destroyFn)
with a no-opdestroyFn
.static <S> ServiceFactory<?,
S> ServiceFactories.nonSharedService
(FunctionEx<? super Processor.Context, ? extends S> createServiceFn, ConsumerEx<? super S> destroyServiceFn) Returns aServiceFactory
which creates a separate service instance for each parallel Jet processor.static <C> SinkBuilder<C,
Void> SinkBuilder.sinkBuilder
(String name, FunctionEx<Processor.Context, ? extends C> createFn) Returns a builder object that offers a step-by-step fluent API to build a customSink
for the Pipeline API.static <C> SourceBuilder<C>.Stream<Void>
SourceBuilder.stream
(String name, FunctionEx<? super Processor.Context, ? extends C> createFn) Returns a fluent-API builder with which you can create an unbounded stream source for a Jet pipeline.static <C> SourceBuilder<C>.TimestampedStream<Void>
SourceBuilder.timestampedStream
(String name, FunctionEx<? super Processor.Context, ? extends C> createFn) Returns a fluent-API builder with which you can create an unbounded stream source for a Jet pipeline.<S_NEW> ServiceFactory<C,
S_NEW> ServiceFactory.withCreateServiceFn
(BiFunctionEx<? super Processor.Context, ? super C, ? extends S_NEW> createServiceFn) Returns a copy of thisServiceFactory
with the givencreateService
function. -
Uses of Processor.Context in com.hazelcast.jet.pipeline.test
Modifier and TypeMethodDescriptionprotected void
LongStreamSourceP.init
(Processor.Context context) protected void
ParallelBatchP.init
(Processor.Context context) protected void
ParallelStreamP.init
(Processor.Context context)