Package org.apache.beam.runners.jobsubmission

Class PortablePipelineJarUtils

java.lang.Object

org.apache.beam.runners.jobsubmission.PortablePipelineJarUtils

public abstract class PortablePipelineJarUtils
extends 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
    • artifacts/
      • ...artifact files...
  • [nth pipeline]
    Same as above
• ...Java classes...

Constructor Summary

Constructors

Constructor	Description
PortablePipelineJarUtils()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

PortablePipelineJarUtils

public PortablePipelineJarUtils()

Method Details

getPipelineFromClasspath

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

Throws:

IOException

getPipelineOptionsFromClasspath

public static org.apache.beam.vendor.grpc.v1p69p0.com.google.protobuf.Struct getPipelineOptionsFromClasspath(String jobName)
                                                                                                      throws IOException

Throws:

IOException

getDefaultJobName

public static String getDefaultJobName()
                                throws IOException

Throws:

IOException

writeDefaultJobName

public static void writeDefaultJobName(JarOutputStream outputStream,
 String jobName)
                                throws IOException

Throws:

IOException