## Uses of Interface
com.hazelcast.jet.function.DistributedConsumer

- Packages that use DistributedConsumer
  Package | Description
  --- | ---
  com.hazelcast.jet.core.processor | Contains static utility classes with factories of Jet processors.
  com.hazelcast.jet.function | Serializable and exception-declaring variants of functional interfaces from `java.util.function`.
  com.hazelcast.jet.pipeline | The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

- - ### Uses of DistributedConsumer in com.hazelcast.jet.core.processor

    Methods in com.hazelcast.jet.core.processor with parameters of type DistributedConsumer
    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 <T> ProcessorMetaSupplier` | SourceProcessors.`streamJmsQueueP(DistributedSupplier<? extends javax.jms.Connection> connectionSupplier, DistributedFunction<? super javax.jms.Connection,? extends javax.jms.Session> sessionFn, DistributedFunction<? super javax.jms.Session,? extends javax.jms.MessageConsumer> consumerFn, DistributedConsumer<? super javax.jms.Session> flushFn, DistributedFunction<? super javax.jms.Message,? extends T> projectionFn)` Returns a supplier of processors for `Sources.jmsQueueBuilder(com.hazelcast.jet.function.DistributedSupplier<? extends javax.jms.ConnectionFactory>)`.
    `static <T> ProcessorMetaSupplier` | SourceProcessors.`streamJmsTopicP(DistributedSupplier<? extends javax.jms.Connection> connectionSupplier, DistributedFunction<? super javax.jms.Connection,? extends javax.jms.Session> sessionFn, DistributedFunction<? super javax.jms.Session,? extends javax.jms.MessageConsumer> consumerFn, DistributedConsumer<? super javax.jms.Session> flushFn, DistributedFunction<? super javax.jms.Message,? extends T> projectionFn)` Returns a supplier of processors for `Sources.jmsTopicBuilder(com.hazelcast.jet.function.DistributedSupplier<? extends javax.jms.ConnectionFactory>)`.
    `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.
    `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 <T> ProcessorMetaSupplier` | SinkProcessors.`writeJmsQueueP(DistributedSupplier<? extends javax.jms.Connection> connectionSupplier, DistributedFunction<? super javax.jms.Connection,? extends javax.jms.Session> sessionF, DistributedBiFunction<? super javax.jms.Session,? super T,? extends javax.jms.Message> messageFn, DistributedBiConsumer<? super javax.jms.MessageProducer,? super javax.jms.Message> sendFn, DistributedConsumer<? super javax.jms.Session> flushFn, String name)` Returns a supplier of processors for `Sinks.jmsQueueBuilder(com.hazelcast.jet.function.DistributedSupplier<javax.jms.ConnectionFactory>)`.
    `static <T> ProcessorMetaSupplier` | SinkProcessors.`writeJmsTopicP(DistributedSupplier<? extends javax.jms.Connection> connectionSupplier, DistributedFunction<? super javax.jms.Connection,? extends javax.jms.Session> sessionF, DistributedBiFunction<? super javax.jms.Session,? super T,? extends javax.jms.Message> messageFn, DistributedBiConsumer<? super javax.jms.MessageProducer,? super javax.jms.Message> sendFn, DistributedConsumer<? super javax.jms.Session> flushFn, String name)` Returns a supplier of processors for `Sinks.jmsTopicBuilder(com.hazelcast.jet.function.DistributedSupplier<javax.jms.ConnectionFactory>)`.

  - ### Uses of DistributedConsumer in com.hazelcast.jet.function

    Methods in com.hazelcast.jet.function that return DistributedConsumer
    Modifier and Type | Method and Description
    --- | ---
    `default DistributedConsumer<T>` | DistributedConsumer.`andThen(DistributedConsumer<? super T> after)` `Serializable` variant of `java.util.function.Consumer#andThen(Consumer)`.
    `static <T> DistributedConsumer<T>` | DistributedConsumer.`noop()` Returns a consumer that does nothing.

    Methods in com.hazelcast.jet.function with parameters of type DistributedConsumer
    Modifier and Type | Method and Description
    --- | ---
    `default DistributedConsumer<T>` | DistributedConsumer.`andThen(DistributedConsumer<? super T> after)` `Serializable` variant of `java.util.function.Consumer#andThen(Consumer)`.

  - ### Uses of DistributedConsumer in com.hazelcast.jet.pipeline

    Methods in com.hazelcast.jet.pipeline that return DistributedConsumer
    Modifier and Type | Method and Description
    --- | ---
    `DistributedConsumer<? super C>` | ContextFactory.`destroyFn()` Returns the destroy-function.

    Methods in com.hazelcast.jet.pipeline with parameters of type DistributedConsumer
    Modifier and Type | Method and Description
    --- | ---
    `SourceBuilder.Batch<T>` | SourceBuilder.Batch.`destroyFn(DistributedConsumer<? super S> destroyFn)`
    `SourceBuilder.Stream<T>` | SourceBuilder.Stream.`destroyFn(DistributedConsumer<? super S> pDestroyFn)`
    `SourceBuilder.TimestampedStream<T>` | SourceBuilder.TimestampedStream.`destroyFn(DistributedConsumer<? super S> pDestroyFn)`
    `SinkBuilder<W,T>` | SinkBuilder.`destroyFn(DistributedConsumer<? super W> destroyFn)` Sets the function that will destroy the writer and perform any cleanup.
    `JmsSourceBuilder` | JmsSourceBuilder.`flushFn(DistributedConsumer<? super javax.jms.Session> flushFn)` Sets the function which commits the session after consuming each message.
    `SinkBuilder<W,T>` | SinkBuilder.`flushFn(DistributedConsumer<? super W> flushFn)` Sets the function that implements the sink's flushing behavior.
    `JmsSinkBuilder<T>` | JmsSinkBuilder.`flushFn(DistributedConsumer<javax.jms.Session> flushFn)` Sets the function which flushes the session after a batch of messages is sent.
    `ContextFactory<C>` | ContextFactory.`withDestroyFn(DistributedConsumer<? super C> destroyFn)` Returns a copy of this `ContextFactory` with the destroy-function replaced with the given function.

Copyright © 2018. All rights reserved.