object flinkRestModel
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- flinkRestModel
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Type Members
- trait BaseJobStatusCounts extends AnyRef
- case class ClusterOverview(slots-total: Int, slots-available: Int) extends Product with Serializable
- 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
- case class ExecutionConfig(job-parallelism: Int, user-config: Map[String, Json]) extends Product with Serializable
- case class FailureCause(class: Option[String], stack-trace: Option[String], serialized-throwable: Option[String]) extends Product with Serializable
- case class GetSavepointStatusResponse(status: SavepointStatus, operation: Option[SavepointOperation]) extends Product with Serializable
- case class JarFile(id: String, name: String) extends Product with Serializable
- case class JarsResponse(files: Option[List[JarFile]]) extends Product with Serializable
- case class JobConfig(jid: String, execution-config: ExecutionConfig) extends Product with Serializable
- case class JobDetails(state: String, status-counts: JobStatusCounts) extends Product with Serializable
- case class JobOverview(jid: String, name: String, last-modification: Long, start-time: Long, state: String, tasks: JobTasksOverview) extends Product with Serializable
- 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
- 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
- case class JobsResponse(jobs: List[JobOverview]) extends Product with Serializable
- case class KeyValueEntry(key: String, value: String) extends Product with Serializable
- case class RunResponse(jobid: String) extends Product with Serializable
- case class SavepointOperation(location: Option[String], failure-cause: Option[FailureCause]) extends Product with Serializable
- case class SavepointStatus(id: String) extends Product with Serializable
- case class SavepointTriggerRequest(target-directory: Option[String], cancel-job: Boolean) extends Product with Serializable
- case class SavepointTriggerResponse(request-id: String) extends Product with Serializable
- case class StopRequest(targetDirectory: Option[String], drain: Boolean) extends Product with Serializable
- case class UploadJarResponse(filename: String) extends Product with Serializable
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- object ClusterOverview extends Serializable
- object DeployProcessRequest extends Serializable
- object ExecutionConfig extends Serializable
- object FailureCause extends Serializable
- object GetSavepointStatusResponse extends Serializable
- object JarFile extends Serializable
- object JarsResponse extends Serializable
- object JobConfig extends Serializable
- object JobDetails extends Serializable
- object JobOverview extends Serializable
- object JobStatusCounts extends Serializable
- object JobTasksOverview extends Serializable
- object JobsResponse extends Serializable
- object KeyValueEntry extends Serializable
- object RunResponse extends Serializable
- object SavepointOperation extends Serializable
- object SavepointStatus extends Serializable
- object SavepointTriggerRequest extends Serializable
- object SavepointTriggerResponse extends Serializable
- object StopRequest extends Serializable
- object UploadJarResponse extends Serializable
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)