Class FlinkProfile

java.lang.Object
com.azure.resourcemanager.hdinsight.containers.models.FlinkProfile
All Implemented Interfaces:
com.azure.json.JsonSerializable<FlinkProfile>
public final class FlinkProfile extends Object implements com.azure.json.JsonSerializable<FlinkProfile>
The Flink cluster profile.

  • Constructor Details

    • FlinkProfile

      public FlinkProfile()
      Creates an instance of FlinkProfile class.

  • Method Details

    • storage

      public FlinkStorageProfile storage()
      Get the storage property: The storage profile.
      Returns:
      the storage value.

    • withStorage

      public FlinkProfile withStorage(FlinkStorageProfile storage)
      Set the storage property: The storage profile.
      Parameters:
      storage - the storage value to set.
      Returns:
      the FlinkProfile object itself.

    • numReplicas

      public Integer numReplicas()
      Get the numReplicas property: The number of task managers.
      Returns:
      the numReplicas value.

    • withNumReplicas

      public FlinkProfile withNumReplicas(Integer numReplicas)
      Set the numReplicas property: The number of task managers.
      Parameters:
      numReplicas - the numReplicas value to set.
      Returns:
      the FlinkProfile object itself.

    • jobManager

      public ComputeResourceDefinition jobManager()
      Get the jobManager property: Job Manager container/ process CPU and memory requirements.
      Returns:
      the jobManager value.

    • withJobManager

      public FlinkProfile withJobManager(ComputeResourceDefinition jobManager)
      Set the jobManager property: Job Manager container/ process CPU and memory requirements.
      Parameters:
      jobManager - the jobManager value to set.
      Returns:
      the FlinkProfile object itself.

    • historyServer

      public ComputeResourceDefinition historyServer()
      Get the historyServer property: History Server container/ process CPU and memory requirements.
      Returns:
      the historyServer value.

    • withHistoryServer

      public FlinkProfile withHistoryServer(ComputeResourceDefinition historyServer)
      Set the historyServer property: History Server container/ process CPU and memory requirements.
      Parameters:
      historyServer - the historyServer value to set.
      Returns:
      the FlinkProfile object itself.

    • taskManager

      public ComputeResourceDefinition taskManager()
      Get the taskManager property: Task Manager container/ process CPU and memory requirements.
      Returns:
      the taskManager value.

    • withTaskManager

      public FlinkProfile withTaskManager(ComputeResourceDefinition taskManager)
      Set the taskManager property: Task Manager container/ process CPU and memory requirements.
      Parameters:
      taskManager - the taskManager value to set.
      Returns:
      the FlinkProfile object itself.

    • catalogOptions

      public FlinkCatalogOptions catalogOptions()
      Get the catalogOptions property: Flink cluster catalog options.
      Returns:
      the catalogOptions value.

    • withCatalogOptions

      public FlinkProfile withCatalogOptions(FlinkCatalogOptions catalogOptions)
      Set the catalogOptions property: Flink cluster catalog options.
      Parameters:
      catalogOptions - the catalogOptions value to set.
      Returns:
      the FlinkProfile object itself.

    • deploymentMode

      public DeploymentMode deploymentMode()
      Get the deploymentMode property: A string property that indicates the deployment mode of Flink cluster. It can have one of the following enum values => Application, Session. Default value is Session.
      Returns:
      the deploymentMode value.

    • withDeploymentMode

      public FlinkProfile withDeploymentMode(DeploymentMode deploymentMode)
      Set the deploymentMode property: A string property that indicates the deployment mode of Flink cluster. It can have one of the following enum values => Application, Session. Default value is Session.
      Parameters:
      deploymentMode - the deploymentMode value to set.
      Returns:
      the FlinkProfile object itself.

    • jobSpec

      public FlinkJobProfile jobSpec()
      Get the jobSpec property: Job specifications for flink clusters in application deployment mode. The specification is immutable even if job properties are changed by calling the RunJob API, please use the ListJob API to get the latest job information.
      Returns:
      the jobSpec value.

    • withJobSpec

      public FlinkProfile withJobSpec(FlinkJobProfile jobSpec)
      Set the jobSpec property: Job specifications for flink clusters in application deployment mode. The specification is immutable even if job properties are changed by calling the RunJob API, please use the ListJob API to get the latest job information.
      Parameters:
      jobSpec - the jobSpec value to set.
      Returns:
      the FlinkProfile object itself.

    • validate

      public void validate()
      Validates the instance.
      Throws:
      IllegalArgumentException - thrown if the instance is not valid.

    • toJson

      public com.azure.json.JsonWriter toJson(com.azure.json.JsonWriter jsonWriter) throws IOException
      Specified by:
      toJson in interface com.azure.json.JsonSerializable<FlinkProfile>
      Throws:
      IOException

    • fromJson

      public static FlinkProfile fromJson(com.azure.json.JsonReader jsonReader) throws IOException
      Reads an instance of FlinkProfile from the JsonReader.
      Parameters:
      jsonReader - The JsonReader being read.
      Returns:
      An instance of FlinkProfile if the JsonReader was pointing to an instance of it, or null if it was pointing to JSON null.
      Throws:
      IllegalStateException - If the deserialized JSON object was missing any required properties.
      IOException - If an error occurs while reading the FlinkProfile.