Package | Description |
---|---|
com.asakusafw.runtime.mapreduce.simple |
Simplified MapReduce engine.
|
Modifier and Type | Method and Description |
---|---|
KeyValueSorter.Options |
KeyValueSorter.Options.withBufferSize(int bufferSize)
Sets the total buffer size.
|
KeyValueSorter.Options |
KeyValueSorter.Options.withBufferSize(int pageBufferSize,
int blockBufferSize)
Sets individual buffer sizes.
|
KeyValueSorter.Options |
KeyValueSorter.Options.withCompressBlock(boolean enable)
Returns whether spill-out block file is compressed or not.
|
KeyValueSorter.Options |
KeyValueSorter.Options.withTemporaryDirectory(File path)
Sets the temporary directory for the sorter.
|
Constructor and Description |
---|
KeyValueSorter(org.apache.hadoop.io.serializer.SerializationFactory serialization,
Class<K> keyClass,
Class<V> valueClass,
org.apache.hadoop.io.RawComparator<?> comparator,
KeyValueSorter.Options options)
Creates a new instance.
|
Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.