com.asakusafw.runtime.mapreduce.simple

Class KeyValueSorter.Options

java.lang.Object

com.asakusafw.runtime.mapreduce.simple.KeyValueSorter.Options

Enclosing class:

KeyValueSorter<K,V>

public static final class KeyValueSorter.Options
extends Object

Settings for KeyValueSorter.

Since:

0.7.1

Constructor Summary

Constructors

Constructor and Description
Options()

Method Summary

Modifier and Type	Method and Description
int	getBlockSize() Returns in-memory block buffer size.
int	getPageSize() Returns in-memory sort buffer size.
File	getTemporaryDirectory() Returns the temporary directory for storing spill-out block files.
boolean	isCompressBlock() Returns whether spill-out block file is compressed or not.
KeyValueSorter.Options	withBufferSize(int bufferSize) Sets the total buffer size.
KeyValueSorter.Options	withBufferSize(int pageBufferSize, int blockBufferSize) Sets individual buffer sizes.
KeyValueSorter.Options	withCompressBlock(boolean enable) Returns whether spill-out block file is compressed or not.
KeyValueSorter.Options	withTemporaryDirectory(File path) Sets the temporary directory for the sorter.

Methods inherited from class java.lang.Object

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

Constructor Detail

Options

public Options()

Method Detail

getPageSize

public int getPageSize()

Returns in-memory sort buffer size.

Returns:

the in-memory sort buffer size

getBlockSize

public int getBlockSize()

Returns in-memory block buffer size.

Returns:

the in-memory block buffer size

getTemporaryDirectory

public File getTemporaryDirectory()

Returns the temporary directory for storing spill-out block files.

Returns:

the temporary directory, or null if it is not set

isCompressBlock

public boolean isCompressBlock()

Returns whether spill-out block file is compressed or not.

Returns:

true if compress block files, otherwise false

withBufferSize

public KeyValueSorter.Options withBufferSize(int bufferSize)

Sets the total buffer size.

Parameters:

bufferSize - the total buffer size

Returns:

this

withBufferSize

public KeyValueSorter.Options withBufferSize(int pageBufferSize,
                                             int blockBufferSize)

Sets individual buffer sizes.

Parameters:

pageBufferSize - in-memory sort buffer size

blockBufferSize - in-memory block buffer size

Returns:

this

withTemporaryDirectory

public KeyValueSorter.Options withTemporaryDirectory(File path)

Sets the temporary directory for the sorter.

Parameters:

path - the temporary directory path

Returns:

this

withCompressBlock

public KeyValueSorter.Options withCompressBlock(boolean enable)

Returns whether spill-out block file is compressed or not.

Parameters:

enable - true to enable compression

Returns:

this