@InterfaceAudience.Public @InterfaceStability.Evolving public static class OrderedPartitionedKVEdgeConfig.Builder extends org.apache.tez.runtime.library.conf.HadoopKeyValuesBasedBaseEdgeConfig.Builder<OrderedPartitionedKVEdgeConfig.Builder>
public OrderedPartitionedKVEdgeConfig.Builder setKeyComparatorClass(String comparatorClassName)
comparatorClassName
- the key comparator class namepublic OrderedPartitionedKVEdgeConfig.Builder setKeyComparatorClass(String comparatorClassName, @Nullable Map<String,String> comparatorConf)
setKeyComparatorClass(String)
is the preferred method for setting a
comparator.comparatorClassName
- the key comparator class namecomparatorConf
- the comparator 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 OrderedPartitionedKVEdgeConfig.Builder setKeySerializationClass(String serializationClassName, String comparatorClassName, @Nullable Map<String,String> serializerConf)
serializationClassName
- comparatorClassName
- 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 OrderedPartitionedKVEdgeConfig.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 OrderedPartitionedKVEdgeConfig.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<OrderedPartitionedKVEdgeConfig.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 OrderedPartitionedKVEdgeConfig.Builder setAdditionalConfiguration(String key, String value)
public OrderedPartitionedKVEdgeConfig.Builder setAdditionalConfiguration(Map<String,String> confMap)
public OrderedPartitionedKVEdgeConfig.Builder setFromConfiguration(org.apache.hadoop.conf.Configuration conf)
public OrderedPartitionedKVEdgeConfig.Builder setFromConfigurationUnfiltered(org.apache.hadoop.conf.Configuration conf)
public OrderedPartitionedKVOutputConfig.SpecificBuilder<OrderedPartitionedKVEdgeConfig.Builder> configureOutput()
public OrderedGroupedKVInputConfig.SpecificBuilder<OrderedPartitionedKVEdgeConfig.Builder> configureInput()
public OrderedPartitionedKVEdgeConfig build()
Copyright © 2024 Apache Software Foundation. All rights reserved.