org.apache.beam.runners.fnexecution.artifact

Class BeamFileSystemArtifactRetrievalService

java.lang.Object

org.apache.beam.model.jobmanagement.v1.ArtifactRetrievalServiceGrpc.ArtifactRetrievalServiceImplBase

org.apache.beam.runners.fnexecution.artifact.AbstractArtifactRetrievalService

org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService

All Implemented Interfaces:

java.lang.AutoCloseable, ArtifactRetrievalService, FnService, org.apache.beam.vendor.grpc.v1p21p0.io.grpc.BindableService

public class BeamFileSystemArtifactRetrievalService
extends AbstractArtifactRetrievalService

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

Constructor Summary

Constructors

Constructor and Description
BeamFileSystemArtifactRetrievalService()

Method Summary

Modifier and Type	Method and Description
static BeamFileSystemArtifactRetrievalService	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.AbstractArtifactRetrievalService

close, getArtifact, getManifest, getManifestProxy

Methods inherited from class org.apache.beam.model.jobmanagement.v1.ArtifactRetrievalServiceGrpc.ArtifactRetrievalServiceImplBase

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.v1p21p0.io.grpc.BindableService

bindService

Constructor Detail

BeamFileSystemArtifactRetrievalService

public BeamFileSystemArtifactRetrievalService()

Method Detail

create

public static BeamFileSystemArtifactRetrievalService create()

openUri

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

Specified by:

openUri in class AbstractArtifactRetrievalService

Throws:

java.io.IOException

openManifest

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

Specified by:

openManifest in class AbstractArtifactRetrievalService

Throws:

java.io.IOException