public class LocalFileSystemArtifactStagerService
extends org.apache.beam.sdk.common.runner.v1.ArtifactStagingServiceGrpc.ArtifactStagingServiceImplBase
ArtifactStagingService
which stages files to a local temp directory.Modifier and Type | Method and Description |
---|---|
void |
commitManifest(org.apache.beam.sdk.common.runner.v1.ArtifactApi.CommitManifestRequest request,
io.grpc.stub.StreamObserver<org.apache.beam.sdk.common.runner.v1.ArtifactApi.CommitManifestResponse> responseObserver) |
io.grpc.stub.StreamObserver<org.apache.beam.sdk.common.runner.v1.ArtifactApi.PutArtifactRequest> |
putArtifact(io.grpc.stub.StreamObserver<org.apache.beam.sdk.common.runner.v1.ArtifactApi.PutArtifactResponse> responseObserver) |
static LocalFileSystemArtifactStagerService |
withRootDirectory(java.io.File base) |
public static LocalFileSystemArtifactStagerService withRootDirectory(java.io.File base)
public io.grpc.stub.StreamObserver<org.apache.beam.sdk.common.runner.v1.ArtifactApi.PutArtifactRequest> putArtifact(io.grpc.stub.StreamObserver<org.apache.beam.sdk.common.runner.v1.ArtifactApi.PutArtifactResponse> responseObserver)
putArtifact
in class org.apache.beam.sdk.common.runner.v1.ArtifactStagingServiceGrpc.ArtifactStagingServiceImplBase
public void commitManifest(org.apache.beam.sdk.common.runner.v1.ArtifactApi.CommitManifestRequest request, io.grpc.stub.StreamObserver<org.apache.beam.sdk.common.runner.v1.ArtifactApi.CommitManifestResponse> responseObserver)
commitManifest
in class org.apache.beam.sdk.common.runner.v1.ArtifactStagingServiceGrpc.ArtifactStagingServiceImplBase