org.apache.beam.runners.fnexecution.artifact

Class AbstractArtifactRetrievalService

java.lang.Object

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

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

All Implemented Interfaces:

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

Direct Known Subclasses:

BeamFileSystemArtifactRetrievalService, ClassLoaderArtifactRetrievalService

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

An ArtifactRetrievalService that handles everything aside from actually opening the backing resources.

Constructor Summary

Constructors

Constructor and Description
AbstractArtifactRetrievalService()
AbstractArtifactRetrievalService(org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.Cache<java.lang.String,org.apache.beam.model.jobmanagement.v1.ArtifactApi.ProxyManifest> manifestCache)

Method Summary

Modifier and Type	Method and Description
void	close() .
void	getArtifact(org.apache.beam.model.jobmanagement.v1.ArtifactApi.GetArtifactRequest request, org.apache.beam.vendor.grpc.v1p21p0.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.v1p21p0.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.GetManifestResponse> responseObserver)
org.apache.beam.model.jobmanagement.v1.ArtifactApi.ProxyManifest	getManifestProxy(java.lang.String retrievalToken)
abstract java.io.InputStream	openManifest(java.lang.String retrievalToken)
abstract java.io.InputStream	openUri(java.lang.String retrievalToken, java.lang.String uri)

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

AbstractArtifactRetrievalService

public AbstractArtifactRetrievalService()

AbstractArtifactRetrievalService

public AbstractArtifactRetrievalService(org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.Cache<java.lang.String,org.apache.beam.model.jobmanagement.v1.ArtifactApi.ProxyManifest> manifestCache)

Method Detail

openManifest

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

Throws:

java.io.IOException

openUri

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

Throws:

java.io.IOException

getManifestProxy

public org.apache.beam.model.jobmanagement.v1.ArtifactApi.ProxyManifest getManifestProxy(java.lang.String retrievalToken)
                                                                                  throws java.io.IOException,
                                                                                         java.util.concurrent.ExecutionException

Throws:

java.io.IOException

java.util.concurrent.ExecutionException

getManifest

public void getManifest(org.apache.beam.model.jobmanagement.v1.ArtifactApi.GetManifestRequest request,
                        org.apache.beam.vendor.grpc.v1p21p0.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.v1p21p0.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