public class InputOutputFormatVertex extends JobVertex
Constructor and Description |
---|
InputOutputFormatVertex(String name) |
InputOutputFormatVertex(String name,
JobVertexID id,
List<JobVertexID> alternativeIds,
List<OperatorID> operatorIds,
List<OperatorID> alternativeOperatorIds) |
Modifier and Type | Method and Description |
---|---|
void |
finalizeOnMaster(ClassLoader loader)
A hook that can be overwritten by sub classes to implement logic that is called by the
master after the job completed.
|
String |
getFormatDescription(OperatorID operatorID) |
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(OperatorID operatorID,
String formatDescription) |
connectDataSetAsInput, connectIdInput, connectNewDataSetAsInput, createAndAddResultDataSet, createAndAddResultDataSet, getCoLocationGroup, getConfiguration, getID, getIdAlternatives, getInputDependencyConstraint, getInputs, getInputSplitSource, getInvokableClass, getInvokableClassName, getMaxParallelism, getMinResources, getName, getNumberOfInputs, getNumberOfProducedIntermediateDataSets, getOperatorDescription, getOperatorIDs, getOperatorName, getOperatorPrettyName, getParallelism, getPreferredResources, getProducedDataSets, getResultOptimizerProperties, getSlotSharingGroup, getUserDefinedOperatorIDs, hasNoConnectedInputs, isInputVertex, isOutputVertex, isStoppable, setInputDependencyConstraint, setInputSplitSource, setInvokableClass, setMaxParallelism, setName, setOperatorDescription, setOperatorName, setOperatorPrettyName, setParallelism, setResources, setResultOptimizerProperties, setSlotSharingGroup, setStrictlyCoLocatedWith, toString, updateCoLocationGroup
public InputOutputFormatVertex(String name)
public InputOutputFormatVertex(String name, JobVertexID id, List<JobVertexID> alternativeIds, List<OperatorID> operatorIds, List<OperatorID> alternativeOperatorIds)
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.public void finalizeOnMaster(ClassLoader loader) throws Exception
JobVertex
finalizeOnMaster
in class JobVertex
loader
- The class loader for user defined code.Exception
- The method may throw exceptions which cause the job to fail immediately.public String getFormatDescription(OperatorID operatorID)
public void setFormatDescription(OperatorID operatorID, String formatDescription)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.