Uses of Interface
com.hazelcast.function.BiConsumerEx
Package
Description
Serializable and exception-declaring variants of functional interfaces from
java.util.function
.Contains
AggregateOperation
and its several variants, as well
as a builder object for the aggregate operations.Contains static utility classes with factories of Jet processors.
Contributes
gRPC service factories
that can be to apply transformations to
a pipeline which for each input item calls to a gRPC service.The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
This package contains various mock sources to help with pipeline testing
and development.
-
Uses of BiConsumerEx in com.hazelcast.function
Modifier and TypeMethodDescriptiondefault BiConsumerEx<T,
U> BiConsumerEx.andThen
(BiConsumerEx<? super T, ? super U> after) Serializable
variant ofjava.util.function.BiConsumer#andThen(BiConsumer)
.Modifier and TypeMethodDescriptiondefault 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
Modifier and TypeMethodDescription<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.Modifier and TypeMethodDescriptionAggregateOperationBuilder.andAccumulate
(BiConsumerEx<? super A, ? super T> accumulateFn) Registers theAggregateOperation1.accumulateFn()
accumulate} primitive.AggregateOperationBuilder.andAccumulate
(Tag<T> tag, BiConsumerEx<? super A, ? super T> accumulateFn) Registers theaccumulate
primitive for the stream tagged with the supplied tag.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.andCombine
(BiConsumerEx<? super A, ? super A> combineFn) Registers thecombine
primitive.AggregateOperationBuilder.Arity2.andCombine
(BiConsumerEx<? super A, ? super A> combineFn) Registers thecombine
primitive.AggregateOperationBuilder.Arity3.andCombine
(BiConsumerEx<? super A, ? super A> combineFn) Registers thecombine
primitive.AggregateOperationBuilder.VarArity.andCombine
(BiConsumerEx<? super A, ? super A> combineFn) Registers thecombine
primitive.AggregateOperationBuilder.Arity1.andDeduct
(BiConsumerEx<? super A, ? super A> deductFn) Registers thededuct
primitive.AggregateOperationBuilder.Arity2.andDeduct
(BiConsumerEx<? super A, ? super A> deductFn) Registers thededuct
primitive.AggregateOperationBuilder.Arity3.andDeduct
(BiConsumerEx<? super A, ? super A> deductFn) Registers thededuct
primitive.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.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
Modifier and TypeMethodDescriptionstatic <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, Permission permission) 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, DataConnectionRef dataConnectionRef, BiConsumerEx<? super PreparedStatement, ? super T> bindFn, boolean exactlyOnce, int batchLimit) Returns a supplier of processors forSinks.jdbcBuilder()
.static <T> ProcessorMetaSupplier
SinkProcessors.writeJdbcP
(String jdbcUrl, 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
Modifier and TypeMethodDescriptionstatic <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
Modifier and TypeMethodDescriptionJdbcSinkBuilder.bindFn
(BiConsumerEx<PreparedStatement, T> bindFn) Set the function to bind values to aPreparedStatement
created with the query set withJdbcSinkBuilder.updateQuery(String)
.<T_NEW> SourceBuilder<C>.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<C>.Stream<T_NEW>
SourceBuilder.Stream.fillBufferFn
(BiConsumerEx<? super C, ? super SourceBuilder.SourceBuffer<T_NEW>> fillBufferFn) <T_NEW> SourceBuilder<C>.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, DataConnectionRef dataConnectionRef, 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.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
Modifier and TypeMethodDescription<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.