org.apache.beam.runners.fnexecution.artifact

Interface ArtifactSource

All Known Implementing Classes:

ArtifactSourcePool

public interface ArtifactSource

Makes artifacts available to an ArtifactRetrievalService by encapsulating runner-specific resources.

Method Summary

Modifier and Type	Method and Description
void	getArtifact(java.lang.String name, io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.ArtifactChunk> responseObserver) Get an artifact by its name.
org.apache.beam.model.jobmanagement.v1.ArtifactApi.Manifest	getManifest() Get the artifact manifest available from this source.

Method Detail

getManifest

org.apache.beam.model.jobmanagement.v1.ArtifactApi.Manifest getManifest()
                                                                 throws java.io.IOException

Get the artifact manifest available from this source.

Throws:

java.io.IOException

getArtifact

void getArtifact(java.lang.String name,
                 io.grpc.stub.StreamObserver<org.apache.beam.model.jobmanagement.v1.ArtifactApi.ArtifactChunk> responseObserver)

Get an artifact by its name.