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
LegacyArtifactRetrievalService	An implementation of the Beam Artifact Retrieval Service.

Class Summary

Class	Description
AbstractLegacyArtifactRetrievalService	An LegacyArtifactRetrievalService that handles everything aside from actually opening the backing resources.
AbstractLegacyArtifactStagingService	An LegacyArtifactStagingServiceGrpc.LegacyArtifactStagingServiceImplBase that handles everything aside from actually opening the backing resources.
BeamFileSystemLegacyArtifactRetrievalService	An LegacyArtifactRetrievalService that uses FileSystems as its backing storage and uses the artifact layout and retrieval token format produced by BeamFileSystemLegacyArtifactStagingService.
BeamFileSystemLegacyArtifactStagingService	This implementation is experimental.
BeamFileSystemLegacyArtifactStagingService.StagingSessionToken	Serializable StagingSessionToken used to stage files with BeamFileSystemLegacyArtifactStagingService.
ClassLoaderLegacyArtifactRetrievalService	An LegacyArtifactRetrievalService that loads artifacts as ClassLoader resources.
JavaFilesystemLegacyArtifactStagingService	An LegacyArtifactStagingServiceGrpc.LegacyArtifactStagingServiceImplBase 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.