@InterfaceAudience.Public @InterfaceStability.Evolving public static class UnorderedPartitionedKVOutputConfig.Builder extends Object implements org.apache.tez.runtime.library.conf.UnorderedPartitionedKVOutputConfig.SpecificConfigBuilder<UnorderedPartitionedKVOutputConfig.Builder>
Modifier and Type | Method and Description |
---|---|
UnorderedPartitionedKVOutputConfig |
build()
Create the actual configuration instance.
|
UnorderedPartitionedKVOutputConfig.Builder |
setAdditionalConfiguration(Map<String,String> confMap)
Used to set additional configuration parameters which are not set via API methods.
|
UnorderedPartitionedKVOutputConfig.Builder |
setAdditionalConfiguration(String key,
String value)
Used to set additional configuration parameters which are not set via API methods.
|
UnorderedPartitionedKVOutputConfig.Builder |
setAvailableBufferSize(int availableBufferSize)
Set the buffer size to use
|
UnorderedPartitionedKVOutputConfig.Builder |
setCompression(boolean enabled,
String compressionCodec,
Map<String,String> codecConf) |
UnorderedPartitionedKVOutputConfig.Builder |
setFromConfiguration(org.apache.hadoop.conf.Configuration conf) |
UnorderedPartitionedKVOutputConfig.Builder |
setFromConfigurationUnfiltered(org.apache.hadoop.conf.Configuration conf) |
UnorderedPartitionedKVOutputConfig.Builder |
setKeySerializationClass(String serializationClassName,
Map<String,String> serializerConf)
Set serialization class responsible for providing serializer/deserializer for keys.
|
UnorderedPartitionedKVOutputConfig.Builder |
setValueSerializationClass(String serializationClassName,
Map<String,String> serializerConf)
Set serialization class responsible for providing serializer/deserializer for values.
|
public UnorderedPartitionedKVOutputConfig.Builder setAvailableBufferSize(int availableBufferSize)
org.apache.tez.runtime.library.conf.UnorderedPartitionedKVOutputConfig.SpecificConfigBuilder
setAvailableBufferSize
in interface org.apache.tez.runtime.library.conf.UnorderedPartitionedKVOutputConfig.SpecificConfigBuilder<UnorderedPartitionedKVOutputConfig.Builder>
availableBufferSize
- the size of the buffer in MBpublic UnorderedPartitionedKVOutputConfig.Builder setAdditionalConfiguration(String key, String value)
key
- the key to setvalue
- the corresponding valuepublic UnorderedPartitionedKVOutputConfig.Builder setAdditionalConfiguration(Map<String,String> confMap)
confMap
- map of configuration key-value pairspublic UnorderedPartitionedKVOutputConfig.Builder setFromConfiguration(org.apache.hadoop.conf.Configuration conf)
public UnorderedPartitionedKVOutputConfig.Builder setFromConfigurationUnfiltered(org.apache.hadoop.conf.Configuration conf)
public UnorderedPartitionedKVOutputConfig.Builder setCompression(boolean enabled, @Nullable String compressionCodec, @Nullable Map<String,String> codecConf)
public UnorderedPartitionedKVOutputConfig.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 UnorderedPartitionedKVOutputConfig.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 UnorderedPartitionedKVOutputConfig build()
Copyright © 2024 Apache Software Foundation. All rights reserved.