Package org.apache.ignite.table
Interface DataStreamerTarget<T>
- Type Parameters:
T- Entry type.
- All Known Subinterfaces:
KeyValueView<K,,V> RecordView<R>
public interface DataStreamerTarget<T>
Represents an entity that can be used as a target for streaming data.
-
Method Summary
Modifier and TypeMethodDescriptiondefault <E,V, R, A> CompletableFuture<Void> streamData(Flow.Publisher<E> publisher, Function<E, T> keyFunc, Function<E, V> payloadFunc, ReceiverDescriptor<A> receiver, Flow.Subscriber<R> resultSubscriber, @Nullable DataStreamerOptions options, A receiverArg) Deprecated.<E,V, A, R> CompletableFuture<Void> streamData(Flow.Publisher<E> publisher, DataStreamerReceiverDescriptor<V, A, R> receiver, Function<E, T> keyFunc, Function<E, V> payloadFunc, A receiverArg, Flow.Subscriber<R> resultSubscriber, @Nullable DataStreamerOptions options) Streams data with receiver.streamData(Flow.Publisher<DataStreamerItem<T>> publisher, @Nullable DataStreamerOptions options) Streams data into the underlying table.
-
Method Details
-
streamData
CompletableFuture<Void> streamData(Flow.Publisher<DataStreamerItem<T>> publisher, @Nullable @Nullable DataStreamerOptions options) Streams data into the underlying table.- Parameters:
publisher- Producer.options- Options (can be null).- Returns:
- Future that will be completed when the stream is finished.
-
streamData
@Deprecated default <E,V, CompletableFuture<Void> streamDataR, A> (Flow.Publisher<E> publisher, Function<E, T> keyFunc, Function<E, V> payloadFunc, ReceiverDescriptor<A> receiver, @Nullable Flow.Subscriber<R> resultSubscriber, @Nullable @Nullable DataStreamerOptions options, @Nullable A receiverArg) Deprecated.Streams data with receiver. The receiver is responsible for processing the data and updating zero or more tables.- Type Parameters:
E- Producer item type.V- Payload type.R- Result type.A- Receiver job argument type.- Parameters:
publisher- Producer.keyFunc- Key function. The key is only used locally for colocation.payloadFunc- Payload function. The payload is sent to the receiver.resultSubscriber- Optional subscriber for the receiver results. NOTE: The result subscriber follows the pace of publisher and ignores backpressure fromFlow.Subscription.request(long)calls.options- Options (can be null).receiverArg- Receiver arguments.- Returns:
- Future that will be completed when the stream is finished.
-
streamData
<E,V, CompletableFuture<Void> streamDataA, R> (Flow.Publisher<E> publisher, DataStreamerReceiverDescriptor<V, A, R> receiver, Function<E, T> keyFunc, Function<E, V> payloadFunc, @Nullable A receiverArg, @Nullable Flow.Subscriber<R> resultSubscriber, @Nullable @Nullable DataStreamerOptions options) Streams data with receiver. The receiver is responsible for processing the data and updating zero or more tables.- Type Parameters:
E- Producer item type.V- Payload type.A- Receiver job argument type.R- Result type.- Parameters:
publisher- Producer.keyFunc- Key function. The key is only used locally for colocation.payloadFunc- Payload function. The payload is sent to the receiver.resultSubscriber- Optional subscriber for the receiver results. NOTE: The result subscriber follows the pace of publisher and ignores backpressure fromFlow.Subscription.request(long)calls.options- Options (can be null).receiverArg- Receiver arguments.- Returns:
- Future that will be completed when the stream is finished.
-
streamData(Flow.Publisher, DataStreamerReceiverDescriptor, Function, Function, Object, Flow.Subscriber, DataStreamerOptions).