[IGNITE-21403] DataStreamer data removal: update public API

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 3.0.0-beta1
• Fix Version/s: 3.0.0-beta2
• Component/s: thin client
• Labels: ignite-3
• Epic Link: DataStreamer Data Removal
• Ignite Flags: Docs Required, Release Notes Required
• Assignee: Pavel Tupitsyn
• Reporter: Pavel Tupitsyn
• Reviewer: Igor Sapego
• Created: 31/Jan/24 10:33
• Updated: 14/Feb/24 15:36
• Resolved: 14/Feb/24 15:36

Description

Change DataStreamerTarget.streamData signature to accept DataStreamerItem instead of raw data:

    CompletableFuture<Void> streamData(
            Flow.Publisher<DataStreamerItem<T>> publisher,
            @Nullable DataStreamerOptions options);

Where DataStreamerItem is:

public interface DataStreamerItem<T> {
    T get();

    DataStreamerOperationType operationType();

    static <T> DataStreamerItem<T> of(T item) {
        return of(item, DataStreamerOperationType.PUT);
    }

    static <T> DataStreamerItem<T> removed(T item) {
        return of(item, DataStreamerOperationType.REMOVE);
    }
}

Issue Links

• relates to: IGNITE-21521 Wrong update order in upsertAll and DataStreamer for a new key
• links to: GitHub Pull Request #3208