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.
|
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 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. |
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>) . |
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 |
---|---|
<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.
|
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 © 2019 Hazelcast, Inc.. All rights reserved.