@InterfaceAudience.Public @InterfaceStability.Evolving public static class OrderedPartitionedKVOutputConfig.SpecificBuilder<E extends org.apache.tez.runtime.library.conf.HadoopKeyValuesBasedBaseEdgeConfig.Builder> extends Object implements org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.SpecificConfigBuilder<OrderedPartitionedKVOutputConfig.SpecificBuilder>
Modifier and Type | Method and Description |
---|---|
E |
done() |
OrderedPartitionedKVOutputConfig.SpecificBuilder<E> |
setAdditionalConfiguration(Map<String,String> confMap)
Used to set additional configuration parameters which are not set via API methods.
|
OrderedPartitionedKVOutputConfig.SpecificBuilder<E> |
setAdditionalConfiguration(String key,
String value)
Used to set additional configuration parameters which are not set via API methods.
|
OrderedPartitionedKVOutputConfig.SpecificBuilder<E> |
setCombiner(String combinerClassName)
Configure the combiner class
|
OrderedPartitionedKVOutputConfig.SpecificBuilder<E> |
setCombiner(String combinerClassName,
Map<String,String> combinerConf)
Configure the combiner class and it's associated configuration (specified as key-value
pairs).
|
OrderedPartitionedKVOutputConfig.SpecificBuilder<E> |
setFromConfiguration(org.apache.hadoop.conf.Configuration conf) |
OrderedPartitionedKVOutputConfig.SpecificBuilder |
setFromConfigurationUnfiltered(org.apache.hadoop.conf.Configuration conf) |
OrderedPartitionedKVOutputConfig.SpecificBuilder<E> |
setSortBufferSize(int sortBufferSize)
Set the buffer size to use when sort the output
|
OrderedPartitionedKVOutputConfig.SpecificBuilder |
setSorter(org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.SorterImpl sorterImpl)
Configure which sorter implementation to be used
|
OrderedPartitionedKVOutputConfig.SpecificBuilder<E> |
setSorterNumThreads(int numThreads)
Configure the number of threads to be used by the sorter
|
public OrderedPartitionedKVOutputConfig.SpecificBuilder<E> setSortBufferSize(int sortBufferSize)
org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.SpecificConfigBuilder
setSortBufferSize
in interface org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.SpecificConfigBuilder<OrderedPartitionedKVOutputConfig.SpecificBuilder>
sortBufferSize
- the size of the buffer in MBpublic OrderedPartitionedKVOutputConfig.SpecificBuilder<E> setCombiner(String combinerClassName)
org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.SpecificConfigBuilder
setCombiner
in interface org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.SpecificConfigBuilder<OrderedPartitionedKVOutputConfig.SpecificBuilder>
combinerClassName
- the combiner class namepublic OrderedPartitionedKVOutputConfig.SpecificBuilder<E> setCombiner(String combinerClassName, Map<String,String> combinerConf)
org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.SpecificConfigBuilder
OrderedPartitionedKVOutputConfig.SpecificConfigBuilder.setCombiner(String)
is the preferred method for setting a combiner.setCombiner
in interface org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.SpecificConfigBuilder<OrderedPartitionedKVOutputConfig.SpecificBuilder>
combinerClassName
- the combiner class namecombinerConf
- the combiner configuration. This can be null, and otherwise
is a Map
of key-value pairs. The keys should
be limited to the ones required by the combiner.public OrderedPartitionedKVOutputConfig.SpecificBuilder<E> setSorterNumThreads(int numThreads)
org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.SpecificConfigBuilder
setSorterNumThreads
in interface org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.SpecificConfigBuilder<OrderedPartitionedKVOutputConfig.SpecificBuilder>
numThreads
- the number of threadspublic OrderedPartitionedKVOutputConfig.SpecificBuilder setSorter(org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.SorterImpl sorterImpl)
org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.SpecificConfigBuilder
setSorter
in interface org.apache.tez.runtime.library.conf.OrderedPartitionedKVOutputConfig.SpecificConfigBuilder<OrderedPartitionedKVOutputConfig.SpecificBuilder>
sorterImpl
- Use an in-built sorter implementations.public OrderedPartitionedKVOutputConfig.SpecificBuilder<E> setAdditionalConfiguration(String key, String value)
key
- the key to setvalue
- the corresponding valuepublic OrderedPartitionedKVOutputConfig.SpecificBuilder<E> setAdditionalConfiguration(Map<String,String> confMap)
confMap
- map of configuration key-value pairspublic OrderedPartitionedKVOutputConfig.SpecificBuilder<E> setFromConfiguration(org.apache.hadoop.conf.Configuration conf)
public OrderedPartitionedKVOutputConfig.SpecificBuilder setFromConfigurationUnfiltered(org.apache.hadoop.conf.Configuration conf)
public E done()
Copyright © 2024 Apache Software Foundation. All rights reserved.