Class FlushPolicy.MinFlushSizeFlushPolicy (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.MinFlushSizeFlushPolicy extends FlushPolicy

Define a FlushPolicy where a min number of bytes will be required before a flush GCS happens.

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.

Instances of this class are immutable and thread safe.

Inheritance

Object > FlushPolicy > FlushPolicy.MinFlushSizeFlushPolicy

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)

getMaxPendingBytes()

public long getMaxPendingBytes()

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.

Returns
Type	Description
long

getMinFlushSize()

public int getMinFlushSize()

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 minimum number of bytes to include in each automatic flush

Default: 4194304 (4 MiB) See Also: #withMinFlushSize(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()

withMaxPendingBytes(long maxPendingBytes)

public FlushPolicy.MinFlushSizeFlushPolicy withMaxPendingBytes(long maxPendingBytes)

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.

Parameter
Name	Description
maxPendingBytes	long

Returns
Type	Description
FlushPolicy.MinFlushSizeFlushPolicy

withMinFlushSize(int minFlushSize)

public FlushPolicy.MinFlushSizeFlushPolicy withMinFlushSize(int minFlushSize)

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 minFlushSize set to the specified value.

Default: 4194304 (4 MiB) See Also: #getMinFlushSize()

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

Returns
Type	Description
FlushPolicy.MinFlushSizeFlushPolicy	The new instance