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.
|
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) . |
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) . |
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.
|
Modifier and Type | Method and Description |
---|---|
<T> AggregateOperationBuilder.Arity1<T,A,Void> |
AggregateOperationBuilder.andAccumulate(BiConsumerEx<? super A,? super T> accumulateFn)
Registers the
AggregateOperation1.accumulateFn() accumulate}
primitive. |
<T> AggregateOperationBuilder.VarArity<A,Void> |
AggregateOperationBuilder.andAccumulate(Tag<T> tag,
BiConsumerEx<? super A,? super T> accumulateFn)
Registers the
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
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
accumulate
primitive for stream-0. |
<T1> AggregateOperationBuilder.Arity2<T0,T1,A,R> |
AggregateOperationBuilder.Arity1.andAccumulate1(BiConsumerEx<? super A,? super T1> accumulateFn1)
Registers the
AggregateOperation2.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 the
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. |
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,
Permission permission)
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,
Permission permission)
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,
ExternalDataStoreRef externalDataStoreRef,
BiConsumerEx<? super PreparedStatement,? super T> bindFn,
boolean exactlyOnce,
int batchLimit)
Returns a supplier of processors for
Sinks.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 for
Sinks.jdbcBuilder() . |
Modifier and Type | Method and 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 a
ServiceFactory that calls out to a
unary gRPC service. |
Modifier and Type | Method and Description |
---|---|
JdbcSinkBuilder<T> |
JdbcSinkBuilder.bindFn(BiConsumerEx<PreparedStatement,T> bindFn)
Set the function to bind values to a
PreparedStatement created
with the query set with JdbcSinkBuilder.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,
ExternalDataStoreRef externalDataStoreRef,
BiConsumerEx<PreparedStatement,T> bindFn)
A shortcut for:
|
static <T> Sink<T> |
Sinks.jdbc(String updateQuery,
String jdbcUrl,
BiConsumerEx<PreparedStatement,T> bindFn)
A shortcut for:
|
static <T> Sink<T> |
Sinks.jdbc(String updateQuery,
SupplierEx<? extends CommonDataSource> dataSourceSupplier,
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.
|
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 © 2022 Hazelcast, Inc.. All rights reserved.