| Package | Description | 
|---|---|
| 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. 
 | 
| com.hazelcast.jet.pipeline.test | 
 This package contains various mock sources to help with pipeline testing
 and development. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
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. 
 | 
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. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static <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 the  
SourceBuilder. | 
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 the  
SourceBuilder. | 
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 for  
SinkProcessors.writeBufferedP(FunctionEx, BiConsumerEx,
 ConsumerEx, ConsumerEx) with a no-op destroyFn. | 
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. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
TestProcessorContext
Processor.Context implementation suitable to be used in tests. | 
| Modifier and Type | Method and Description | 
|---|---|
BiFunctionEx<? super Processor.Context,? super C,? extends S> | 
ServiceFactory.createServiceFn()
Returns the function that creates the service object. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static <C> SourceBuilder.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 of  
nonSharedService(createFn, destroyFn) with a no-op destroyFn. | 
static <S> ServiceFactory<?,S> | 
ServiceFactories.nonSharedService(FunctionEx<? super Processor.Context,? extends S> createServiceFn,
                ConsumerEx<? super S> destroyServiceFn)
Returns a  
ServiceFactory 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 custom  
Sink for the Pipeline API. | 
static <C> SourceBuilder.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.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 this  
ServiceFactory with the given createService function. | 
| Modifier and Type | Method and Description | 
|---|---|
protected void | 
LongStreamSourceP.init(Processor.Context context)  | 
protected void | 
ParallelBatchP.init(Processor.Context context)  | 
protected void | 
ParallelStreamP.init(Processor.Context context)  | 
Copyright © 2023 Hazelcast, Inc.. All rights reserved.