public class InputFormatVertex extends JobVertex
Constructor and Description |
---|
InputFormatVertex(String name) |
InputFormatVertex(String name,
JobVertexID id) |
Modifier and Type | Method and Description |
---|---|
String |
getFormatDescription() |
void |
initializeOnMaster(ClassLoader loader)
A hook that can be overwritten by sub classes to implement logic that is called by the
master when the job starts.
|
void |
setFormatDescription(String formatDescription) |
connectDataSetAsInput, connectIdInput, connectNewDataSetAsInput, connectNewDataSetAsInput, createAndAddResultDataSet, createAndAddResultDataSet, finalizeOnMaster, getCoLocationGroup, getConfiguration, getID, getInputs, getInputSplitSource, getInvokableClass, getInvokableClassName, getName, getNumberOfInputs, getNumberOfProducedIntermediateDataSets, getOperatorDescription, getOperatorName, getOperatorPrettyName, getParallelism, getProducedDataSets, getResultOptimizerProperties, getSlotSharingGroup, hasNoConnectedInputs, isInputVertex, isOutputVertex, isStoppable, setInputSplitSource, setInvokableClass, setName, setOperatorDescription, setOperatorName, setOperatorPrettyName, setParallelism, setResultOptimizerProperties, setSlotSharingGroup, setStrictlyCoLocatedWith, toString, updateCoLocationGroup
public InputFormatVertex(String name)
public InputFormatVertex(String name, JobVertexID id)
public void setFormatDescription(String formatDescription)
public String getFormatDescription()
public void initializeOnMaster(ClassLoader loader) throws Exception
JobVertex
initializeOnMaster
in class JobVertex
loader
- The class loader for user defined code.Exception
- The method may throw exceptions which cause the job to fail immediately.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.