Package com.google.dataflow.v1beta3

Interface LaunchFlexTemplateParameterOrBuilder

    • Method Detail

      • getJobName

        String getJobName()
         Required. The job name to use for the created job. For update job request,
 job name should be same as the existing running job.
        string job_name = 1;
        Returns:
        The jobName.

      • getJobNameBytes

        com.google.protobuf.ByteString getJobNameBytes()
         Required. The job name to use for the created job. For update job request,
 job name should be same as the existing running job.
        string job_name = 1;
        Returns:
        The bytes for jobName.

      • hasContainerSpec

        boolean hasContainerSpec()
         Spec about the container image to launch.
        .google.dataflow.v1beta3.ContainerSpec container_spec = 4;
        Returns:
        Whether the containerSpec field is set.

      • getContainerSpec

        ContainerSpec getContainerSpec()
         Spec about the container image to launch.
        .google.dataflow.v1beta3.ContainerSpec container_spec = 4;
        Returns:
        The containerSpec.

      • getContainerSpecOrBuilder

        ContainerSpecOrBuilder getContainerSpecOrBuilder()
         Spec about the container image to launch.
        .google.dataflow.v1beta3.ContainerSpec container_spec = 4;

      • hasContainerSpecGcsPath

        boolean hasContainerSpecGcsPath()
         Cloud Storage path to a file with json serialized ContainerSpec as
 content.
        string container_spec_gcs_path = 5;
        Returns:
        Whether the containerSpecGcsPath field is set.

      • getContainerSpecGcsPath

        String getContainerSpecGcsPath()
         Cloud Storage path to a file with json serialized ContainerSpec as
 content.
        string container_spec_gcs_path = 5;
        Returns:
        The containerSpecGcsPath.

      • getContainerSpecGcsPathBytes

        com.google.protobuf.ByteString getContainerSpecGcsPathBytes()
         Cloud Storage path to a file with json serialized ContainerSpec as
 content.
        string container_spec_gcs_path = 5;
        Returns:
        The bytes for containerSpecGcsPath.

      • getParametersCount

        int getParametersCount()
         The parameters for FlexTemplate.
 Ex. {"num_workers":"5"}
        map<string, string> parameters = 2;

      • containsParameters

        boolean containsParameters​(String key)
         The parameters for FlexTemplate.
 Ex. {"num_workers":"5"}
        map<string, string> parameters = 2;

      • getParametersMap

        Map<String,​String> getParametersMap()
         The parameters for FlexTemplate.
 Ex. {"num_workers":"5"}
        map<string, string> parameters = 2;

      • getParametersOrDefault

        String getParametersOrDefault​(String key,
                              String defaultValue)
         The parameters for FlexTemplate.
 Ex. {"num_workers":"5"}
        map<string, string> parameters = 2;

      • getParametersOrThrow

        String getParametersOrThrow​(String key)
         The parameters for FlexTemplate.
 Ex. {"num_workers":"5"}
        map<string, string> parameters = 2;

      • getLaunchOptionsCount

        int getLaunchOptionsCount()
         Launch options for this flex template job. This is a common set of options
 across languages and templates. This should not be used to pass job
 parameters.
        map<string, string> launch_options = 6;

      • containsLaunchOptions

        boolean containsLaunchOptions​(String key)
         Launch options for this flex template job. This is a common set of options
 across languages and templates. This should not be used to pass job
 parameters.
        map<string, string> launch_options = 6;

      • getLaunchOptionsMap

        Map<String,​String> getLaunchOptionsMap()
         Launch options for this flex template job. This is a common set of options
 across languages and templates. This should not be used to pass job
 parameters.
        map<string, string> launch_options = 6;

      • getLaunchOptionsOrDefault

        String getLaunchOptionsOrDefault​(String key,
                                 String defaultValue)
         Launch options for this flex template job. This is a common set of options
 across languages and templates. This should not be used to pass job
 parameters.
        map<string, string> launch_options = 6;

      • getLaunchOptionsOrThrow

        String getLaunchOptionsOrThrow​(String key)
         Launch options for this flex template job. This is a common set of options
 across languages and templates. This should not be used to pass job
 parameters.
        map<string, string> launch_options = 6;

      • hasEnvironment

        boolean hasEnvironment()
         The runtime environment for the FlexTemplate job
        .google.dataflow.v1beta3.FlexTemplateRuntimeEnvironment environment = 7;
        Returns:
        Whether the environment field is set.

      • getEnvironment

        FlexTemplateRuntimeEnvironment getEnvironment()
         The runtime environment for the FlexTemplate job
        .google.dataflow.v1beta3.FlexTemplateRuntimeEnvironment environment = 7;
        Returns:
        The environment.

      • getEnvironmentOrBuilder

        FlexTemplateRuntimeEnvironmentOrBuilder getEnvironmentOrBuilder()
         The runtime environment for the FlexTemplate job
        .google.dataflow.v1beta3.FlexTemplateRuntimeEnvironment environment = 7;

      • getUpdate

        boolean getUpdate()
         Set this to true if you are sending a request to update a running
 streaming job. When set, the job name should be the same as the
 running job.
        bool update = 8;
        Returns:
        The update.

      • getTransformNameMappingsCount

        int getTransformNameMappingsCount()
         Use this to pass transform_name_mappings for streaming update jobs.
 Ex:{"oldTransformName":"newTransformName",...}'
        map<string, string> transform_name_mappings = 9;

      • containsTransformNameMappings

        boolean containsTransformNameMappings​(String key)
         Use this to pass transform_name_mappings for streaming update jobs.
 Ex:{"oldTransformName":"newTransformName",...}'
        map<string, string> transform_name_mappings = 9;

      • getTransformNameMappingsMap

        Map<String,​String> getTransformNameMappingsMap()
         Use this to pass transform_name_mappings for streaming update jobs.
 Ex:{"oldTransformName":"newTransformName",...}'
        map<string, string> transform_name_mappings = 9;

      • getTransformNameMappingsOrDefault

        String getTransformNameMappingsOrDefault​(String key,
                                         String defaultValue)
         Use this to pass transform_name_mappings for streaming update jobs.
 Ex:{"oldTransformName":"newTransformName",...}'
        map<string, string> transform_name_mappings = 9;

      • getTransformNameMappingsOrThrow

        String getTransformNameMappingsOrThrow​(String key)
         Use this to pass transform_name_mappings for streaming update jobs.
 Ex:{"oldTransformName":"newTransformName",...}'
        map<string, string> transform_name_mappings = 9;