@InterfaceAudience.Public @InterfaceStability.Evolving public static class UnorderedKVEdgeConfig.Builder extends org.apache.tez.runtime.library.conf.HadoopKeyValuesBasedBaseEdgeConfig.Builder<UnorderedKVEdgeConfig.Builder>
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 |
setFromConfigurationUnfiltered(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.
|
public UnorderedKVEdgeConfig.Builder setCompression(boolean enabled, @Nullable String compressionCodec, @Nullable Map<String,String> codecConf)
org.apache.tez.runtime.library.conf.HadoopKeyValuesBasedBaseEdgeConfig.Builder
setCompression
in class org.apache.tez.runtime.library.conf.HadoopKeyValuesBasedBaseEdgeConfig.Builder<UnorderedKVEdgeConfig.Builder>
enabled
- whether to enable compression or notcompressionCodec
- the codec to be used if compression is enabled. null implies using
the defaultcodecConf
- 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.public UnorderedKVEdgeConfig.Builder setAdditionalConfiguration(String key, String value)
public UnorderedKVEdgeConfig.Builder setAdditionalConfiguration(Map<String,String> confMap)
public UnorderedKVEdgeConfig.Builder setFromConfiguration(org.apache.hadoop.conf.Configuration conf)
public UnorderedKVEdgeConfig.Builder setFromConfigurationUnfiltered(org.apache.hadoop.conf.Configuration conf)
public UnorderedKVEdgeConfig.Builder setKeySerializationClass(String serializationClassName, @Nullable Map<String,String> serializerConf)
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.public UnorderedKVEdgeConfig.Builder setValueSerializationClass(String serializationClassName, @Nullable Map<String,String> serializerConf)
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.public UnorderedKVOutputConfig.SpecificBuilder<UnorderedKVEdgeConfig.Builder> configureOutput()
public UnorderedKVInputConfig.SpecificBuilder<UnorderedKVEdgeConfig.Builder> configureInput()
public UnorderedKVEdgeConfig build()
Copyright © 2024 Apache Software Foundation. All rights reserved.