class FlinkRestManager extends FlinkDeploymentManager with LazyLogging
Linear Supertypes
Known Subclasses
Ordering
- Alphabetic
- By Inheritance
Inherited
- FlinkRestManager
- FlinkDeploymentManager
- LazyLogging
- DeploymentManager
- AutoCloseable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
- new FlinkRestManager(config: FlinkConfig, modelData: BaseModelData, mainClassName: String)(implicit ec: ExecutionContext, backend: SttpBackend[Future, Nothing, NothingT])
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
cancel(deploymentId: ExternalDeploymentId): Future[Unit]
- Attributes
- protected
- Definition Classes
- FlinkRestManager → FlinkDeploymentManager
-
def
cancel(processName: ProcessName, user: User): Future[Unit]
- Definition Classes
- FlinkRestManager → DeploymentManager
-
def
checkDuringDeployForNotRunningJob(s: JobStatus): Boolean
- Attributes
- protected
-
def
checkRequiredSlotsExceedAvailableSlots(canonicalProcess: CanonicalProcess, currentlyDeployedJobId: Option[ExternalDeploymentId]): Future[Unit]
- Attributes
- protected
- Definition Classes
- FlinkRestManager → FlinkDeploymentManager
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native() @HotSpotIntrinsicCandidate()
-
def
close(): Unit
- Definition Classes
- FlinkRestManager → AutoCloseable
-
def
customActions: List[CustomAction]
- Definition Classes
- FlinkDeploymentManager → DeploymentManager
-
def
deploy(processVersion: ProcessVersion, deploymentData: DeploymentData, canonicalProcess: CanonicalProcess, savepointPath: Option[String]): Future[Option[ExternalDeploymentId]]
- Definition Classes
- FlinkDeploymentManager → DeploymentManager
-
def
ensureTasksRunning(overview: JobOverview): Boolean
- Attributes
- protected
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
findJobStatus(name: ProcessName): Future[Option[ProcessState]]
- Definition Classes
- FlinkRestManager → DeploymentManager
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
invokeCustomAction(actionRequest: CustomActionRequest, canonicalProcess: CanonicalProcess): Future[Either[CustomActionError, CustomActionResult]]
- Definition Classes
- FlinkDeploymentManager → DeploymentManager
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
isNotFinished(overview: JobOverview): Boolean
- Attributes
- protected
-
lazy val
jarFile: File
- Attributes
- protected
-
lazy val
logger: Logger
- Attributes
- protected
- Definition Classes
- LazyLogging
- Annotations
- @transient()
-
def
makeSavepoint(deploymentId: ExternalDeploymentId, savepointDir: Option[String]): Future[SavepointResult]
- Attributes
- protected
- Definition Classes
- FlinkRestManager → FlinkDeploymentManager
-
def
mapJobStatus(overview: JobOverview): StateStatus
- Attributes
- protected
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
processStateDefinitionManager: ProcessStateDefinitionManager
- Definition Classes
- FlinkDeploymentManager → DeploymentManager
-
def
runProgram(processName: ProcessName, mainClass: String, args: List[String], savepointPath: Option[String]): Future[Option[ExternalDeploymentId]]
- Attributes
- protected
- Definition Classes
- FlinkRestManager → FlinkDeploymentManager
-
def
savepoint(processName: ProcessName, savepointDir: Option[String]): Future[SavepointResult]
- Definition Classes
- FlinkDeploymentManager → DeploymentManager
-
def
stop(deploymentId: ExternalDeploymentId, savepointDir: Option[String]): Future[SavepointResult]
- Attributes
- protected
- Definition Classes
- FlinkRestManager → FlinkDeploymentManager
-
def
stop(processName: ProcessName, savepointDir: Option[String], user: User): Future[SavepointResult]
- Definition Classes
- FlinkDeploymentManager → DeploymentManager
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
test[T](processName: ProcessName, canonicalProcess: CanonicalProcess, testData: TestData, variableEncoder: (Any) ⇒ T): Future[TestResults[T]]
- Definition Classes
- FlinkDeploymentManager → DeploymentManager
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
def
validate(processVersion: ProcessVersion, deploymentData: DeploymentData, canonicalProcess: CanonicalProcess): Future[Unit]
- Definition Classes
- FlinkDeploymentManager → DeploymentManager
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
Deprecated Value Members
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] ) @Deprecated @deprecated
- Deprecated
(Since version ) see corresponding Javadoc for more information.