Package com.google.cloud.storage

Class FlushPolicy.MaxFlushSizeFlushPolicy

java.lang.Object

com.google.cloud.storage.FlushPolicy

com.google.cloud.storage.FlushPolicy.MaxFlushSizeFlushPolicy

Enclosing class:

FlushPolicy

@Immutable
@BetaApi
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)

Since:

2.51.0 This new api is in preview and is subject to breaking changes.

Nested Class Summary

Nested classes/interfaces inherited from class com.google.cloud.storage.FlushPolicy

FlushPolicy.MaxFlushSizeFlushPolicy, FlushPolicy.MinFlushSizeFlushPolicy

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
int	getMaxFlushSize()	The maximum number of bytes to include in each automatic flush
int	hashCode()
String	toString()
FlushPolicy.MaxFlushSizeFlushPolicy	withMaxFlushSize(int maxFlushSize)	Return an instance with the maxFlushSize set to the specified value.

Methods inherited from class com.google.cloud.storage.FlushPolicy

maxFlushSize, maxFlushSize, minFlushSize, minFlushSize

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Details

getMaxFlushSize

@BetaApi
public int getMaxFlushSize()

The maximum number of bytes to include in each automatic flush

Default: 2097152 (2 MiB)

See Also:

• withMaxFlushSize(int)

withMaxFlushSize

@BetaApi
public FlushPolicy.MaxFlushSizeFlushPolicy withMaxFlushSize(int maxFlushSize)

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

Default: 2097152 (2 MiB)

Parameters:

maxFlushSize - The number of bytes to buffer before flushing.

Returns:

The new instance

See Also:

• getMaxFlushSize()

equals

public boolean equals(Object o)

Specified by:

equals in class FlushPolicy

hashCode

public int hashCode()

Specified by:

hashCode in class FlushPolicy

toString

public String toString()

Specified by:

toString in class FlushPolicy