org.apache.beam.runners.fnexecution.artifact

Class JavaFilesystemLegacyArtifactStagingService

java.lang.Object

org.apache.beam.model.jobmanagement.v1.LegacyArtifactStagingServiceGrpc.LegacyArtifactStagingServiceImplBase

org.apache.beam.runners.fnexecution.artifact.AbstractLegacyArtifactStagingService

org.apache.beam.runners.fnexecution.artifact.JavaFilesystemLegacyArtifactStagingService

All Implemented Interfaces:

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

public class JavaFilesystemLegacyArtifactStagingService
extends AbstractLegacyArtifactStagingService

An LegacyArtifactStagingServiceGrpc.LegacyArtifactStagingServiceImplBase 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.AbstractLegacyArtifactStagingService

NO_ARTIFACTS_STAGED_TOKEN

Constructor Summary

Constructors

Constructor and Description
JavaFilesystemLegacyArtifactStagingService(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.AbstractLegacyArtifactStagingService

close, commitManifest, putArtifact

Methods inherited from class org.apache.beam.model.jobmanagement.v1.LegacyArtifactStagingServiceGrpc.LegacyArtifactStagingServiceImplBase

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.v1p26p0.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

JavaFilesystemLegacyArtifactStagingService

public JavaFilesystemLegacyArtifactStagingService(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 AbstractLegacyArtifactStagingService

Throws:

java.lang.Exception

openUri

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

Specified by:

openUri in class AbstractLegacyArtifactStagingService

Throws:

java.io.IOException

removeUri

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

Specified by:

removeUri in class AbstractLegacyArtifactStagingService

Throws:

java.io.IOException

openManifest

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

Specified by:

openManifest in class AbstractLegacyArtifactStagingService

Throws:

java.lang.Exception

removeArtifacts

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

Specified by:

removeArtifacts in class AbstractLegacyArtifactStagingService

Throws:

java.lang.Exception

getRetrievalToken

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

Specified by:

getRetrievalToken in class AbstractLegacyArtifactStagingService

Throws:

java.lang.Exception