public class VertexInputInfoStore extends Object
JobVertexInputInfo
s. Note that if a vertex has multiple job
edges connecting to the same intermediate result, their DistributionPattern
must be the
same and therefore the JobVertexInputInfo
will be the same.Constructor and Description |
---|
VertexInputInfoStore() |
Modifier and Type | Method and Description |
---|---|
JobVertexInputInfo |
get(JobVertexID jobVertexId,
IntermediateDataSetID resultId)
Get a
JobVertexInputInfo . |
void |
put(JobVertexID jobVertexId,
IntermediateDataSetID resultId,
JobVertexInputInfo info)
Put a
JobVertexInputInfo . |
public void put(JobVertexID jobVertexId, IntermediateDataSetID resultId, JobVertexInputInfo info)
JobVertexInputInfo
.jobVertexId
- the job vertex idresultId
- the intermediate result idinfo
- the JobVertexInputInfo
to putpublic JobVertexInputInfo get(JobVertexID jobVertexId, IntermediateDataSetID resultId)
JobVertexInputInfo
.jobVertexId
- the job vertex idresultId
- the intermediate result idJobVertexInputInfo
identified by the job vertex id and intermediate
result idCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.