## Uses of Interface
com.hazelcast.jet.core.Processor.Context

- Packages that use Processor.Context
  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.

- - ### Uses of Processor.Context in com.hazelcast.jet.core

    Methods in com.hazelcast.jet.core with parameters of type Processor.Context
    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.

  - ### Uses of Processor.Context in com.hazelcast.jet.core.processor

    Method parameters in com.hazelcast.jet.core.processor with type arguments of type Processor.Context
    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)` 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.

  - ### Uses of Processor.Context in com.hazelcast.jet.core.test

    Classes in com.hazelcast.jet.core.test that implement Processor.Context
    Modifier and Type | Class and Description
    --- | ---
    `class` | `TestProcessorContext` `Processor.Context` implementation suitable to be used in tests.

  - ### Uses of Processor.Context in com.hazelcast.jet.pipeline

    Method parameters in com.hazelcast.jet.pipeline with type arguments of type Processor.Context
    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 <W> SinkBuilder<W,Void>` | SinkBuilder.`sinkBuilder(String name, FunctionEx<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 <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.

Copyright © 2020. All rights reserved.