public class ArtifactRetrievalService extends org.apache.beam.model.jobmanagement.v1.ArtifactRetrievalServiceGrpc.ArtifactRetrievalServiceImplBase implements FnService
ArtifactRetrievalService
that uses FileSystems
as its backing storage.Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_BUFFER_SIZE |
static java.lang.String |
EMBEDDED_ARTIFACT_URN |
static java.lang.String |
FILE_ARTIFACT_URN |
static java.lang.String |
STAGING_TO_ARTIFACT_URN |
static java.lang.String |
URL_ARTIFACT_URN |
Constructor and Description |
---|
ArtifactRetrievalService() |
ArtifactRetrievalService(org.apache.beam.runners.core.construction.ArtifactResolver resolver) |
ArtifactRetrievalService(org.apache.beam.runners.core.construction.ArtifactResolver resolver,
int bufferSize) |
ArtifactRetrievalService(int bufferSize) |
Modifier and Type | Method and Description |
---|---|
void |
close()
.
|
void |
getArtifact(org.apache.beam.model.jobmanagement.v1.ArtifactApi.GetArtifactRequest request,
org.apache.beam.vendor.grpc.v1p48p1.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.GetArtifactResponse> responseObserver) |
static java.io.InputStream |
getArtifact(org.apache.beam.model.pipeline.v1.RunnerApi.ArtifactInformation artifact) |
void |
resolveArtifacts(org.apache.beam.model.jobmanagement.v1.ArtifactApi.ResolveArtifactsRequest request,
org.apache.beam.vendor.grpc.v1p48p1.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.ResolveArtifactsResponse> responseObserver) |
bindService
public static final int DEFAULT_BUFFER_SIZE
public static final java.lang.String FILE_ARTIFACT_URN
public static final java.lang.String URL_ARTIFACT_URN
public static final java.lang.String EMBEDDED_ARTIFACT_URN
public static final java.lang.String STAGING_TO_ARTIFACT_URN
public ArtifactRetrievalService()
public ArtifactRetrievalService(org.apache.beam.runners.core.construction.ArtifactResolver resolver)
public ArtifactRetrievalService(int bufferSize)
public ArtifactRetrievalService(org.apache.beam.runners.core.construction.ArtifactResolver resolver, int bufferSize)
public void resolveArtifacts(org.apache.beam.model.jobmanagement.v1.ArtifactApi.ResolveArtifactsRequest request, org.apache.beam.vendor.grpc.v1p48p1.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.ResolveArtifactsResponse> responseObserver)
resolveArtifacts
in class org.apache.beam.model.jobmanagement.v1.ArtifactRetrievalServiceGrpc.ArtifactRetrievalServiceImplBase
public void getArtifact(org.apache.beam.model.jobmanagement.v1.ArtifactApi.GetArtifactRequest request, org.apache.beam.vendor.grpc.v1p48p1.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.GetArtifactResponse> responseObserver)
getArtifact
in class org.apache.beam.model.jobmanagement.v1.ArtifactRetrievalServiceGrpc.ArtifactRetrievalServiceImplBase
public static java.io.InputStream getArtifact(org.apache.beam.model.pipeline.v1.RunnerApi.ArtifactInformation artifact) throws java.io.IOException
java.io.IOException
public void close()
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.