@InterfaceAudience.Public @InterfaceStability.Evolving public static class OrderedGroupedKVInputConfig.SpecificBuilder<E extends org.apache.tez.runtime.library.conf.HadoopKeyValuesBasedBaseEdgeConfig.Builder> extends Object implements org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificConfigBuilder<OrderedGroupedKVInputConfig.SpecificBuilder>
Modifier and Type | Method and Description |
---|---|
E |
done() |
OrderedGroupedKVInputConfig.SpecificBuilder<E> |
setAdditionalConfiguration(Map<String,String> confMap)
Used to set additional configuration parameters which are not set via API methods.
|
OrderedGroupedKVInputConfig.SpecificBuilder<E> |
setAdditionalConfiguration(String key,
String value)
Used to set additional configuration parameters which are not set via API methods.
|
OrderedGroupedKVInputConfig.SpecificBuilder<E> |
setCombiner(String combinerClassName)
Configure the combiner class
|
OrderedGroupedKVInputConfig.SpecificBuilder<E> |
setCombiner(String combinerClassName,
Map<String,String> combinerConf)
Configure the combiner class and it's associated configuration (specified as key-value
pairs).
|
OrderedGroupedKVInputConfig.SpecificBuilder<E> |
setFromConfiguration(org.apache.hadoop.conf.Configuration conf)
Used to build out a configuration from an existing Hadoop
Configuration . |
OrderedGroupedKVInputConfig.SpecificBuilder<E> |
setMaxSingleMemorySegmentFraction(float maxSingleSegmentFraction)
Sets a size limit on the maximum segment size to be shuffled to disk.
|
OrderedGroupedKVInputConfig.SpecificBuilder<E> |
setMemToMemMerger(boolean enable)
Enable the memory to memory merger
|
OrderedGroupedKVInputConfig.SpecificBuilder<E> |
setMergeFraction(float mergeFraction)
Configure the point at which in memory segments will be merged.
|
OrderedGroupedKVInputConfig.SpecificBuilder<E> |
setPostMergeBufferFraction(float postMergeBufferFraction)
Sets the buffer fraction, as a fraction of container size, to be used after the fetch and
merge are complete.
|
OrderedGroupedKVInputConfig.SpecificBuilder<E> |
setShuffleBufferFraction(float shuffleBufferFraction)
Sets the buffer fraction, as a fraction of container size, to be used while fetching remote
data.
|
OrderedGroupedKVInputConfig.SpecificBuilder<E> |
useLegacyInput()
Specifies whether the legacy version of this input should be used.
|
public OrderedGroupedKVInputConfig.SpecificBuilder<E> useLegacyInput()
org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificConfigBuilder
useLegacyInput
in interface org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificConfigBuilder<OrderedGroupedKVInputConfig.SpecificBuilder>
public OrderedGroupedKVInputConfig.SpecificBuilder<E> setShuffleBufferFraction(float shuffleBufferFraction)
org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificConfigBuilder
setShuffleBufferFraction
in interface org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificConfigBuilder<OrderedGroupedKVInputConfig.SpecificBuilder>
shuffleBufferFraction
- fraction of container sizepublic OrderedGroupedKVInputConfig.SpecificBuilder<E> setPostMergeBufferFraction(float postMergeBufferFraction)
org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificConfigBuilder
setPostMergeBufferFraction
in interface org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificConfigBuilder<OrderedGroupedKVInputConfig.SpecificBuilder>
postMergeBufferFraction
- fraction of container sizepublic OrderedGroupedKVInputConfig.SpecificBuilder<E> setMaxSingleMemorySegmentFraction(float maxSingleSegmentFraction)
org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificConfigBuilder
setMaxSingleMemorySegmentFraction
in interface org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificConfigBuilder<OrderedGroupedKVInputConfig.SpecificBuilder>
maxSingleSegmentFraction
- fraction of memory determined by ShuffleBufferFractionpublic OrderedGroupedKVInputConfig.SpecificBuilder<E> setMemToMemMerger(boolean enable)
org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificConfigBuilder
setMemToMemMerger
in interface org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificConfigBuilder<OrderedGroupedKVInputConfig.SpecificBuilder>
enable
- whether to enable the memory to memory mergerpublic OrderedGroupedKVInputConfig.SpecificBuilder<E> setMergeFraction(float mergeFraction)
org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificConfigBuilder
setMergeFraction
in interface org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificConfigBuilder<OrderedGroupedKVInputConfig.SpecificBuilder>
mergeFraction
- fraction of memory determined by ShuffleBufferFraction, which when
filled, will
trigger a mergepublic OrderedGroupedKVInputConfig.SpecificBuilder<E> setCombiner(String combinerClassName)
org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificConfigBuilder
setCombiner
in interface org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificConfigBuilder<OrderedGroupedKVInputConfig.SpecificBuilder>
combinerClassName
- the combiner class namepublic OrderedGroupedKVInputConfig.SpecificBuilder<E> setCombiner(String combinerClassName, Map<String,String> combinerConf)
org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificConfigBuilder
OrderedGroupedKVInputConfig.SpecificConfigBuilder.setCombiner(String)
is the preferred method for setting a combiner.setCombiner
in interface org.apache.tez.runtime.library.conf.OrderedGroupedKVInputConfig.SpecificConfigBuilder<OrderedGroupedKVInputConfig.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 OrderedGroupedKVInputConfig.SpecificBuilder<E> setAdditionalConfiguration(String key, String value)
key
- the key to setvalue
- the corresponding valuepublic OrderedGroupedKVInputConfig.SpecificBuilder<E> setAdditionalConfiguration(Map<String,String> confMap)
confMap
- map of configuration key-value pairspublic OrderedGroupedKVInputConfig.SpecificBuilder<E> setFromConfiguration(org.apache.hadoop.conf.Configuration conf)
Configuration
. This is a private API is present only for
compatibility and ease of use for existing systems which rely heavily on Configuration.public E done()
Copyright © 2016 Apache Software Foundation. All rights reserved.