Package org.apache.beam.runners.fnexecution.artifact

Class ArtifactStagingService.ArtifactDestination

java.lang.Object

org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService.ArtifactDestination

Enclosing class:

ArtifactStagingService

public abstract static class ArtifactStagingService.ArtifactDestination
extends Object

A pairing of a newly created artifact type and an output stream that will be readable at that type.

Constructor Summary

Constructors

Constructor	Description
ArtifactDestination()

Method Summary

Modifier and Type	Method	Description
static ArtifactStagingService.ArtifactDestination	create(String typeUrn, org.apache.beam.vendor.grpc.v1p69p0.com.google.protobuf.ByteString typePayload, OutputStream out)
static ArtifactStagingService.ArtifactDestination	fromFile(String path)
static ArtifactStagingService.ArtifactDestination	fromFile(String path, OutputStream out)
abstract OutputStream	getOutputStream()
abstract org.apache.beam.vendor.grpc.v1p69p0.com.google.protobuf.ByteString	getTypePayload()
abstract String	getTypeUrn()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ArtifactDestination

public ArtifactDestination()

Method Details

create

public static ArtifactStagingService.ArtifactDestination create(String typeUrn,
 org.apache.beam.vendor.grpc.v1p69p0.com.google.protobuf.ByteString typePayload,
 OutputStream out)

fromFile

public static ArtifactStagingService.ArtifactDestination fromFile(String path)
                                                           throws IOException

Throws:

IOException

fromFile

public static ArtifactStagingService.ArtifactDestination fromFile(String path,
 OutputStream out)

getTypeUrn

public abstract String getTypeUrn()

getTypePayload

public abstract org.apache.beam.vendor.grpc.v1p69p0.com.google.protobuf.ByteString getTypePayload()

getOutputStream

public abstract OutputStream getOutputStream()