public class DefaultArtifactResolver extends java.lang.Object implements ArtifactResolver
ResolutionFn
in the reversed order
they registered i.e. the function registered later overrides the earlier one if they resolve the
same artifact.ArtifactResolver.ResolutionFn
Modifier and Type | Field and Description |
---|---|
static ArtifactResolver |
INSTANCE |
Constructor and Description |
---|
DefaultArtifactResolver() |
Modifier and Type | Method and Description |
---|---|
void |
register(ArtifactResolver.ResolutionFn fn)
Register
ArtifactResolver.ResolutionFn . |
java.util.List<org.apache.beam.model.pipeline.v1.RunnerApi.ArtifactInformation> |
resolveArtifacts(java.util.List<org.apache.beam.model.pipeline.v1.RunnerApi.ArtifactInformation> artifacts)
Resolves a list of artifacts by applying registered
ArtifactResolver.ResolutionFn s. |
org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline |
resolveArtifacts(org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline)
Updating pipeline proto by applying registered
ArtifactResolver.ResolutionFn s. |
public static final ArtifactResolver INSTANCE
public void register(ArtifactResolver.ResolutionFn fn)
ArtifactResolver
ArtifactResolver.ResolutionFn
. When multiple ArtifactResolver.ResolutionFn
s are capable of resolving the
same RunnerApi.ArtifactInformation
, the application order is up to the implementing
class of this interface.register
in interface ArtifactResolver
fn
- a resolution function to be registeredpublic java.util.List<org.apache.beam.model.pipeline.v1.RunnerApi.ArtifactInformation> resolveArtifacts(java.util.List<org.apache.beam.model.pipeline.v1.RunnerApi.ArtifactInformation> artifacts)
ArtifactResolver
ArtifactResolver.ResolutionFn
s.resolveArtifacts
in interface ArtifactResolver
public org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline resolveArtifacts(org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline)
ArtifactResolver
ArtifactResolver.ResolutionFn
s.resolveArtifacts
in interface ArtifactResolver