public class InputFormatVertex extends JobVertex
Constructor and Description |
---|
InputFormatVertex(String name) |
InputFormatVertex(String name,
JobVertexID id) |
InputFormatVertex(String name,
JobVertexID id,
List<JobVertexID> alternativeIds,
List<OperatorID> operatorIds,
List<OperatorID> alternativeOperatorIds) |
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, createAndAddResultDataSet, createAndAddResultDataSet, finalizeOnMaster, getCoLocationGroup, getConfiguration, getID, getIdAlternatives, getInputs, getInputSplitSource, getInvokableClass, getInvokableClassName, getMaxParallelism, getMinResources, getName, getNumberOfInputs, getNumberOfProducedIntermediateDataSets, getOperatorDescription, getOperatorIDs, getOperatorName, getOperatorPrettyName, getParallelism, getPreferredResources, getProducedDataSets, getResultOptimizerProperties, getSlotSharingGroup, getUserDefinedOperatorIDs, hasNoConnectedInputs, isInputVertex, isOutputVertex, isStoppable, setInputSplitSource, setInvokableClass, setMaxParallelism, setName, setOperatorDescription, setOperatorName, setOperatorPrettyName, setParallelism, setResources, setResultOptimizerProperties, setSlotSharingGroup, setStrictlyCoLocatedWith, toString, updateCoLocationGroup
public InputFormatVertex(String name)
public InputFormatVertex(String name, JobVertexID id)
public InputFormatVertex(String name, JobVertexID id, List<JobVertexID> alternativeIds, List<OperatorID> operatorIds, List<OperatorID> alternativeOperatorIds)
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–2020 The Apache Software Foundation. All rights reserved.