org.apache.beam.runners.fnexecution.artifact

Class ArtifactRetrievalService

java.lang.Object

org.apache.beam.model.jobmanagement.v1.ArtifactRetrievalServiceGrpc.ArtifactRetrievalServiceImplBase

org.apache.beam.runners.fnexecution.artifact.ArtifactRetrievalService

All Implemented Interfaces:

java.lang.AutoCloseable, FnService, org.apache.beam.vendor.grpc.v1p48p1.io.grpc.BindableService

public class ArtifactRetrievalService
extends org.apache.beam.model.jobmanagement.v1.ArtifactRetrievalServiceGrpc.ArtifactRetrievalServiceImplBase
implements FnService

An ArtifactRetrievalService that uses FileSystems as its backing storage.

Field Summary

Fields

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 Summary

Constructors

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)

Method Summary

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)

Methods inherited from class org.apache.beam.model.jobmanagement.v1.ArtifactRetrievalServiceGrpc.ArtifactRetrievalServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.beam.vendor.grpc.v1p48p1.io.grpc.BindableService

bindService

Field Detail

DEFAULT_BUFFER_SIZE

public static final int DEFAULT_BUFFER_SIZE

See Also:

Constant Field Values

FILE_ARTIFACT_URN

public static final java.lang.String FILE_ARTIFACT_URN

See Also:

Constant Field Values

URL_ARTIFACT_URN

public static final java.lang.String URL_ARTIFACT_URN

See Also:

Constant Field Values

EMBEDDED_ARTIFACT_URN

public static final java.lang.String EMBEDDED_ARTIFACT_URN

See Also:

Constant Field Values

STAGING_TO_ARTIFACT_URN

public static final java.lang.String STAGING_TO_ARTIFACT_URN

See Also:

Constant Field Values

Constructor Detail

ArtifactRetrievalService

public ArtifactRetrievalService()

ArtifactRetrievalService

public ArtifactRetrievalService(org.apache.beam.runners.core.construction.ArtifactResolver resolver)

ArtifactRetrievalService

public ArtifactRetrievalService(int bufferSize)

ArtifactRetrievalService

public ArtifactRetrievalService(org.apache.beam.runners.core.construction.ArtifactResolver resolver,
                                int bufferSize)

Method Detail

resolveArtifacts

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)

Overrides:

resolveArtifacts in class org.apache.beam.model.jobmanagement.v1.ArtifactRetrievalServiceGrpc.ArtifactRetrievalServiceImplBase

getArtifact

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)

Overrides:

getArtifact in class org.apache.beam.model.jobmanagement.v1.ArtifactRetrievalServiceGrpc.ArtifactRetrievalServiceImplBase

getArtifact

public static java.io.InputStream getArtifact(org.apache.beam.model.pipeline.v1.RunnerApi.ArtifactInformation artifact)
                                       throws java.io.IOException

Throws:

java.io.IOException

close

public void close()

Description copied from interface: 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.

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface FnService