org.apache.beam.runners.fnexecution.artifact

Class ClassLoaderArtifactRetrievalService

java.lang.Object

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

org.apache.beam.runners.fnexecution.artifact.AbstractArtifactRetrievalService

org.apache.beam.runners.fnexecution.artifact.ClassLoaderArtifactRetrievalService

All Implemented Interfaces:

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

public class ClassLoaderArtifactRetrievalService
extends AbstractArtifactRetrievalService

An ArtifactRetrievalService that loads artifacts as ClassLoader resources.

The retrieval token should be a path to a JSON-formatted ProxyManifest accessible via ClassLoader.getResource(String) whose resource locations also point to paths loadable via ClassLoader.getResource(String).

Constructor Summary

Constructors

Constructor and Description
ClassLoaderArtifactRetrievalService()
ClassLoaderArtifactRetrievalService(java.lang.ClassLoader classLoader)

Method Summary

Modifier and Type	Method and Description
java.io.InputStream	openManifest(java.lang.String retrievalToken)
java.io.InputStream	openUri(java.lang.String retrievalToken, java.lang.String uri)

Methods inherited from class org.apache.beam.runners.fnexecution.artifact.AbstractArtifactRetrievalService

close, getArtifact, getManifest, getManifestProxy

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.v1p21p0.io.grpc.BindableService

bindService

Constructor Detail

ClassLoaderArtifactRetrievalService

public ClassLoaderArtifactRetrievalService()

ClassLoaderArtifactRetrievalService

public ClassLoaderArtifactRetrievalService(java.lang.ClassLoader classLoader)

Method Detail

openManifest

public java.io.InputStream openManifest(java.lang.String retrievalToken)
                                 throws java.io.IOException

Specified by:

openManifest in class AbstractArtifactRetrievalService

Throws:

java.io.IOException

openUri

public java.io.InputStream openUri(java.lang.String retrievalToken,
                                   java.lang.String uri)
                            throws java.io.IOException

Specified by:

openUri in class AbstractArtifactRetrievalService

Throws:

java.io.IOException