Package org.apache.beam.runners.dataflow

Class DataflowRunnerInfo

java.lang.Object

org.apache.beam.sdk.util.ReleaseInfo

org.apache.beam.runners.dataflow.DataflowRunnerInfo

All Implemented Interfaces:

Serializable

public final class DataflowRunnerInfo
extends org.apache.beam.sdk.util.ReleaseInfo

Populates versioning and other information for DataflowRunner.

See Also:

• Serialized Form

Method Summary

Modifier and Type	Method	Description
String	getContainerImageBaseRepository()	Provides the version/tag for constructing the container image path.
static DataflowRunnerInfo	getDataflowRunnerInfo()	Returns an instance of DataflowRunnerInfo.
String	getFnApiDevContainerVersion()	Provides the version/tag for dev SDK FnAPI container image.
String	getFnApiEnvironmentMajorVersion()	Provides the FnAPI environment's major version number.
String	getLegacyDevContainerVersion()	Provides the version/tag for legacy SDK FnAPI container image.
String	getLegacyEnvironmentMajorVersion()	Provides the legacy environment's major version number.
Map<String,String>	getProperties()

Methods inherited from class org.apache.beam.sdk.util.ReleaseInfo

getDefaultDockerRepoPrefix, getDefaultDockerRepoRoot, getName, getReleaseInfo, getSdkVersion, getVersion, isDevSdkVersion

Methods inherited from class java.lang.Object

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

Method Details

getDataflowRunnerInfo

public static DataflowRunnerInfo getDataflowRunnerInfo()

Returns an instance of DataflowRunnerInfo.

getLegacyEnvironmentMajorVersion

public String getLegacyEnvironmentMajorVersion()

Provides the legacy environment's major version number.

getFnApiEnvironmentMajorVersion

public String getFnApiEnvironmentMajorVersion()

Provides the FnAPI environment's major version number.

getFnApiDevContainerVersion

public String getFnApiDevContainerVersion()

Provides the version/tag for dev SDK FnAPI container image.

getLegacyDevContainerVersion

public String getLegacyDevContainerVersion()

Provides the version/tag for legacy SDK FnAPI container image.

getContainerImageBaseRepository

public String getContainerImageBaseRepository()

Provides the version/tag for constructing the container image path.

getProperties

public Map<String,String> getProperties()

Specified by:

getProperties in class org.apache.beam.sdk.util.ReleaseInfo