org.apache.beam.runners.fnexecution.artifact

Interface ArtifactStagingService.ArtifactDestinationProvider

Enclosing class:

ArtifactStagingService

public static interface ArtifactStagingService.ArtifactDestinationProvider

Provides a concrete location to which artifacts can be staged on retrieval.

Method Summary

Modifier and Type	Method and Description
ArtifactStagingService.ArtifactDestination	getDestination(java.lang.String stagingToken, java.lang.String name)
void	removeStagedArtifacts(java.lang.String stagingToken)

Method Detail

getDestination

ArtifactStagingService.ArtifactDestination getDestination(java.lang.String stagingToken,
                                                          java.lang.String name)
                                                   throws java.io.IOException

Throws:

java.io.IOException

removeStagedArtifacts

void removeStagedArtifacts(java.lang.String stagingToken)
                    throws java.io.IOException

Throws:

java.io.IOException