public class TezProcessor
extends org.apache.tez.runtime.api.AbstractLogicalIOProcessor
Modifier and Type | Class and Description |
---|---|
static interface |
TezProcessor.Hook
This provides the ability to pass things into TezProcessor, which is normally impossible
because of how Tez APIs are structured.
|
Modifier and Type | Field and Description |
---|---|
protected boolean |
isMap |
protected org.apache.hadoop.mapred.JobConf |
jobConf |
protected static NumberFormat |
jobIdFormat |
protected org.apache.tez.runtime.api.ProcessorContext |
processorContext |
protected RecordProcessor |
rproc |
protected static NumberFormat |
taskIdFormat |
Constructor and Description |
---|
TezProcessor(org.apache.tez.runtime.api.ProcessorContext context) |
Modifier and Type | Method and Description |
---|---|
void |
abort() |
void |
close() |
org.apache.hadoop.mapred.JobConf |
getConf() |
void |
handleEvents(List<org.apache.tez.runtime.api.Event> arg0) |
void |
initialize() |
protected void |
initializeAndRunProcessor(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs,
Map<String,org.apache.tez.runtime.api.LogicalOutput> outputs) |
void |
run(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs,
Map<String,org.apache.tez.runtime.api.LogicalOutput> outputs) |
protected boolean isMap
protected RecordProcessor rproc
protected org.apache.hadoop.mapred.JobConf jobConf
protected org.apache.tez.runtime.api.ProcessorContext processorContext
protected static final NumberFormat taskIdFormat
protected static final NumberFormat jobIdFormat
public TezProcessor(org.apache.tez.runtime.api.ProcessorContext context)
public void close() throws IOException
IOException
public void handleEvents(List<org.apache.tez.runtime.api.Event> arg0)
public void initialize() throws IOException
initialize
in interface org.apache.tez.runtime.api.ProcessorFrameworkInterface
initialize
in class org.apache.tez.runtime.api.AbstractLogicalIOProcessor
IOException
public void run(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs, Map<String,org.apache.tez.runtime.api.LogicalOutput> outputs) throws Exception
Exception
protected void initializeAndRunProcessor(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs, Map<String,org.apache.tez.runtime.api.LogicalOutput> outputs) throws Exception
Exception
public void abort()
abort
in interface org.apache.tez.runtime.api.ProcessorFrameworkInterface
abort
in class org.apache.tez.runtime.api.AbstractLogicalIOProcessor
public org.apache.hadoop.mapred.JobConf getConf()
Copyright © 2017 The Apache Software Foundation. All rights reserved.