org.apache.beam.runners.fnexecution.artifact

Class AbstractLegacyArtifactStagingService

java.lang.Object

org.apache.beam.model.jobmanagement.v1.LegacyArtifactStagingServiceGrpc.LegacyArtifactStagingServiceImplBase

org.apache.beam.runners.fnexecution.artifact.AbstractLegacyArtifactStagingService

All Implemented Interfaces:

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

Direct Known Subclasses:

BeamFileSystemLegacyArtifactStagingService, JavaFilesystemLegacyArtifactStagingService

public abstract class AbstractLegacyArtifactStagingService
extends org.apache.beam.model.jobmanagement.v1.LegacyArtifactStagingServiceGrpc.LegacyArtifactStagingServiceImplBase
implements FnService

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

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	NO_ARTIFACTS_STAGED_TOKEN

Constructor Summary

Constructors

Constructor and Description
AbstractLegacyArtifactStagingService()

Method Summary

Modifier and Type	Method and Description
void	close() .
void	commitManifest(org.apache.beam.model.jobmanagement.v1.ArtifactApi.CommitManifestRequest request, org.apache.beam.vendor.grpc.v1p26p0.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.CommitManifestResponse> responseObserver)
abstract java.lang.String	getArtifactUri(java.lang.String stagingSessionToken, java.lang.String encodedFileName)
abstract java.lang.String	getRetrievalToken(java.lang.String stagingSessionToken)
abstract java.nio.channels.WritableByteChannel	openManifest(java.lang.String stagingSessionToken)
abstract java.nio.channels.WritableByteChannel	openUri(java.lang.String uri)
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.PutArtifactRequest>	putArtifact(org.apache.beam.vendor.grpc.v1p26p0.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.PutArtifactResponse> responseObserver)
abstract void	removeArtifacts(java.lang.String stagingSessionToken)
abstract void	removeUri(java.lang.String uri)

Methods inherited from class org.apache.beam.model.jobmanagement.v1.LegacyArtifactStagingServiceGrpc.LegacyArtifactStagingServiceImplBase

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

Field Detail

NO_ARTIFACTS_STAGED_TOKEN

public static final java.lang.String NO_ARTIFACTS_STAGED_TOKEN

Constructor Detail

AbstractLegacyArtifactStagingService

public AbstractLegacyArtifactStagingService()

Method Detail

getArtifactUri

public abstract java.lang.String getArtifactUri(java.lang.String stagingSessionToken,
                                                java.lang.String encodedFileName)
                                         throws java.lang.Exception

Throws:

java.lang.Exception

openUri

public abstract java.nio.channels.WritableByteChannel openUri(java.lang.String uri)
                                                       throws java.io.IOException

Throws:

java.io.IOException

removeUri

public abstract void removeUri(java.lang.String uri)
                        throws java.io.IOException

Throws:

java.io.IOException

openManifest

public abstract java.nio.channels.WritableByteChannel openManifest(java.lang.String stagingSessionToken)
                                                            throws java.lang.Exception

Throws:

java.lang.Exception

removeArtifacts

public abstract void removeArtifacts(java.lang.String stagingSessionToken)
                              throws java.lang.Exception

Throws:

java.lang.Exception

getRetrievalToken

public abstract java.lang.String getRetrievalToken(java.lang.String stagingSessionToken)
                                            throws java.lang.Exception

Throws:

java.lang.Exception

putArtifact

public org.apache.beam.vendor.grpc.v1p26p0.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.PutArtifactRequest> putArtifact(org.apache.beam.vendor.grpc.v1p26p0.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.PutArtifactResponse> responseObserver)

Overrides:

putArtifact in class org.apache.beam.model.jobmanagement.v1.LegacyArtifactStagingServiceGrpc.LegacyArtifactStagingServiceImplBase

commitManifest

public void commitManifest(org.apache.beam.model.jobmanagement.v1.ArtifactApi.CommitManifestRequest request,
                           org.apache.beam.vendor.grpc.v1p26p0.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.CommitManifestResponse> responseObserver)

Overrides:

commitManifest in class org.apache.beam.model.jobmanagement.v1.LegacyArtifactStagingServiceGrpc.LegacyArtifactStagingServiceImplBase

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