public class InputOutputFormatVertex extends JobVertex
JobVertex.FinalizeOnMasterContext, JobVertex.InitializeOnMasterContext
MAX_PARALLELISM_DEFAULT
Constructor and Description |
---|
InputOutputFormatVertex(String name) |
InputOutputFormatVertex(String name,
JobVertexID id,
List<OperatorIDPair> operatorIDPairs) |
Modifier and Type | Method and Description |
---|---|
void |
finalizeOnMaster(JobVertex.FinalizeOnMasterContext context)
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(JobVertex.InitializeOnMasterContext context)
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) |
addIntermediateDataSetIdToConsume, addOperatorCoordinator, connectNewDataSetAsInput, connectNewDataSetAsInput, connectNewDataSetAsInput, getCoLocationGroup, getConfiguration, getID, getInputs, getInputSplitSource, getIntermediateDataSetIdsToConsume, getInvokableClass, getInvokableClassName, getMaxParallelism, getMinResources, getName, getNumberOfInputs, getNumberOfProducedIntermediateDataSets, getOperatorCoordinators, getOperatorDescription, getOperatorIDs, getOperatorName, getOperatorPrettyName, getOrCreateResultDataSet, getParallelism, getPreferredResources, getProducedDataSets, getResultOptimizerProperties, getSlotSharingGroup, hasNoConnectedInputs, isAnyOutputBlocking, isDynamicParallelism, isInputVertex, isOutputVertex, isParallelismConfigured, isStoppable, isSupportsConcurrentExecutionAttempts, setDynamicParallelism, setInputSplitSource, setInvokableClass, setMaxParallelism, setName, setOperatorDescription, setOperatorName, setOperatorPrettyName, setParallelism, setParallelismConfigured, setResources, setResultOptimizerProperties, setSlotSharingGroup, setStrictlyCoLocatedWith, setSupportsConcurrentExecutionAttempts, toString, updateCoLocationGroup
public InputOutputFormatVertex(String name)
public InputOutputFormatVertex(String name, JobVertexID id, List<OperatorIDPair> operatorIDPairs)
public void initializeOnMaster(JobVertex.InitializeOnMasterContext context) throws Exception
JobVertex
initializeOnMaster
in class JobVertex
context
- Provides contextual information for the initializationException
- The method may throw exceptions which cause the job to fail immediately.public void finalizeOnMaster(JobVertex.FinalizeOnMasterContext context) throws Exception
JobVertex
finalizeOnMaster
in class JobVertex
context
- Provides contextual information for the initializationException
- 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–2024 The Apache Software Foundation. All rights reserved.