public class LocalFileSystemArtifactStagerService extends org.apache.beam.model.jobmanagement.v1.ArtifactStagingServiceGrpc.ArtifactStagingServiceImplBase implements FnService
ArtifactStagingService
which stages files to a local temp directory.Modifier and Type | Method and Description |
---|---|
void |
close()
.
|
void |
commitManifest(org.apache.beam.model.jobmanagement.v1.ArtifactApi.CommitManifestRequest request,
io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.CommitManifestResponse> responseObserver) |
io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.PutArtifactRequest> |
putArtifact(io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.PutArtifactResponse> responseObserver) |
static LocalFileSystemArtifactStagerService |
withRootDirectory(java.io.File base) |
bindService
public static LocalFileSystemArtifactStagerService withRootDirectory(java.io.File base)
public io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.PutArtifactRequest> putArtifact(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, 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.