org.apache.tez.runtime.library.conf

Class UnorderedPartitionedKVEdgeConfig.Builder

java.lang.Object

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

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

Enclosing class:

UnorderedPartitionedKVEdgeConfig

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

Method Summary

Methods

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

setAdditionalConfiguration

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

setFromConfiguration

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

setFromConfigurationUnfiltered

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

setKeySerializationClass

public UnorderedPartitionedKVEdgeConfig.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 UnorderedPartitionedKVEdgeConfig.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 UnorderedPartitionedKVOutputConfig.SpecificBuilder<UnorderedPartitionedKVEdgeConfig.Builder> configureOutput()

Configure the specific output

Returns:

a builder to configure the output

configureInput

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

Configure the specific input

Returns:

a builder to configure the input

build

public UnorderedPartitionedKVEdgeConfig build()

Build and return an instance of the configuration

Returns:

an instance of the acatual configuration