Package org.apache.ignite.table

Class DataStreamerOptions

java.lang.Object

org.apache.ignite.table.DataStreamerOptions

public class DataStreamerOptions
extends Object

Data streamer options. See DataStreamerTarget for more information.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DataStreamerOptions.Builder	Builder.

Field Summary

Fields

Modifier and Type	Field	Description
static final DataStreamerOptions	DEFAULT	Default options.

Method Summary

Modifier and Type	Method	Description
int	autoFlushInterval()	Gets the auto flush interval, in milliseconds (the period of time after which the streamer will flush the per-node buffer even if it is not full).
static DataStreamerOptions.Builder	builder()	Creates a new builder.
int	pageSize()	Gets the page size (the number of entries that will be sent to the cluster in one network call).
int	perPartitionParallelOperations()	Gets the number of parallel operations per partition (how many in-flight requests can be active for a given partition).
int	retryLimit()	Gets the retry limit for a page.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

DEFAULT

public static final DataStreamerOptions DEFAULT

Default options.

Method Details

builder

public static DataStreamerOptions.Builder builder()

Creates a new builder.

Returns:

Builder.

pageSize

public int pageSize()

Gets the page size (the number of entries that will be sent to the cluster in one network call).

Returns:

Page size.

perPartitionParallelOperations

public int perPartitionParallelOperations()

Gets the number of parallel operations per partition (how many in-flight requests can be active for a given partition).

Returns:

Per node parallel operations.

autoFlushInterval

public int autoFlushInterval()

Gets the auto flush interval, in milliseconds (the period of time after which the streamer will flush the per-node buffer even if it is not full).

Returns:

Auto flush interval.

retryLimit

public int retryLimit()

Gets the retry limit for a page. If a page fails to be sent to the cluster, the streamer will retry it a number of times. If all retries fail, the streamer will be aborted.

Returns:

Retry limit.