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.
|
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 <S,T> ProcessorMetaSupplier |
SourceProcessors.convenientSourceP(DistributedFunction<? super Processor.Context,? extends S> createFn,
DistributedBiConsumer<? super S,? super SourceBuilder.SourceBuffer<T>> fillBufferFn,
DistributedConsumer<? super S> destroyFn,
int preferredLocalParallelism)
Returns a supplier of processors for a source that the user can create
using the
SourceBuilder . |
static <S,T> ProcessorMetaSupplier |
SourceProcessors.convenientTimestampedSourceP(DistributedFunction<? super Processor.Context,? extends S> createFn,
DistributedBiConsumer<? super S,? super SourceBuilder.TimestampedSourceBuffer<T>> fillBufferFn,
WatermarkGenerationParams<? super com.hazelcast.jet.impl.JetEvent<T>> wmParams,
DistributedConsumer<? super S> destroyFn,
int preferredLocalParallelism)
Returns a supplier of processors for a source that the user can create
using the
SourceBuilder . |
static <W,T> DistributedSupplier<Processor> |
SinkProcessors.writeBufferedP(DistributedFunction<? super Processor.Context,? extends W> createFn,
DistributedBiConsumer<? super W,? super T> onReceiveFn,
DistributedConsumer<? super W> flushFn)
Shortcut for
SinkProcessors.writeBufferedP(DistributedFunction,
DistributedBiConsumer, DistributedConsumer, DistributedConsumer) with
a no-op destroyFn . |
static <W,T> DistributedSupplier<Processor> |
SinkProcessors.writeBufferedP(DistributedFunction<? super Processor.Context,? extends W> createFn,
DistributedBiConsumer<? super W,? super T> onReceiveFn,
DistributedConsumer<? super W> flushFn,
DistributedConsumer<? 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 |
---|---|
static <S> SourceBuilder.Batch<Void> |
SourceBuilder.batch(String name,
DistributedFunction<? super Processor.Context,? extends S> createFn)
Returns a fluent-API builder with which you can create a batch source for a Jet pipeline.
|
static <W> SinkBuilder<W,Void> |
SinkBuilder.sinkBuilder(String name,
DistributedFunction<Processor.Context,? extends W> createFn)
Returns a builder object that offers a step-by-step fluent API to build
a custom
Sink for the Pipeline API. |
static <S> SourceBuilder.Stream<Void> |
SourceBuilder.stream(String name,
DistributedFunction<? super Processor.Context,? extends S> createFn)
Returns a fluent-API builder with which you can create an unbounded stream source for a Jet pipeline.
|
static <S> SourceBuilder.TimestampedStream<Void> |
SourceBuilder.timestampedStream(String name,
DistributedFunction<? super Processor.Context,? extends S> createFn)
Returns a fluent-API builder with which you can create an unbounded stream source for a Jet pipeline.
|
Copyright © 2018 Hazelcast, Inc.. All rights reserved.