public class MergeFileTezProcessor extends TezProcessor
TezProcessor.Hook
isMap, jobConf, jobIdFormat, processorContext, rproc, taskIdFormat
Constructor and Description |
---|
MergeFileTezProcessor(org.apache.tez.runtime.api.ProcessorContext context) |
Modifier and Type | Method and Description |
---|---|
void |
run(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs,
Map<String,org.apache.tez.runtime.api.LogicalOutput> outputs) |
abort, close, getConf, handleEvents, initialize, initializeAndRunProcessor
public MergeFileTezProcessor(org.apache.tez.runtime.api.ProcessorContext context)
public void run(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs, Map<String,org.apache.tez.runtime.api.LogicalOutput> outputs) throws Exception
run
in interface org.apache.tez.runtime.api.LogicalIOProcessorFrameworkInterface
run
in class TezProcessor
Exception
Copyright © 2021 The Apache Software Foundation. All rights reserved.