Package 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:
AutoCloseable, org.apache.beam.model.jobmanagement.v1.ArtifactRetrievalServiceGrpc.AsyncService, FnService, org.apache.beam.vendor.grpc.v1p69p0.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
    Description
    static final int
    DEFAULT_BUFFER_SIZE
     
    static final String
    EMBEDDED_ARTIFACT_URN
     
    static final String
    FILE_ARTIFACT_URN
     
    static final String
    STAGING_TO_ARTIFACT_URN
     
    static final String
    URL_ARTIFACT_URN
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    ArtifactRetrievalService()
     
    ArtifactRetrievalService(int bufferSize)
     
    ArtifactRetrievalService(org.apache.beam.sdk.util.construction.ArtifactResolver resolver)
     
    ArtifactRetrievalService(org.apache.beam.sdk.util.construction.ArtifactResolver resolver, int bufferSize)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
    .
    void
    getArtifact(org.apache.beam.model.jobmanagement.v1.ArtifactApi.GetArtifactRequest request, org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.GetArtifactResponse> responseObserver)
     
    static 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.v1p69p0.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.v1p69p0.io.grpc.BindableService

    bindService

  • Field Details

  • Constructor Details

    • ArtifactRetrievalService

      public ArtifactRetrievalService()

    • ArtifactRetrievalService

      public ArtifactRetrievalService(org.apache.beam.sdk.util.construction.ArtifactResolver resolver)

    • ArtifactRetrievalService

      public ArtifactRetrievalService(int bufferSize)

    • ArtifactRetrievalService

      public ArtifactRetrievalService(org.apache.beam.sdk.util.construction.ArtifactResolver resolver, int bufferSize)

  • Method Details

    • resolveArtifacts

      public void resolveArtifacts(org.apache.beam.model.jobmanagement.v1.ArtifactApi.ResolveArtifactsRequest request, org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.ResolveArtifactsResponse> responseObserver)
      Specified by:
      resolveArtifacts in interface org.apache.beam.model.jobmanagement.v1.ArtifactRetrievalServiceGrpc.AsyncService

    • getArtifact

      public void getArtifact(org.apache.beam.model.jobmanagement.v1.ArtifactApi.GetArtifactRequest request, org.apache.beam.vendor.grpc.v1p69p0.io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.GetArtifactResponse> responseObserver)
      Specified by:
      getArtifact in interface org.apache.beam.model.jobmanagement.v1.ArtifactRetrievalServiceGrpc.AsyncService

    • getArtifact

      public static InputStream getArtifact(org.apache.beam.model.pipeline.v1.RunnerApi.ArtifactInformation artifact) throws IOException
      Throws:
      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 AutoCloseable
      Specified by:
      close in interface FnService