org.apache.beam.runners.fnexecution.artifact

Class JavaFilesystemArtifactStagingService

java.lang.Object

org.apache.beam.model.jobmanagement.v1.ArtifactStagingServiceGrpc.ArtifactStagingServiceImplBase

org.apache.beam.runners.fnexecution.artifact.AbstractArtifactStagingService

org.apache.beam.runners.fnexecution.artifact.JavaFilesystemArtifactStagingService

All Implemented Interfaces:

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

public class JavaFilesystemArtifactStagingService
extends AbstractArtifactStagingService

An ArtifactStagingServiceGrpc.ArtifactStagingServiceImplBase that loads artifacts into a Java FileSystem.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	ARTIFACTS
static java.lang.String	MANIFEST

Fields inherited from class org.apache.beam.runners.fnexecution.artifact.AbstractArtifactStagingService

NO_ARTIFACTS_STAGED_TOKEN

Constructor Summary

Constructors

Constructor and Description
JavaFilesystemArtifactStagingService(java.nio.file.FileSystem fileSystem, java.lang.String artifactRootDir)

Method Summary

Modifier and Type	Method and Description
java.lang.String	getArtifactUri(java.lang.String stagingSessionToken, java.lang.String encodedFileName)
java.lang.String	getRetrievalToken(java.lang.String stagingSessionToken)
java.nio.channels.WritableByteChannel	openManifest(java.lang.String stagingSessionToken)
java.nio.channels.WritableByteChannel	openUri(java.lang.String uri)
void	removeArtifacts(java.lang.String stagingSessionToken)
void	removeUri(java.lang.String uri)

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

close, commitManifest, putArtifact

Methods inherited from class org.apache.beam.model.jobmanagement.v1.ArtifactStagingServiceGrpc.ArtifactStagingServiceImplBase

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

Field Detail

MANIFEST

public static final java.lang.String MANIFEST

See Also:

Constant Field Values

ARTIFACTS

public static final java.lang.String ARTIFACTS

See Also:

Constant Field Values

Constructor Detail

JavaFilesystemArtifactStagingService

public JavaFilesystemArtifactStagingService(java.nio.file.FileSystem fileSystem,
                                            java.lang.String artifactRootDir)

Method Detail

getArtifactUri

public java.lang.String getArtifactUri(java.lang.String stagingSessionToken,
                                       java.lang.String encodedFileName)
                                throws java.lang.Exception

Specified by:

getArtifactUri in class AbstractArtifactStagingService

Throws:

java.lang.Exception

openUri

public java.nio.channels.WritableByteChannel openUri(java.lang.String uri)
                                              throws java.io.IOException

Specified by:

openUri in class AbstractArtifactStagingService

Throws:

java.io.IOException

removeUri

public void removeUri(java.lang.String uri)
               throws java.io.IOException

Specified by:

removeUri in class AbstractArtifactStagingService

Throws:

java.io.IOException

openManifest

public java.nio.channels.WritableByteChannel openManifest(java.lang.String stagingSessionToken)
                                                   throws java.lang.Exception

Specified by:

openManifest in class AbstractArtifactStagingService

Throws:

java.lang.Exception

removeArtifacts

public void removeArtifacts(java.lang.String stagingSessionToken)
                     throws java.lang.Exception

Specified by:

removeArtifacts in class AbstractArtifactStagingService

Throws:

java.lang.Exception

getRetrievalToken

public java.lang.String getRetrievalToken(java.lang.String stagingSessionToken)
                                   throws java.lang.Exception

Specified by:

getRetrievalToken in class AbstractArtifactStagingService

Throws:

java.lang.Exception