org.apache.beam.artifact.local

Class LocalFileSystemArtifactStagerService

java.lang.Object

org.apache.beam.sdk.common.runner.v1.ArtifactStagingServiceGrpc.ArtifactStagingServiceImplBase

org.apache.beam.artifact.local.LocalFileSystemArtifactStagerService

All Implemented Interfaces:

io.grpc.BindableService

public class LocalFileSystemArtifactStagerService
extends org.apache.beam.sdk.common.runner.v1.ArtifactStagingServiceGrpc.ArtifactStagingServiceImplBase

An ArtifactStagingService which stages files to a local temp directory.

Method Summary

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)

Methods inherited from class org.apache.beam.sdk.common.runner.v1.ArtifactStagingServiceGrpc.ArtifactStagingServiceImplBase

bindService

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

withRootDirectory

public static LocalFileSystemArtifactStagerService withRootDirectory(java.io.File base)

putArtifact

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)

Overrides:

putArtifact in class org.apache.beam.sdk.common.runner.v1.ArtifactStagingServiceGrpc.ArtifactStagingServiceImplBase

commitManifest

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)

Overrides:

commitManifest in class org.apache.beam.sdk.common.runner.v1.ArtifactStagingServiceGrpc.ArtifactStagingServiceImplBase