Namespace Apache.Ignite.Core.Client.Datastream

Classes

DataStreamerClientOptions

Thin client data streamer options.

To set a receiver, use generic class DataStreamerClientOptions<TK, TV>.

See also IDataStreamerClient<TK, TV>, GetDataStreamer<TK, TV>(String).

DataStreamerClientOptions<TK, TV>

Thin client data streamer extended options.

See also IDataStreamerClient<TK, TV>, GetDataStreamer<TK, TV>(String).

Interfaces

IDataStreamerClient<TK, TV>

Thin client data streamer.

Data streamer is an efficient and fault-tolerant way to load data into cache. Updates are buffered and mapped to primary nodes to ensure minimal data movement and optimal resource utilization. Update failures caused by cluster topology changes are retried automatically.

Note that streamer send data to remote nodes asynchronously, so cache updates can be reordered.

Instances of the implementing class are thread-safe: data can be added from multiple threads.

Closing and disposing: method calls Close(Boolean)(false). This will flush any remaining data to the cache synchronously. To avoid blocking threads when exiting using() block, use CloseAsync(Boolean).