public abstract class AbstractArtifactStagingService extends org.apache.beam.model.jobmanagement.v1.ArtifactStagingServiceGrpc.ArtifactStagingServiceImplBase implements FnService
ArtifactStagingServiceGrpc.ArtifactStagingServiceImplBase
that handles everything aside from actually opening the
backing resources.Modifier and Type | Field and Description |
---|---|
static java.lang.String |
NO_ARTIFACTS_STAGED_TOKEN |
Constructor and Description |
---|
AbstractArtifactStagingService() |
Modifier and Type | Method and Description |
---|---|
void |
close()
.
|
void |
commitManifest(org.apache.beam.model.jobmanagement.v1.ArtifactApi.CommitManifestRequest request,
org.apache.beam.vendor.grpc.v1p21p0.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.v1p21p0.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.PutArtifactRequest> |
putArtifact(org.apache.beam.vendor.grpc.v1p21p0.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) |
bindService
public static final java.lang.String NO_ARTIFACTS_STAGED_TOKEN
public abstract java.lang.String getArtifactUri(java.lang.String stagingSessionToken, java.lang.String encodedFileName) throws java.lang.Exception
java.lang.Exception
public abstract java.nio.channels.WritableByteChannel openUri(java.lang.String uri) throws java.io.IOException
java.io.IOException
public abstract void removeUri(java.lang.String uri) throws java.io.IOException
java.io.IOException
public abstract java.nio.channels.WritableByteChannel openManifest(java.lang.String stagingSessionToken) throws java.lang.Exception
java.lang.Exception
public abstract void removeArtifacts(java.lang.String stagingSessionToken) throws java.lang.Exception
java.lang.Exception
public abstract java.lang.String getRetrievalToken(java.lang.String stagingSessionToken) throws java.lang.Exception
java.lang.Exception
public org.apache.beam.vendor.grpc.v1p21p0.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.PutArtifactRequest> putArtifact(org.apache.beam.vendor.grpc.v1p21p0.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.PutArtifactResponse> responseObserver)
putArtifact
in class org.apache.beam.model.jobmanagement.v1.ArtifactStagingServiceGrpc.ArtifactStagingServiceImplBase
public void commitManifest(org.apache.beam.model.jobmanagement.v1.ArtifactApi.CommitManifestRequest request, org.apache.beam.vendor.grpc.v1p21p0.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.CommitManifestResponse> responseObserver)
commitManifest
in class org.apache.beam.model.jobmanagement.v1.ArtifactStagingServiceGrpc.ArtifactStagingServiceImplBase
public void close() throws java.lang.Exception
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.