public class BeamFileSystemLegacyArtifactStagingService extends AbstractLegacyArtifactStagingService
LegacyArtifactStagingServiceGrpc.LegacyArtifactStagingServiceImplBase
based on beam file system. BeamFileSystemLegacyArtifactStagingService
requires BeamFileSystemLegacyArtifactStagingService.StagingSessionToken
in every me
call. The manifest is put in BeamFileSystemLegacyArtifactStagingService.StagingSessionToken.getBasePath()
/BeamFileSystemLegacyArtifactStagingService.StagingSessionToken.getSessionId()
and artifacts are put in BeamFileSystemLegacyArtifactStagingService.StagingSessionToken.getBasePath()
/BeamFileSystemLegacyArtifactStagingService.StagingSessionToken.getSessionId()
/ARTIFACTS
.
The returned token is the path to the manifest file.
The manifest file is encoded in ArtifactApi.ProxyManifest
.
Modifier and Type | Class and Description |
---|---|
protected static class |
BeamFileSystemLegacyArtifactStagingService.StagingSessionToken
Serializable StagingSessionToken used to stage files with
BeamFileSystemLegacyArtifactStagingService . |
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
ARTIFACTS |
static java.lang.String |
MANIFEST |
NO_ARTIFACTS_STAGED_TOKEN
Constructor and Description |
---|
BeamFileSystemLegacyArtifactStagingService() |
Modifier and Type | Method and Description |
---|---|
static java.lang.String |
generateStagingSessionToken(java.lang.String sessionId,
java.lang.String basePath)
Generate a stagingSessionToken compatible with
BeamFileSystemLegacyArtifactStagingService . |
java.lang.String |
getArtifactUri(java.lang.String stagingSession,
java.lang.String encodedFileName) |
java.lang.String |
getRetrievalToken(java.lang.String stagingSession) |
java.nio.channels.WritableByteChannel |
openManifest(java.lang.String stagingSession) |
java.nio.channels.WritableByteChannel |
openUri(java.lang.String uri) |
void |
removeArtifacts(java.lang.String stagingSessionToken) |
void |
removeUri(java.lang.String uri) |
close, commitManifest, putArtifact
bindService
public static final java.lang.String MANIFEST
public static final java.lang.String ARTIFACTS
public BeamFileSystemLegacyArtifactStagingService()
public java.lang.String getArtifactUri(java.lang.String stagingSession, java.lang.String encodedFileName) throws java.lang.Exception
getArtifactUri
in class AbstractLegacyArtifactStagingService
java.lang.Exception
public java.nio.channels.WritableByteChannel openUri(java.lang.String uri) throws java.io.IOException
openUri
in class AbstractLegacyArtifactStagingService
java.io.IOException
public void removeUri(java.lang.String uri) throws java.io.IOException
removeUri
in class AbstractLegacyArtifactStagingService
java.io.IOException
public void removeArtifacts(java.lang.String stagingSessionToken) throws java.lang.Exception
removeArtifacts
in class AbstractLegacyArtifactStagingService
java.lang.Exception
public java.nio.channels.WritableByteChannel openManifest(java.lang.String stagingSession) throws java.lang.Exception
openManifest
in class AbstractLegacyArtifactStagingService
java.lang.Exception
public java.lang.String getRetrievalToken(java.lang.String stagingSession) throws java.lang.Exception
getRetrievalToken
in class AbstractLegacyArtifactStagingService
java.lang.Exception
public static java.lang.String generateStagingSessionToken(java.lang.String sessionId, java.lang.String basePath)
BeamFileSystemLegacyArtifactStagingService
.sessionId
- Unique sessionId for artifact staging.basePath
- Base path to upload artifacts.