| Package | Description |
|---|---|
| com.hazelcast.jet.processor |
Provides JET-processors
|
| Modifier and Type | Method and Description |
|---|---|
default void |
ContainerProcessor.afterProcessing(ProcessorContext processorContext)
Will be invoked strictly after last invocation of the corresponding task, strictly
from the executor thread
|
default void |
ContainerProcessor.beforeProcessing(ProcessorContext processorContext)
Will be invoked strictly before first invocation of the corresponding task, strictly
from the executor thread
|
default boolean |
ContainerProcessor.finalizeProcessor(ConsumerOutputStream<O> outputStream,
ProcessorContext processorContext)
Will be invoked on finalization phase
|
default boolean |
ContainerProcessor.process(ProducerInputStream<I> inputStream,
ConsumerOutputStream<O> outputStream,
String sourceName,
ProcessorContext processorContext)
Performs next iteration of execution
|
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.