org.apache.beam.runners.fnexecution.jobsubmission

Class PortablePipelineJarUtils

java.lang.Object

org.apache.beam.runners.fnexecution.jobsubmission.PortablePipelineJarUtils

public abstract class PortablePipelineJarUtils
extends java.lang.Object

Contains common code for writing and reading portable pipeline jars.

Jar layout:

• META-INF/
  • MANIFEST.MF
• BEAM-PIPELINE/
  • pipeline-manifest.json
  • [1st pipeline (default)]
    • pipeline.json
    • pipeline-options.json
    • artifact-manifest.json
    • artifacts/
      • ...artifact files...
  • [nth pipeline]
    Same as above
• ...Java classes...

Constructor Summary

Constructors

Constructor and Description
PortablePipelineJarUtils()

Method Summary

Modifier and Type	Method and Description
static java.lang.String	getArtifactManifestUri(java.lang.String jobName)
static java.lang.String	getDefaultJobName()
static org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline	getPipelineFromClasspath(java.lang.String jobName)
static org.apache.beam.vendor.grpc.v1p21p0.com.google.protobuf.Struct	getPipelineOptionsFromClasspath(java.lang.String jobName)
static void	writeDefaultJobName(java.util.jar.JarOutputStream outputStream, java.lang.String jobName)

Methods inherited from class java.lang.Object

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

Constructor Detail

PortablePipelineJarUtils

public PortablePipelineJarUtils()

Method Detail

getPipelineFromClasspath

public static org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline getPipelineFromClasspath(java.lang.String jobName)
                                                                                     throws java.io.IOException

Throws:

java.io.IOException

getPipelineOptionsFromClasspath

public static org.apache.beam.vendor.grpc.v1p21p0.com.google.protobuf.Struct getPipelineOptionsFromClasspath(java.lang.String jobName)
                                                                                                      throws java.io.IOException

Throws:

java.io.IOException

getArtifactManifestUri

public static java.lang.String getArtifactManifestUri(java.lang.String jobName)

getDefaultJobName

public static java.lang.String getDefaultJobName()
                                          throws java.io.IOException

Throws:

java.io.IOException

writeDefaultJobName

public static void writeDefaultJobName(java.util.jar.JarOutputStream outputStream,
                                       java.lang.String jobName)
                                throws java.io.IOException

Throws:

java.io.IOException