public class Environments
extends java.lang.Object
environments
.Modifier and Type | Class and Description |
---|---|
static class |
Environments.JavaVersion |
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
ENVIRONMENT_DOCKER |
static java.lang.String |
ENVIRONMENT_EMBEDDED |
static java.lang.String |
ENVIRONMENT_EXTERNAL |
static java.lang.String |
ENVIRONMENT_LOOPBACK |
static java.lang.String |
ENVIRONMENT_PROCESS |
static org.apache.beam.model.pipeline.v1.RunnerApi.Environment |
JAVA_SDK_HARNESS_ENVIRONMENT |
Modifier and Type | Method and Description |
---|---|
static org.apache.beam.model.pipeline.v1.RunnerApi.Environment |
createAnyOfEnvironment(org.apache.beam.model.pipeline.v1.RunnerApi.Environment... environments) |
static org.apache.beam.model.pipeline.v1.RunnerApi.Environment |
createDockerEnvironment(java.lang.String dockerImageUrl) |
static org.apache.beam.model.pipeline.v1.RunnerApi.Environment |
createOrGetDefaultEnvironment(PortablePipelineOptions options) |
static org.apache.beam.model.pipeline.v1.RunnerApi.Environment |
createProcessEnvironment(java.lang.String os,
java.lang.String arch,
java.lang.String command,
java.util.Map<java.lang.String,java.lang.String> env) |
static java.lang.String |
createStagingFileName(java.io.File path,
org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.hash.HashCode hash) |
static java.util.List<org.apache.beam.model.pipeline.v1.RunnerApi.Environment> |
expandAnyOfEnvironments(org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment) |
static java.util.List<org.apache.beam.model.pipeline.v1.RunnerApi.ArtifactInformation> |
getArtifacts(java.util.List<java.lang.String> stagingFiles) |
static java.util.List<org.apache.beam.model.pipeline.v1.RunnerApi.ArtifactInformation> |
getDeferredArtifacts(PipelineOptions options) |
static java.util.Optional<org.apache.beam.model.pipeline.v1.RunnerApi.Environment> |
getEnvironment(org.apache.beam.model.pipeline.v1.RunnerApi.PTransform ptransform,
RehydratedComponents components) |
static java.util.Optional<org.apache.beam.model.pipeline.v1.RunnerApi.Environment> |
getEnvironment(java.lang.String ptransformId,
org.apache.beam.model.pipeline.v1.RunnerApi.Components components) |
static java.lang.String |
getExternalServiceAddress(PortablePipelineOptions options) |
static java.util.Set<java.lang.String> |
getJavaCapabilities() |
static Environments.JavaVersion |
getJavaVersion() |
static org.apache.beam.model.pipeline.v1.RunnerApi.Environment |
resolveAnyOfEnvironment(org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment,
java.lang.String... preferredEnvironmentTypes) |
public static final java.lang.String ENVIRONMENT_DOCKER
public static final java.lang.String ENVIRONMENT_PROCESS
public static final java.lang.String ENVIRONMENT_EXTERNAL
public static final java.lang.String ENVIRONMENT_EMBEDDED
public static final java.lang.String ENVIRONMENT_LOOPBACK
public static final org.apache.beam.model.pipeline.v1.RunnerApi.Environment JAVA_SDK_HARNESS_ENVIRONMENT
public static org.apache.beam.model.pipeline.v1.RunnerApi.Environment createOrGetDefaultEnvironment(PortablePipelineOptions options)
public static org.apache.beam.model.pipeline.v1.RunnerApi.Environment createDockerEnvironment(java.lang.String dockerImageUrl)
public static org.apache.beam.model.pipeline.v1.RunnerApi.Environment createProcessEnvironment(java.lang.String os, java.lang.String arch, java.lang.String command, java.util.Map<java.lang.String,java.lang.String> env)
public static org.apache.beam.model.pipeline.v1.RunnerApi.Environment createAnyOfEnvironment(org.apache.beam.model.pipeline.v1.RunnerApi.Environment... environments)
public static java.util.List<org.apache.beam.model.pipeline.v1.RunnerApi.Environment> expandAnyOfEnvironments(org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment)
public static org.apache.beam.model.pipeline.v1.RunnerApi.Environment resolveAnyOfEnvironment(org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment, java.lang.String... preferredEnvironmentTypes)
public static java.util.Optional<org.apache.beam.model.pipeline.v1.RunnerApi.Environment> getEnvironment(java.lang.String ptransformId, org.apache.beam.model.pipeline.v1.RunnerApi.Components components)
public static java.util.Optional<org.apache.beam.model.pipeline.v1.RunnerApi.Environment> getEnvironment(org.apache.beam.model.pipeline.v1.RunnerApi.PTransform ptransform, RehydratedComponents components)
public static java.util.List<org.apache.beam.model.pipeline.v1.RunnerApi.ArtifactInformation> getArtifacts(java.util.List<java.lang.String> stagingFiles)
public static java.util.List<org.apache.beam.model.pipeline.v1.RunnerApi.ArtifactInformation> getDeferredArtifacts(PipelineOptions options)
public static java.util.Set<java.lang.String> getJavaCapabilities()
public static Environments.JavaVersion getJavaVersion()
public static java.lang.String createStagingFileName(java.io.File path, org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.hash.HashCode hash)
public static java.lang.String getExternalServiceAddress(PortablePipelineOptions options)