Uses of Interface
com.hazelcast.function.BiConsumerEx
Package | Description |
---|---|
com.hazelcast.function |
Serializable and exception-declaring variants of functional interfaces from
java.util.function . |
com.hazelcast.jet.aggregate |
Contains
AggregateOperation and its several 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.grpc |
Contributes
gRPC service factories that can be to apply transformations to
a pipeline which for each input item calls to a gRPC service. |
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.function
Methods in com.hazelcast.function that return BiConsumerEx Modifier and Type Method Description default BiConsumerEx<T,U>
BiConsumerEx. andThen(BiConsumerEx<? super T,? super U> after)
Serializable
variant ofjava.util.function.BiConsumer#andThen(BiConsumer)
.Methods in com.hazelcast.function with parameters of type BiConsumerEx Modifier and Type Method Description default BiConsumerEx<T,U>
BiConsumerEx. andThen(BiConsumerEx<? super T,? super U> after)
Serializable
variant ofjava.util.function.BiConsumer#andThen(BiConsumer)
. -
Uses of BiConsumerEx in com.hazelcast.jet.aggregate
Methods in com.hazelcast.jet.aggregate that return BiConsumerEx Modifier and Type Method Description <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 T>
AggregateOperation1. accumulateFn()
A primitive that updates the accumulator state to account for a new item.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 T0>
AggregateOperation3. accumulateFn0()
A primitive that updates the accumulator state to account for a new item coming from stream-0.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 T1>
AggregateOperation3. 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 Description <T> AggregateOperationBuilder.Arity1<T,A,Void>
AggregateOperationBuilder. andAccumulate(BiConsumerEx<? super A,? super T> accumulateFn)
Registers theAggregateOperation1.accumulateFn()
accumulate} primitive.<T> AggregateOperationBuilder.VarArity<A,Void>
AggregateOperationBuilder. andAccumulate(Tag<T> tag, BiConsumerEx<? super A,? super T> accumulateFn)
Registers theaccumulate
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 theaccumulate
primitive for the stream tagged with the supplied tag.<T0> AggregateOperationBuilder.Arity1<T0,A,Void>
AggregateOperationBuilder. andAccumulate0(BiConsumerEx<? super A,? super T0> accumulateFn0)
Registers theaccumulate
primitive for stream-0.<T1> AggregateOperationBuilder.Arity2<T0,T1,A,R>
AggregateOperationBuilder.Arity1. andAccumulate1(BiConsumerEx<? super A,? super T1> accumulateFn1)
Registers theAggregateOperation2.accumulateFn1()
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 theaccumulate
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 thecombine
primitive.AggregateOperationBuilder.Arity2<T0,T1,A,R>
AggregateOperationBuilder.Arity2. andCombine(BiConsumerEx<? super A,? super A> combineFn)
Registers thecombine
primitive.AggregateOperationBuilder.Arity3<T0,T1,T2,A,R>
AggregateOperationBuilder.Arity3. andCombine(BiConsumerEx<? super A,? super A> combineFn)
Registers thecombine
primitive.AggregateOperationBuilder.VarArity<A,R>
AggregateOperationBuilder.VarArity. andCombine(BiConsumerEx<? super A,? super A> combineFn)
Registers thecombine
primitive.AggregateOperationBuilder.Arity1<T0,A,R>
AggregateOperationBuilder.Arity1. andDeduct(BiConsumerEx<? super A,? super A> deductFn)
Registers thededuct
primitive.AggregateOperationBuilder.Arity2<T0,T1,A,R>
AggregateOperationBuilder.Arity2. andDeduct(BiConsumerEx<? super A,? super A> deductFn)
Registers thededuct
primitive.AggregateOperationBuilder.Arity3<T0,T1,T2,A,R>
AggregateOperationBuilder.Arity3. andDeduct(BiConsumerEx<? super A,? super A> deductFn)
Registers thededuct
primitive.AggregateOperationBuilder.VarArity<A,R>
AggregateOperationBuilder.VarArity. andDeduct(BiConsumerEx<? super A,? super A> deductFn)
Registers thededuct
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 theaccumulate
primitive 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 theaccumulate
primitive at index 0 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 theaccumulate
primitive at index 0 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 theaccumulate
primitive at index 1 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 theaccumulate
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 theaccumulate
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 theaccumulate
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 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 theSourceBuilder
.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 theSourceBuilder
.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 forSinkProcessors.writeBufferedP(FunctionEx, BiConsumerEx, ConsumerEx, ConsumerEx)
with a no-opdestroyFn
.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 CommonDataSource> dataSourceSupplier, BiConsumerEx<? super PreparedStatement,? super T> bindFn, boolean exactlyOnce, int batchLimit)
Returns a supplier of processors forSinks.jdbcBuilder()
. -
Uses of BiConsumerEx in com.hazelcast.jet.grpc
Method parameters in com.hazelcast.jet.grpc with type arguments of type BiConsumerEx Modifier and Type Method Description static <T, R> ServiceFactory<?,? extends GrpcService<T,R>>
GrpcServices. unaryService(SupplierEx<? extends io.grpc.ManagedChannelBuilder<?>> channelFn, FunctionEx<? super io.grpc.ManagedChannel,? extends BiConsumerEx<T,io.grpc.stub.StreamObserver<R>>> callStubFn)
Creates aServiceFactory
that calls out to a unary gRPC service. -
Uses of BiConsumerEx in com.hazelcast.jet.pipeline
Methods in com.hazelcast.jet.pipeline with parameters of type BiConsumerEx Modifier and Type Method Description JdbcSinkBuilder<T>
JdbcSinkBuilder. bindFn(BiConsumerEx<PreparedStatement,T> bindFn)
Set the function to bind values to aPreparedStatement
created with the query set withJdbcSinkBuilder.updateQuery(String)
.<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, SupplierEx<? extends CommonDataSource> dataSourceSupplier, BiConsumerEx<PreparedStatement,T> bindFn)
A shortcut for:static <T> Sink<T>
Sinks. jdbc(String updateQuery, String jdbcUrl, BiConsumerEx<PreparedStatement,T> bindFn)
A shortcut for:<T_NEW> SinkBuilder<C,T_NEW>
SinkBuilder. receiveFn(BiConsumerEx<? super C,? 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. -
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 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.