org.apache.beam.sdk.extensions.sorter

Class BufferedExternalSorter.Options

java.lang.Object

org.apache.beam.sdk.extensions.sorter.BufferedExternalSorter.Options

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

BufferedExternalSorter

public static class BufferedExternalSorter.Options
extends java.lang.Object
implements java.io.Serializable

Contains configuration for the sorter.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
ExternalSorter.Options.SorterType	getExternalSorterType() Returns the external sorter type.
int	getMemoryMB() Returns the configured size of the memory buffer.
java.lang.String	getTempLocation() Returns the configured temporary location.
BufferedExternalSorter.Options	withExternalSorterType(ExternalSorter.Options.SorterType sorterType) Sets the external sorter type.
BufferedExternalSorter.Options	withMemoryMB(int memoryMB) Sets the size of the memory buffer in megabytes.
BufferedExternalSorter.Options	withTempLocation(java.lang.String tempLocation) Sets the path to a temporary location where the sorter writes intermediate files.

Methods inherited from class java.lang.Object

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

Method Detail

withTempLocation

public BufferedExternalSorter.Options withTempLocation(java.lang.String tempLocation)

Sets the path to a temporary location where the sorter writes intermediate files.

getTempLocation

public java.lang.String getTempLocation()

Returns the configured temporary location.

withMemoryMB

public BufferedExternalSorter.Options withMemoryMB(int memoryMB)

Sets the size of the memory buffer in megabytes. This controls both the buffer for initial in memory sorting and the buffer used when external sorting. Must be greater than zero. Must be less than 2048 if sorter type is Hadoop.

getMemoryMB

public int getMemoryMB()

Returns the configured size of the memory buffer.

withExternalSorterType

public BufferedExternalSorter.Options withExternalSorterType(ExternalSorter.Options.SorterType sorterType)

Sets the external sorter type.

getExternalSorterType

public ExternalSorter.Options.SorterType getExternalSorterType()

Returns the external sorter type.