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

All Implemented Interfaces:

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

public class BeamFileSystemArtifactRetrievalService
extends org.apache.beam.model.jobmanagement.v1.ArtifactRetrievalServiceGrpc.ArtifactRetrievalServiceImplBase
implements ArtifactRetrievalService

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
void	close() .
static BeamFileSystemArtifactRetrievalService	create()
void	getArtifact(org.apache.beam.model.jobmanagement.v1.ArtifactApi.GetArtifactRequest request, org.apache.beam.vendor.grpc.v1.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.ArtifactChunk> responseObserver)
void	getManifest(org.apache.beam.model.jobmanagement.v1.ArtifactApi.GetManifestRequest request, org.apache.beam.vendor.grpc.v1.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.GetManifestResponse> responseObserver)

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

bindService

Constructor Detail

BeamFileSystemArtifactRetrievalService

public BeamFileSystemArtifactRetrievalService()

Method Detail

create

public static BeamFileSystemArtifactRetrievalService create()

getManifest

public void getManifest(org.apache.beam.model.jobmanagement.v1.ArtifactApi.GetManifestRequest request,
                        org.apache.beam.vendor.grpc.v1.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.GetManifestResponse> responseObserver)

Overrides:

getManifest in class org.apache.beam.model.jobmanagement.v1.ArtifactRetrievalServiceGrpc.ArtifactRetrievalServiceImplBase

getArtifact

public void getArtifact(org.apache.beam.model.jobmanagement.v1.ArtifactApi.GetArtifactRequest request,
                        org.apache.beam.vendor.grpc.v1.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.ArtifactChunk> responseObserver)

Overrides:

getArtifact in class org.apache.beam.model.jobmanagement.v1.ArtifactRetrievalServiceGrpc.ArtifactRetrievalServiceImplBase

close

public void close()
           throws java.lang.Exception

Description copied from interface: FnService

.

There should be no more calls to any service method by the time a call to FnService.close() begins. Specifically, this means that a Server that this service is bound to should have completed a call to the Server.shutdown() method, and all future incoming calls will be rejected.

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface FnService

Throws:

java.lang.Exception