Class ExternalSorter.Options

java.lang.Object
org.apache.beam.sdk.extensions.sorter.ExternalSorter.Options
All Implemented Interfaces:
Serializable
Enclosing class:
ExternalSorter

public static class ExternalSorter.Options extends Object implements Serializable
ExternalSorter.Options contains configuration of the sorter.
See Also:
  • Constructor Details

    • Options

      public Options()
  • Method Details

    • setTempLocation

      public ExternalSorter.Options setTempLocation(String tempLocation)
      Sets the path to a temporary location where the sorter writes intermediate files.
    • getTempLocation

      public String getTempLocation()
      Returns the configured temporary location.
    • setMemoryMB

      public ExternalSorter.Options setMemoryMB(int memoryMB)
      Sets the size of the memory buffer in megabytes. Must be greater than zero and less than 2048.
    • getMemoryMB

      public int getMemoryMB()
      Returns the configured size of the memory buffer.
    • setSorterType

      public ExternalSorter.Options setSorterType(ExternalSorter.Options.SorterType sorterType)
      Sets the sorter type.
    • getSorterType

      public ExternalSorter.Options.SorterType getSorterType()
      Returns the sorter type.