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.
|
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 <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.
|
static <W,T> DistributedSupplier<Processor> |
SinkProcessors.writeBufferedP(DistributedFunction<Processor.Context,W> createFn,
DistributedBiConsumer<W,T> onReceiveFn,
DistributedConsumer<W> flushFn)
Shortcut for
SinkProcessors.writeBufferedP(DistributedFunction,
DistributedBiConsumer, DistributedConsumer, DistributedConsumer) with
a no-op destroyFn . |
Modifier and Type | Class and Description |
---|---|
class |
TestProcessorContext
Processor.Context implementation suitable to be used in tests. |
Copyright © 2018 Hazelcast, Inc.. All rights reserved.