Package org.apache.beam.runners.fnexecution.artifact

Pipeline execution-time artifact-management services, including abstract implementations of the Artifact Retrieval Service.

See: Description

Interface Summary

Interface	Description
ArtifactRetrievalService	An implementation of the Beam Artifact Retrieval Service.

Class Summary

Class	Description
AbstractArtifactRetrievalService	An ArtifactRetrievalService that handles everything aside from actually opening the backing resources.
AbstractArtifactStagingService	An ArtifactStagingServiceGrpc.ArtifactStagingServiceImplBase that handles everything aside from actually opening the backing resources.
BeamFileSystemArtifactRetrievalService	An ArtifactRetrievalService that uses FileSystems as its backing storage and uses the artifact layout and retrieval token format produced by BeamFileSystemArtifactStagingService.
BeamFileSystemArtifactStagingService	This implementation is experimental.
BeamFileSystemArtifactStagingService.StagingSessionToken	Serializable StagingSessionToken used to stage files with BeamFileSystemArtifactStagingService.
ClassLoaderArtifactRetrievalService	An ArtifactRetrievalService that loads artifacts as ClassLoader resources.
JavaFilesystemArtifactStagingService	An ArtifactStagingServiceGrpc.ArtifactStagingServiceImplBase that loads artifacts into a Java FileSystem.

Package org.apache.beam.runners.fnexecution.artifact Description

Pipeline execution-time artifact-management services, including abstract implementations of the Artifact Retrieval Service.