org.apache.beam.sdk.util.construction

Interface ArtifactResolver

All Known Implementing Classes:

DefaultArtifactResolver

public interface ArtifactResolver

An interface for artifact resolvers. Artifact resolvers transform RunnerApi.ArtifactInformation from one type to another typically from remote or deferred artifacts to locally accessible file artifacts.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	ArtifactResolver.ResolutionFn A lazy transformer for resolving RunnerApi.ArtifactInformation.

Method Summary

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.ResolutionFns.
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.ResolutionFns.

Method Detail

register

void register(ArtifactResolver.ResolutionFn fn)

Register ArtifactResolver.ResolutionFn. When multiple ArtifactResolver.ResolutionFns are capable of resolving the same RunnerApi.ArtifactInformation, the application order is up to the implementing class of this interface.

Parameters:

fn - a resolution function to be registered

resolveArtifacts

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.ResolutionFns.

resolveArtifacts

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.ResolutionFns.