org.apache.tez.runtime.library.conf

Class UnorderedKVEdgeConfig.Builder

java.lang.Object

org.apache.tez.runtime.library.conf.HadoopKeyValuesBasedBaseEdgeConfig.Builder<UnorderedKVEdgeConfig.Builder>

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

Enclosing class:

UnorderedKVEdgeConfig

@InterfaceAudience.Public
@InterfaceStability.Evolving
public static class UnorderedKVEdgeConfig.Builder
extends org.apache.tez.runtime.library.conf.HadoopKeyValuesBasedBaseEdgeConfig.Builder<UnorderedKVEdgeConfig.Builder>

Method Summary

Methods

Modifier and Type	Method and Description
UnorderedKVEdgeConfig	build() Build and return an instance of the configuration
UnorderedKVInputConfig.SpecificBuilder<UnorderedKVEdgeConfig.Builder>	configureInput() Configure the specific input
UnorderedKVOutputConfig.SpecificBuilder<UnorderedKVEdgeConfig.Builder>	configureOutput() Configure the specific output
UnorderedKVEdgeConfig.Builder	setAdditionalConfiguration(Map<String,String> confMap)
UnorderedKVEdgeConfig.Builder	setAdditionalConfiguration(String key, String value)
UnorderedKVEdgeConfig.Builder	setCompression(boolean enabled, String compressionCodec, Map<String,String> codecConf) Enable compression for the specific Input / Output / Edge
UnorderedKVEdgeConfig.Builder	setFromConfiguration(org.apache.hadoop.conf.Configuration conf)
UnorderedKVEdgeConfig.Builder	setKeySerializationClass(String serializationClassName, Map<String,String> serializerConf) Set serialization class responsible for providing serializer/deserializer for key/value and the corresponding comparator class to be used as key comparator.
UnorderedKVEdgeConfig.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

setCompression

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

Description copied from class: org.apache.tez.runtime.library.conf.HadoopKeyValuesBasedBaseEdgeConfig.Builder

Enable compression for the specific Input / Output / Edge

Specified by:

setCompression in class org.apache.tez.runtime.library.conf.HadoopKeyValuesBasedBaseEdgeConfig.Builder<UnorderedKVEdgeConfig.Builder>

Parameters:

enabled - whether to enable compression or not

compressionCodec - the codec to be used if compression is enabled. null implies using the default

codecConf - the codec 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:

instance of the current builder

setAdditionalConfiguration

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

setAdditionalConfiguration

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

setFromConfiguration

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

setKeySerializationClass

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

Set serialization class responsible for providing serializer/deserializer for key/value and the corresponding comparator class to be used as key comparator.

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 UnorderedKVEdgeConfig.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

configureOutput

public UnorderedKVOutputConfig.SpecificBuilder<UnorderedKVEdgeConfig.Builder> configureOutput()

Configure the specific output

Returns:

a builder to configure the output

configureInput

public UnorderedKVInputConfig.SpecificBuilder<UnorderedKVEdgeConfig.Builder> configureInput()

Configure the specific input

Returns:

a builder to configure the input

build

public UnorderedKVEdgeConfig build()

Build and return an instance of the configuration

Returns:

an instance of the acatual configuration