Class FlushPolicy.MaxFlushSizeFlushPolicy (2.58.1)

Beta

This library is covered by the Pre-GA Offerings Terms of the Terms of Service. Pre-GA libraries might have limited support, and changes to pre-GA libraries might not be compatible with other pre-GA versions. For more information, see the launch stage descriptions.

public static final class FlushPolicy.MaxFlushSizeFlushPolicy extends FlushPolicy

Define a FlushPolicy where a max number of bytes will be flushed to GCS per flush.

If there are not enough bytes to trigger a flush, they will be held in memory until there are enough bytes, or an explicit flush is performed by closing the channel. If more bytes are provided than the configured maxFlushSize, multiple flushes will be performed.

Instances of this class are immutable and thread safe.

Instead of this, strategy use FlushPolicy#minFlushSize().withMaxPendingBytes(long)

Inheritance

Object > FlushPolicy > FlushPolicy.MaxFlushSizeFlushPolicy

Inherited Members

FlushPolicy.equals(Object)

FlushPolicy.hashCode()

FlushPolicy.maxFlushSize()

FlushPolicy.maxFlushSize(int)

FlushPolicy.minFlushSize()

FlushPolicy.minFlushSize(int)

FlushPolicy.toString()

Object.clone()

Object.finalize()

Object.getClass()

Object.notify()

Object.notifyAll()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Methods

equals(Object o)

public boolean equals(Object o)

Parameter
Name	Description
o	Object

Returns
Type	Description
boolean

Overrides

FlushPolicy.equals(Object obj)

getMaxFlushSize()

public int getMaxFlushSize()

Beta

This feature is covered by the Pre-GA Offerings Terms of the Terms of Service. Pre-GA libraries might have limited support, and changes to pre-GA libraries might not be compatible with other pre-GA versions. For more information, see the launch stage descriptions.

The maximum number of bytes to include in each automatic flush

Default: 2097152 (2 MiB) See Also: #withMaxFlushSize(int)

Returns
Type	Description
int

hashCode()

public int hashCode()

Returns
Type	Description
int

Overrides

FlushPolicy.hashCode()

toString()

public String toString()

Returns
Type	Description
String

Overrides

FlushPolicy.toString()

withMaxFlushSize(int maxFlushSize)

public FlushPolicy.MaxFlushSizeFlushPolicy withMaxFlushSize(int maxFlushSize)

Beta

This feature is covered by the Pre-GA Offerings Terms of the Terms of Service. Pre-GA libraries might have limited support, and changes to pre-GA libraries might not be compatible with other pre-GA versions. For more information, see the launch stage descriptions.

Return an instance with the maxFlushSize set to the specified value.

Default: 2097152 (2 MiB) See Also: #getMaxFlushSize()

Parameter
Name	Description
maxFlushSize	int The number of bytes to buffer before flushing.

Returns
Type	Description
FlushPolicy.MaxFlushSizeFlushPolicy	The new instance