org.apache.tez.runtime.library.conf

Class UnorderedKVOutputConfig.Builder

java.lang.Object

org.apache.tez.runtime.library.conf.UnorderedKVOutputConfig.Builder

All Implemented Interfaces:

org.apache.tez.runtime.library.conf.UnorderedKVOutputConfig.SpecificConfigBuilder<UnorderedKVOutputConfig.Builder>

Enclosing class:

UnorderedKVOutputConfig

@InterfaceAudience.Public
 @InterfaceStability.Evolving
public static class UnorderedKVOutputConfig.Builder
extends Object
implements org.apache.tez.runtime.library.conf.UnorderedKVOutputConfig.SpecificConfigBuilder<UnorderedKVOutputConfig.Builder>

Method Summary

Modifier and Type	Method and Description
UnorderedKVOutputConfig	build() Create the actual configuration instance.
UnorderedKVOutputConfig.Builder	setAdditionalConfiguration(Map<String,String> confMap) Used to set additional configuration parameters which are not set via API methods.
UnorderedKVOutputConfig.Builder	setAdditionalConfiguration(String key, String value) Used to set additional configuration parameters which are not set via API methods.
UnorderedKVOutputConfig.Builder	setCompression(boolean enabled, String compressionCodec, Map<String,String> codecConf)
UnorderedKVOutputConfig.Builder	setFromConfiguration(org.apache.hadoop.conf.Configuration conf)
UnorderedKVOutputConfig.Builder	setFromConfigurationUnfiltered(org.apache.hadoop.conf.Configuration conf)
UnorderedKVOutputConfig.Builder	setKeySerializationClass(String serializationClassName, Map<String,String> serializerConf) Set serialization class responsible for providing serializer/deserializer for keys.
UnorderedKVOutputConfig.Builder	setValueSerializationClass(String serializationClassName, Map<String,String> serializerConf) Set serialization class responsible for providing serializer/deserializer for values.

Methods inherited from class java.lang.Object

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

Method Detail

setAdditionalConfiguration

public UnorderedKVOutputConfig.Builder setAdditionalConfiguration(String key,
                                                                  String value)

Used to set additional configuration parameters which are not set via API methods. This is primarily meant for rarely used configuration options such as IFile read-ahead, configuring the number of parallel files to merge etc.

Parameters:

key - the key to set

value - the corresponding value

Returns:

this object for further chained method calls

setAdditionalConfiguration

public UnorderedKVOutputConfig.Builder setAdditionalConfiguration(Map<String,String> confMap)

Used to set additional configuration parameters which are not set via API methods. This is primarily meant for rarely used configuration options such as IFile read-ahead, configuring the number of parallel files to merge etc.

Additionally keys set via this method are made available to the combiner.

Parameters:

confMap - map of configuration key-value pairs

Returns:

this object for further chained method calls

setFromConfiguration

public UnorderedKVOutputConfig.Builder setFromConfiguration(org.apache.hadoop.conf.Configuration conf)

setFromConfigurationUnfiltered

public UnorderedKVOutputConfig.Builder setFromConfigurationUnfiltered(org.apache.hadoop.conf.Configuration conf)

setKeySerializationClass

public UnorderedKVOutputConfig.Builder setKeySerializationClass(String serializationClassName,
                                                                @Nullable
                                                                Map<String,String> serializerConf)

Set serialization class responsible for providing serializer/deserializer for keys.

Parameters:

serializationClassName -

serializerConf - the serializer configuration. This can be null, and is a Map of key-value pairs. The keys should be limited to the ones required by the comparator.

Returns:

this object for further chained method calls

setValueSerializationClass

public UnorderedKVOutputConfig.Builder setValueSerializationClass(String serializationClassName,
                                                                  @Nullable
                                                                  Map<String,String> serializerConf)

Set serialization class responsible for providing serializer/deserializer for values.

Parameters:

serializationClassName -

serializerConf - the serializer configuration. This can be null, and is a Map of key-value pairs. The keys should be limited to the ones required by the comparator.

Returns:

this object for further chained method calls

setCompression

public UnorderedKVOutputConfig.Builder setCompression(boolean enabled,
                                                      @Nullable
                                                      String compressionCodec,
                                                      @Nullable
                                                      Map<String,String> codecConf)

build

public UnorderedKVOutputConfig build()

Create the actual configuration instance.

Returns:

an instance of the Configuration