org.apache.beam.runners.fnexecution.artifact

Class BeamFileSystemLegacyArtifactRetrievalService

java.lang.Object

org.apache.beam.model.jobmanagement.v1.LegacyArtifactRetrievalServiceGrpc.LegacyArtifactRetrievalServiceImplBase

org.apache.beam.runners.fnexecution.artifact.AbstractLegacyArtifactRetrievalService

org.apache.beam.runners.fnexecution.artifact.BeamFileSystemLegacyArtifactRetrievalService

All Implemented Interfaces:

java.lang.AutoCloseable, LegacyArtifactRetrievalService, FnService, org.apache.beam.vendor.grpc.v1p26p0.io.grpc.BindableService

public class BeamFileSystemLegacyArtifactRetrievalService
extends AbstractLegacyArtifactRetrievalService

An LegacyArtifactRetrievalService that uses FileSystems as its backing storage and uses the artifact layout and retrieval token format produced by BeamFileSystemLegacyArtifactStagingService.

Constructor Summary

Constructors

Constructor and Description
BeamFileSystemLegacyArtifactRetrievalService()

Method Summary

Modifier and Type	Method and Description
static BeamFileSystemLegacyArtifactRetrievalService	create()
java.io.InputStream	openManifest(java.lang.String retrievalToken)
java.io.InputStream	openUri(java.lang.String retrievalToken, java.lang.String uri)

Methods inherited from class org.apache.beam.runners.fnexecution.artifact.AbstractLegacyArtifactRetrievalService

close, getArtifact, getManifest, getManifestProxy

Methods inherited from class org.apache.beam.model.jobmanagement.v1.LegacyArtifactRetrievalServiceGrpc.LegacyArtifactRetrievalServiceImplBase

bindService

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.beam.vendor.grpc.v1p26p0.io.grpc.BindableService

bindService

Constructor Detail

BeamFileSystemLegacyArtifactRetrievalService

public BeamFileSystemLegacyArtifactRetrievalService()

Method Detail

create

public static BeamFileSystemLegacyArtifactRetrievalService create()

openUri

public java.io.InputStream openUri(java.lang.String retrievalToken,
                                   java.lang.String uri)
                            throws java.io.IOException

Specified by:

openUri in class AbstractLegacyArtifactRetrievalService

Throws:

java.io.IOException

openManifest

public java.io.InputStream openManifest(java.lang.String retrievalToken)
                                 throws java.io.IOException

Specified by:

openManifest in class AbstractLegacyArtifactRetrievalService

Throws:

java.io.IOException