Packages

object flinkRestModel

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. flinkRestModel
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. trait BaseJobStatusCounts extends AnyRef
  2. case class ClusterOverview(slots-total: Int, slots-available: Int) extends Product with Serializable
  3. case class DeployProcessRequest(entryClass: String, savepointPath: Option[String], programArgs: String, parallelism: Int = org.apache.flink.api.common.ExecutionConfig.PARALLELISM_DEFAULT, allowNonRestoredState: Boolean = true, jobId: Option[String]) extends Product with Serializable
  4. case class ExecutionConfig(job-parallelism: Int, user-config: Map[String, Json]) extends Product with Serializable
  5. case class FailureCause(class: Option[String], stack-trace: Option[String], serialized-throwable: Option[String]) extends Product with Serializable
  6. case class GetSavepointStatusResponse(status: SavepointStatus, operation: Option[SavepointOperation]) extends Product with Serializable
  7. case class JarFile(id: String, name: String) extends Product with Serializable
  8. case class JarsResponse(files: Option[List[JarFile]]) extends Product with Serializable
  9. case class JobConfig(jid: String, execution-config: ExecutionConfig) extends Product with Serializable
  10. case class JobDetails(state: String, status-counts: JobStatusCounts) extends Product with Serializable
  11. case class JobOverview(jid: String, name: String, last-modification: Long, start-time: Long, state: String, tasks: JobTasksOverview) extends Product with Serializable
  12. case class JobStatusCounts(CREATED: Int, SCHEDULED: Int, DEPLOYING: Int, RUNNING: Int, FINISHED: Int, CANCELING: Int, CANCELED: Int, FAILED: Int, RECONCILING: Int, INITIALIZING: Option[Int]) extends BaseJobStatusCounts with Product with Serializable
  13. case class JobTasksOverview(total: Int, created: Int, scheduled: Int, deploying: Int, running: Int, finished: Int, canceling: Int, canceled: Int, failed: Int, reconciling: Int, initializing: Option[Int]) extends BaseJobStatusCounts with Product with Serializable
  14. case class JobsResponse(jobs: List[JobOverview]) extends Product with Serializable
  15. case class KeyValueEntry(key: String, value: String) extends Product with Serializable
  16. case class RunResponse(jobid: String) extends Product with Serializable
  17. case class SavepointOperation(location: Option[String], failure-cause: Option[FailureCause]) extends Product with Serializable
  18. case class SavepointStatus(id: String) extends Product with Serializable
  19. case class SavepointTriggerRequest(target-directory: Option[String], cancel-job: Boolean) extends Product with Serializable
  20. case class SavepointTriggerResponse(request-id: String) extends Product with Serializable
  21. case class StopRequest(targetDirectory: Option[String], drain: Boolean) extends Product with Serializable
  22. case class UploadJarResponse(filename: String) extends Product with Serializable

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  8. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  9. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  10. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  11. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  13. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  14. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  15. def toString(): String
    Definition Classes
    AnyRef → Any
  16. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  17. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  18. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  19. object ClusterOverview extends Serializable
  20. object DeployProcessRequest extends Serializable
  21. object ExecutionConfig extends Serializable
  22. object FailureCause extends Serializable
  23. object GetSavepointStatusResponse extends Serializable
  24. object JarFile extends Serializable
  25. object JarsResponse extends Serializable
  26. object JobConfig extends Serializable
  27. object JobDetails extends Serializable
  28. object JobOverview extends Serializable
  29. object JobStatusCounts extends Serializable
  30. object JobTasksOverview extends Serializable
  31. object JobsResponse extends Serializable
  32. object KeyValueEntry extends Serializable
  33. object RunResponse extends Serializable
  34. object SavepointOperation extends Serializable
  35. object SavepointStatus extends Serializable
  36. object SavepointTriggerRequest extends Serializable
  37. object SavepointTriggerResponse extends Serializable
  38. object StopRequest extends Serializable
  39. object UploadJarResponse extends Serializable

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from AnyRef

Inherited from Any

Ungrouped