org.apache.beam.sdk.util.construction

Class PipelineOptionsTranslation

java.lang.Object

org.apache.beam.sdk.util.construction.PipelineOptionsTranslation

public class PipelineOptionsTranslation
extends java.lang.Object

Utilities for going to/from Runner API pipeline options.

TODO: Make this the default to/from translation for PipelineOptions.

Constructor Summary

Constructors

Constructor and Description
PipelineOptionsTranslation()

Method Summary

Modifier and Type	Method and Description
static PipelineOptions	fromJson(java.lang.String optionsJson) Converts the provided JsonString into PipelineOptions.
static PipelineOptions	fromProto(org.apache.beam.vendor.grpc.v1p60p1.com.google.protobuf.Struct protoOptions) Converts the provided Struct into PipelineOptions.
static java.lang.String	toJson(PipelineOptions options) Converts the provided PipelineOptions into JsonString.
static org.apache.beam.vendor.grpc.v1p60p1.com.google.protobuf.Struct	toProto(PipelineOptions options) Converts the provided PipelineOptions to a Struct.

Methods inherited from class java.lang.Object

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

Constructor Detail

PipelineOptionsTranslation

public PipelineOptionsTranslation()

Method Detail

toProto

public static org.apache.beam.vendor.grpc.v1p60p1.com.google.protobuf.Struct toProto(PipelineOptions options)

Converts the provided PipelineOptions to a Struct.

fromProto

public static PipelineOptions fromProto(org.apache.beam.vendor.grpc.v1p60p1.com.google.protobuf.Struct protoOptions)

Converts the provided Struct into PipelineOptions.

fromJson

public static PipelineOptions fromJson(java.lang.String optionsJson)

Converts the provided JsonString into PipelineOptions.

toJson

public static java.lang.String toJson(PipelineOptions options)

Converts the provided PipelineOptions into JsonString.