Uses of Class
com.google.dataflow.v1beta3.FlexTemplateRuntimeEnvironment.Builder
-
Uses of FlexTemplateRuntimeEnvironment.Builder in com.google.dataflow.v1beta3
Methods in com.google.dataflow.v1beta3 that return FlexTemplateRuntimeEnvironment.BuilderModifier and TypeMethodDescriptionFlexTemplateRuntimeEnvironment.Builder.addAdditionalExperiments(String value) Additional experiment flags for the job.FlexTemplateRuntimeEnvironment.Builder.addAdditionalExperimentsBytes(com.google.protobuf.ByteString value) Additional experiment flags for the job.FlexTemplateRuntimeEnvironment.Builder.addAdditionalPipelineOptions(String value) Optional.FlexTemplateRuntimeEnvironment.Builder.addAdditionalPipelineOptionsBytes(com.google.protobuf.ByteString value) Optional.FlexTemplateRuntimeEnvironment.Builder.addAllAdditionalExperiments(Iterable<String> values) Additional experiment flags for the job.FlexTemplateRuntimeEnvironment.Builder.addAllAdditionalPipelineOptions(Iterable<String> values) Optional.FlexTemplateRuntimeEnvironment.Builder.clear()FlexTemplateRuntimeEnvironment.Builder.clearAdditionalExperiments()Additional experiment flags for the job.FlexTemplateRuntimeEnvironment.Builder.clearAdditionalPipelineOptions()Optional.FlexTemplateRuntimeEnvironment.Builder.clearAdditionalUserLabels()FlexTemplateRuntimeEnvironment.Builder.clearAutoscalingAlgorithm()The algorithm to use for autoscalingFlexTemplateRuntimeEnvironment.Builder.clearDiskSizeGb()Worker disk size, in gigabytes.FlexTemplateRuntimeEnvironment.Builder.clearDumpHeapOnOom()If true, when processing time is spent almost entirely on garbage collection (GC), saves a heap dump before ending the thread or process.FlexTemplateRuntimeEnvironment.Builder.clearEnableLauncherVmSerialPortLogging()If true serial port logging will be enabled for the launcher VM.FlexTemplateRuntimeEnvironment.Builder.clearEnableStreamingEngine()Whether to enable Streaming Engine for the job.FlexTemplateRuntimeEnvironment.Builder.clearFlexrsGoal()Set FlexRS goal for the job.FlexTemplateRuntimeEnvironment.Builder.clearIpConfiguration()Configuration for VM IPs.FlexTemplateRuntimeEnvironment.Builder.clearKmsKeyName()Name for the Cloud KMS key for the job.FlexTemplateRuntimeEnvironment.Builder.clearLauncherMachineType()The machine type to use for launching the job.FlexTemplateRuntimeEnvironment.Builder.clearMachineType()The machine type to use for the job.FlexTemplateRuntimeEnvironment.Builder.clearMaxWorkers()The maximum number of Google Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.FlexTemplateRuntimeEnvironment.Builder.clearNetwork()Network to which VMs will be assigned.FlexTemplateRuntimeEnvironment.Builder.clearNumWorkers()The initial number of Google Compute Engine instances for the job.FlexTemplateRuntimeEnvironment.Builder.clearSaveHeapDumpsToGcsPath()Cloud Storage bucket (directory) to upload heap dumps to.FlexTemplateRuntimeEnvironment.Builder.clearSdkContainerImage()Docker registry location of container image to use for the 'worker harness.FlexTemplateRuntimeEnvironment.Builder.clearServiceAccountEmail()The email address of the service account to run the job as.FlexTemplateRuntimeEnvironment.Builder.clearStagingLocation()The Cloud Storage path for staging local files.FlexTemplateRuntimeEnvironment.Builder.clearStreamingMode()Optional.FlexTemplateRuntimeEnvironment.Builder.clearSubnetwork()Subnetwork to which VMs will be assigned, if desired.FlexTemplateRuntimeEnvironment.Builder.clearTempLocation()The Cloud Storage path to use for temporary files.FlexTemplateRuntimeEnvironment.Builder.clearWorkerRegion()The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.FlexTemplateRuntimeEnvironment.Builder.clearWorkerZone()The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.FlexTemplateRuntimeEnvironment.Builder.clearZone()The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline.ContainerSpec.Builder.getDefaultEnvironmentBuilder()Default runtime environment for the job.LaunchFlexTemplateParameter.Builder.getEnvironmentBuilder()The runtime environment for the FlexTemplate jobFlexTemplateRuntimeEnvironment.Builder.mergeFrom(FlexTemplateRuntimeEnvironment other) FlexTemplateRuntimeEnvironment.Builder.mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) FlexTemplateRuntimeEnvironment.Builder.mergeFrom(com.google.protobuf.Message other) FlexTemplateRuntimeEnvironment.newBuilder()FlexTemplateRuntimeEnvironment.newBuilder(FlexTemplateRuntimeEnvironment prototype) FlexTemplateRuntimeEnvironment.newBuilderForType()protected FlexTemplateRuntimeEnvironment.BuilderFlexTemplateRuntimeEnvironment.newBuilderForType(com.google.protobuf.AbstractMessage.BuilderParent parent) FlexTemplateRuntimeEnvironment.Builder.putAdditionalUserLabels(String key, String value) Additional user labels to be specified for the job.FlexTemplateRuntimeEnvironment.Builder.putAllAdditionalUserLabels(Map<String, String> values) Additional user labels to be specified for the job.FlexTemplateRuntimeEnvironment.Builder.removeAdditionalUserLabels(String key) Additional user labels to be specified for the job.FlexTemplateRuntimeEnvironment.Builder.setAdditionalExperiments(int index, String value) Additional experiment flags for the job.FlexTemplateRuntimeEnvironment.Builder.setAdditionalPipelineOptions(int index, String value) Optional.FlexTemplateRuntimeEnvironment.Builder.setAutoscalingAlgorithm(AutoscalingAlgorithm value) The algorithm to use for autoscalingFlexTemplateRuntimeEnvironment.Builder.setAutoscalingAlgorithmValue(int value) The algorithm to use for autoscalingFlexTemplateRuntimeEnvironment.Builder.setDiskSizeGb(int value) Worker disk size, in gigabytes.FlexTemplateRuntimeEnvironment.Builder.setDumpHeapOnOom(boolean value) If true, when processing time is spent almost entirely on garbage collection (GC), saves a heap dump before ending the thread or process.FlexTemplateRuntimeEnvironment.Builder.setEnableLauncherVmSerialPortLogging(boolean value) If true serial port logging will be enabled for the launcher VM.FlexTemplateRuntimeEnvironment.Builder.setEnableStreamingEngine(boolean value) Whether to enable Streaming Engine for the job.FlexTemplateRuntimeEnvironment.Builder.setFlexrsGoal(FlexResourceSchedulingGoal value) Set FlexRS goal for the job.FlexTemplateRuntimeEnvironment.Builder.setFlexrsGoalValue(int value) Set FlexRS goal for the job.FlexTemplateRuntimeEnvironment.Builder.setIpConfiguration(WorkerIPAddressConfiguration value) Configuration for VM IPs.FlexTemplateRuntimeEnvironment.Builder.setIpConfigurationValue(int value) Configuration for VM IPs.FlexTemplateRuntimeEnvironment.Builder.setKmsKeyName(String value) Name for the Cloud KMS key for the job.FlexTemplateRuntimeEnvironment.Builder.setKmsKeyNameBytes(com.google.protobuf.ByteString value) Name for the Cloud KMS key for the job.FlexTemplateRuntimeEnvironment.Builder.setLauncherMachineType(String value) The machine type to use for launching the job.FlexTemplateRuntimeEnvironment.Builder.setLauncherMachineTypeBytes(com.google.protobuf.ByteString value) The machine type to use for launching the job.FlexTemplateRuntimeEnvironment.Builder.setMachineType(String value) The machine type to use for the job.FlexTemplateRuntimeEnvironment.Builder.setMachineTypeBytes(com.google.protobuf.ByteString value) The machine type to use for the job.FlexTemplateRuntimeEnvironment.Builder.setMaxWorkers(int value) The maximum number of Google Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000.FlexTemplateRuntimeEnvironment.Builder.setNetwork(String value) Network to which VMs will be assigned.FlexTemplateRuntimeEnvironment.Builder.setNetworkBytes(com.google.protobuf.ByteString value) Network to which VMs will be assigned.FlexTemplateRuntimeEnvironment.Builder.setNumWorkers(int value) The initial number of Google Compute Engine instances for the job.FlexTemplateRuntimeEnvironment.Builder.setSaveHeapDumpsToGcsPath(String value) Cloud Storage bucket (directory) to upload heap dumps to.FlexTemplateRuntimeEnvironment.Builder.setSaveHeapDumpsToGcsPathBytes(com.google.protobuf.ByteString value) Cloud Storage bucket (directory) to upload heap dumps to.FlexTemplateRuntimeEnvironment.Builder.setSdkContainerImage(String value) Docker registry location of container image to use for the 'worker harness.FlexTemplateRuntimeEnvironment.Builder.setSdkContainerImageBytes(com.google.protobuf.ByteString value) Docker registry location of container image to use for the 'worker harness.FlexTemplateRuntimeEnvironment.Builder.setServiceAccountEmail(String value) The email address of the service account to run the job as.FlexTemplateRuntimeEnvironment.Builder.setServiceAccountEmailBytes(com.google.protobuf.ByteString value) The email address of the service account to run the job as.FlexTemplateRuntimeEnvironment.Builder.setStagingLocation(String value) The Cloud Storage path for staging local files.FlexTemplateRuntimeEnvironment.Builder.setStagingLocationBytes(com.google.protobuf.ByteString value) The Cloud Storage path for staging local files.FlexTemplateRuntimeEnvironment.Builder.setStreamingMode(StreamingMode value) Optional.FlexTemplateRuntimeEnvironment.Builder.setStreamingModeValue(int value) Optional.FlexTemplateRuntimeEnvironment.Builder.setSubnetwork(String value) Subnetwork to which VMs will be assigned, if desired.FlexTemplateRuntimeEnvironment.Builder.setSubnetworkBytes(com.google.protobuf.ByteString value) Subnetwork to which VMs will be assigned, if desired.FlexTemplateRuntimeEnvironment.Builder.setTempLocation(String value) The Cloud Storage path to use for temporary files.FlexTemplateRuntimeEnvironment.Builder.setTempLocationBytes(com.google.protobuf.ByteString value) The Cloud Storage path to use for temporary files.FlexTemplateRuntimeEnvironment.Builder.setWorkerRegion(String value) The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.FlexTemplateRuntimeEnvironment.Builder.setWorkerRegionBytes(com.google.protobuf.ByteString value) The Compute Engine region (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.FlexTemplateRuntimeEnvironment.Builder.setWorkerZone(String value) The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.FlexTemplateRuntimeEnvironment.Builder.setWorkerZoneBytes(com.google.protobuf.ByteString value) The Compute Engine zone (https://cloud.google.com/compute/docs/regions-zones/regions-zones) in which worker processing should occur, e.g.The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline.FlexTemplateRuntimeEnvironment.Builder.setZoneBytes(com.google.protobuf.ByteString value) The Compute Engine [availability zone](https://cloud.google.com/compute/docs/regions-zones/regions-zones) for launching worker instances to run your pipeline.FlexTemplateRuntimeEnvironment.toBuilder()Methods in com.google.dataflow.v1beta3 with parameters of type FlexTemplateRuntimeEnvironment.BuilderModifier and TypeMethodDescriptionContainerSpec.Builder.setDefaultEnvironment(FlexTemplateRuntimeEnvironment.Builder builderForValue) Default runtime environment for the job.LaunchFlexTemplateParameter.Builder.setEnvironment(FlexTemplateRuntimeEnvironment.Builder builderForValue) The runtime environment for the FlexTemplate job