Package | Description |
---|---|
org.apache.tez.runtime.library.common | |
org.apache.tez.runtime.library.common.shuffle.orderedgrouped |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
org.apache.tez.runtime.library.common.sort.impl |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
Modifier and Type | Method and Description |
---|---|
static Combiner |
TezRuntimeUtils.instantiateCombiner(org.apache.hadoop.conf.Configuration conf,
org.apache.tez.runtime.api.TaskContext taskContext) |
Constructor and Description |
---|
MergeManager(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem localFS,
org.apache.hadoop.fs.LocalDirAllocator localDirAllocator,
org.apache.tez.runtime.api.InputContext inputContext,
Combiner combiner,
org.apache.tez.common.counters.TezCounter spilledRecordsCounter,
org.apache.tez.common.counters.TezCounter reduceCombineInputCounter,
org.apache.tez.common.counters.TezCounter mergedMapOutputsCounter,
org.apache.tez.runtime.library.common.shuffle.orderedgrouped.ExceptionReporter exceptionReporter,
long initialMemoryAvailable,
org.apache.hadoop.io.compress.CompressionCodec codec,
boolean ifileReadAheadEnabled,
int ifileReadAheadLength)
Construct the MergeManager.
|
Modifier and Type | Field and Description |
---|---|
protected Combiner |
ExternalSorter.combiner |
Copyright © 2016 Apache Software Foundation. All rights reserved.