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

- Packages that use BiConsumerEx
  Package | Description
  --- | ---
  com.hazelcast.jet.aggregate | Contains `AggregateOperation` and several its variants, as well as a builder object for the aggregate operations.
  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.
  com.hazelcast.jet.pipeline.test | This package contains various mock sources to help with pipeline testing and development.

- - ### Uses of BiConsumerEx in com.hazelcast.jet.aggregate

    Methods in com.hazelcast.jet.aggregate that return BiConsumerEx
    Modifier and Type | Method and Description
    --- | ---
    `BiConsumerEx<? super A,? super T>` | AggregateOperation1.`accumulateFn()` A primitive that updates the accumulator state to account for a new item.
    `<T> BiConsumerEx<? super A,? super T>` | AggregateOperation.`accumulateFn(int index)` A primitive that updates the accumulator state to account for a new item.
    `default <T> BiConsumerEx<? super A,? super T>` | AggregateOperation.`accumulateFn(Tag<T> tag)` A primitive that updates the accumulator state to account for a new item.
    `BiConsumerEx<? super A,? super T0>` | AggregateOperation3.`accumulateFn0()` A primitive that updates the accumulator state to account for a new item coming from stream-0.
    `BiConsumerEx<? super A,? super T0>` | AggregateOperation2.`accumulateFn0()` A primitive that updates the accumulator state to account for a new item coming from stream-0.
    `BiConsumerEx<? super A,? super T1>` | AggregateOperation3.`accumulateFn1()` A primitive that updates the accumulator state to account for a new item coming from stream-1.
    `BiConsumerEx<? super A,? super T1>` | AggregateOperation2.`accumulateFn1()` A primitive that updates the accumulator state to account for a new item coming from stream-1.
    `BiConsumerEx<? super A,? super T2>` | AggregateOperation3.`accumulateFn2()` A primitive that updates the accumulator state to account for a new item coming from stream-2.
    `BiConsumerEx<? super A,? super A>` | AggregateOperation.`combineFn()` A primitive that accepts two accumulators and updates the state of the left-hand one by combining it with the state of the right-hand one.
    `BiConsumerEx<? super A,? super A>` | AggregateOperation.`deductFn()` A primitive that accepts two accumulators and updates the state of the left-hand one by deducting the state of the right-hand one from it.

    Methods in com.hazelcast.jet.aggregate with parameters of type BiConsumerEx
    Modifier and Type | Method and Description
    --- | ---
    `<T> AggregateOperationBuilder.Arity1<T,A,Void>` | AggregateOperationBuilder.`andAccumulate(BiConsumerEx<? super A,? super T> accumulateFn)` Registers the supplied `accumulate` primitive.
    `<T> AggregateOperationBuilder.VarArity<A,Void>` | AggregateOperationBuilder.`andAccumulate(Tag<T> tag, BiConsumerEx<? super A,? super T> accumulateFn)` Registers the supplied `accumulate` primitive for the stream tagged with the supplied tag.
    `<T> AggregateOperationBuilder.VarArity<A,R>` | AggregateOperationBuilder.VarArity.`andAccumulate(Tag<T> tag, BiConsumerEx<? super A,T> accumulateFn)` Registers the supplied `accumulate` primitive for the stream tagged with the supplied tag.
    `<T0> AggregateOperationBuilder.Arity1<T0,A,Void>` | AggregateOperationBuilder.`andAccumulate0(BiConsumerEx<? super A,? super T0> accumulateFn0)` Registers the supplied `accumulate` primitive for stream-0.
    `<T1> AggregateOperationBuilder.Arity2<T0,T1,A,R>` | AggregateOperationBuilder.Arity1.`andAccumulate1(BiConsumerEx<? super A,? super T1> accumulateFn1)` Registers the supplied `accumulate` primitive for stream-1, returning the arity-2 variant of the builder.
    `<T2> AggregateOperationBuilder.Arity3<T0,T1,T2,A,R>` | AggregateOperationBuilder.Arity2.`andAccumulate2(BiConsumerEx<? super A,? super T2> accumulateFn2)` Registers the supplied `accumulate` primitive for stream-2, returning the arity-3 variant of the builder.
    `AggregateOperationBuilder.Arity1<T0,A,R>` | AggregateOperationBuilder.Arity1.`andCombine(BiConsumerEx<? super A,? super A> combineFn)` Registers the `combine` primitive.
    `AggregateOperationBuilder.Arity2<T0,T1,A,R>` | AggregateOperationBuilder.Arity2.`andCombine(BiConsumerEx<? super A,? super A> combineFn)` Registers the `combine` primitive.
    `AggregateOperationBuilder.Arity3<T0,T1,T2,A,R>` | AggregateOperationBuilder.Arity3.`andCombine(BiConsumerEx<? super A,? super A> combineFn)` Registers the `combine` primitive.
    `AggregateOperationBuilder.VarArity<A,R>` | AggregateOperationBuilder.VarArity.`andCombine(BiConsumerEx<? super A,? super A> combineFn)` Registers the `combine` primitive.
    `AggregateOperationBuilder.Arity1<T0,A,R>` | AggregateOperationBuilder.Arity1.`andDeduct(BiConsumerEx<? super A,? super A> deductFn)` Registers the `deduct` primitive.
    `AggregateOperationBuilder.Arity2<T0,T1,A,R>` | AggregateOperationBuilder.Arity2.`andDeduct(BiConsumerEx<? super A,? super A> deductFn)` Registers the `deduct` primitive.
    `AggregateOperationBuilder.Arity3<T0,T1,T2,A,R>` | AggregateOperationBuilder.Arity3.`andDeduct(BiConsumerEx<? super A,? super A> deductFn)` Registers the `deduct` primitive.
    `AggregateOperationBuilder.VarArity<A,R>` | AggregateOperationBuilder.VarArity.`andDeduct(BiConsumerEx<? super A,? super A> deductFn)` Registers the `deduct` primitive.
    `<NEW_T> AggregateOperation1<NEW_T,A,R>` | AggregateOperation1.`withAccumulateFn(BiConsumerEx<? super A,? super NEW_T> accumulateFn)` Returns a copy of this aggregate operation, but with the `accumulate` primitive replaced with the one supplied here.
    `<T0_NEW> AggregateOperation3<T0_NEW,T1,T2,A,R>` | AggregateOperation3.`withAccumulateFn0(BiConsumerEx<? super A,? super T0_NEW> newAccFn0)` Returns a copy of this aggregate operation, but with the `accumulate` primitive at index 0 replaced with the one supplied here.
    `<T0_NEW> AggregateOperation2<T0_NEW,T1,A,R>` | AggregateOperation2.`withAccumulateFn0(BiConsumerEx<? super A,? super T0_NEW> newAccFn0)` Returns a copy of this aggregate operation, but with the `accumulate` primitive at index 0 replaced with the one supplied here.
    `<T1_NEW> AggregateOperation3<T0,T1_NEW,T2,A,R>` | AggregateOperation3.`withAccumulateFn1(BiConsumerEx<? super A,? super T1_NEW> newAccFn1)` Returns a copy of this aggregate operation, but with the `accumulate` primitive at index 1 replaced with the one supplied here.
    `<T1_NEW> AggregateOperation2<T0,T1_NEW,A,R>` | AggregateOperation2.`withAccumulateFn1(BiConsumerEx<? super A,? super T1_NEW> newAccFn1)` Returns a copy of this aggregate operation, but with the `accumulate` primitive at index 1 replaced with the one supplied here.
    `<T2_NEW> AggregateOperation3<T0,T1,T2_NEW,A,R>` | AggregateOperation3.`withAccumulateFn2(BiConsumerEx<? super A,? super T2_NEW> newAccFn2)` Returns a copy of this aggregate operation, but with the `accumulate` primitive at index 2 replaced with the one supplied here.
    `AggregateOperation<A,R>` | AggregateOperation.`withAccumulateFns(BiConsumerEx... accumulateFns)` Returns a copy of this aggregate operation, but with all the `accumulate` primitives replaced with the ones supplied here.

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

    Methods in com.hazelcast.jet.core.processor with parameters of type BiConsumerEx
    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.`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 <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.
    `static <T> ProcessorMetaSupplier` | SinkProcessors.`writeJdbcP(String updateQuery, SupplierEx<? extends Connection> newConnectionFn, BiConsumerEx<? super PreparedStatement,? super T> bindFn)` Returns a supplier of processors for `Sinks.jdbc(String, SupplierEx, BiConsumerEx)`.
    `static <T> ProcessorMetaSupplier` | SinkProcessors.`writeJmsQueueP(SupplierEx<? extends javax.jms.Connection> newConnectionFn, FunctionEx<? super javax.jms.Connection,? extends javax.jms.Session> newSessionFn, BiFunctionEx<? super javax.jms.Session,? super T,? extends javax.jms.Message> messageFn, BiConsumerEx<? super javax.jms.MessageProducer,? super javax.jms.Message> sendFn, ConsumerEx<? super javax.jms.Session> flushFn, String name)` Returns a supplier of processors for `Sinks.jmsQueueBuilder(com.hazelcast.jet.function.SupplierEx<javax.jms.ConnectionFactory>)`.
    `static <T> ProcessorMetaSupplier` | SinkProcessors.`writeJmsTopicP(SupplierEx<? extends javax.jms.Connection> newConnectionFn, FunctionEx<? super javax.jms.Connection,? extends javax.jms.Session> newSessionFn, BiFunctionEx<? super javax.jms.Session,? super T,? extends javax.jms.Message> messageFn, BiConsumerEx<? super javax.jms.MessageProducer,? super javax.jms.Message> sendFn, ConsumerEx<? super javax.jms.Session> flushFn, String name)` Returns a supplier of processors for `Sinks.jmsTopicBuilder(com.hazelcast.jet.function.SupplierEx<javax.jms.ConnectionFactory>)`.

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

    Methods in com.hazelcast.jet.function that return BiConsumerEx
    Modifier and Type | Method and Description
    --- | ---
    `default BiConsumerEx<T,U>` | BiConsumerEx.`andThen(BiConsumerEx<? super T,? super U> after)` `Serializable` variant of `java.util.function.BiConsumer#andThen(BiConsumer)`.

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

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

    Methods in com.hazelcast.jet.pipeline with parameters of type BiConsumerEx
    Modifier and Type | Method and Description
    --- | ---
    `<T_NEW> SourceBuilder.Batch<T_NEW>` | SourceBuilder.Batch.`fillBufferFn(BiConsumerEx<? super C,? super SourceBuilder.SourceBuffer<T_NEW>> fillBufferFn)` Sets the function that Jet will call whenever it needs more data from your source.
    `<T_NEW> SourceBuilder.Stream<T_NEW>` | SourceBuilder.Stream.`fillBufferFn(BiConsumerEx<? super C,? super SourceBuilder.SourceBuffer<T_NEW>> fillBufferFn)`
    `<T_NEW> SourceBuilder.TimestampedStream<T_NEW>` | SourceBuilder.TimestampedStream.`fillBufferFn(BiConsumerEx<? super C,? super SourceBuilder.TimestampedSourceBuffer<T_NEW>> fillBufferFn)` Sets the function that Jet will call whenever it needs more data from your source.
    `static <T> Sink<T>` | Sinks.`jdbc(String updateQuery, String connectionUrl, BiConsumerEx<PreparedStatement,T> bindFn)` Convenience for `Sinks.jdbc(String, SupplierEx, BiConsumerEx)`.
    `static <T> Sink<T>` | Sinks.`jdbc(String updateQuery, SupplierEx<Connection> newConnectionFn, BiConsumerEx<PreparedStatement,T> bindFn)` Returns a sink that connects to the specified database using the given `newConnectionFn`, prepares a statement using the given `updateQuery` and inserts/updates the items.
    `<T_NEW> SinkBuilder<W,T_NEW>` | SinkBuilder.`receiveFn(BiConsumerEx<? super W,? super T_NEW> receiveFn)` Sets the function Jet will call upon receiving an item.
    `B` | SourceBuilder.FaultTolerant.`restoreSnapshotFn(BiConsumerEx<? super C,? super List<S>> restoreSnapshotFn)` Sets the function that restores the source's state from a snapshot.
    `JmsSinkBuilder<T>` | JmsSinkBuilder.`sendFn(BiConsumerEx<javax.jms.MessageProducer,javax.jms.Message> sendFn)` Sets the function which sends the message via message producer.

  - ### Uses of BiConsumerEx in com.hazelcast.jet.pipeline.test

    Methods in com.hazelcast.jet.pipeline.test with parameters of type BiConsumerEx
    Modifier and Type | Method and Description
    --- | ---
    `<T_NEW> AssertionSinkBuilder<S,T_NEW>` | AssertionSinkBuilder.`receiveFn(BiConsumerEx<? super S,? super T_NEW> receiveFn)` Sets the function Jet will call upon receiving every item.

Copyright © 2020. All rights reserved.