c
pl.touk.nussknacker.engine.management
FlinkDeploymentManager
Companion object FlinkDeploymentManager
abstract class FlinkDeploymentManager extends DeploymentManager with LazyLogging
Linear Supertypes
Known Subclasses
Ordering
- Alphabetic
- By Inheritance
Inherited
- FlinkDeploymentManager
- LazyLogging
- DeploymentManager
- AutoCloseable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
- new FlinkDeploymentManager(modelData: BaseModelData, dependencies: DeploymentManagerDependencies, shouldVerifyBeforeDeploy: Boolean, mainClassName: String)
Abstract Value Members
-
abstract
def
cancelDeployment(command: DMCancelDeploymentCommand): Future[Unit]
- Attributes
- protected
-
abstract
def
cancelFlinkJob(deploymentId: ExternalDeploymentId): Future[Unit]
- Attributes
- protected
-
abstract
def
cancelScenario(command: DMCancelScenarioCommand): Future[Unit]
- Attributes
- protected
-
abstract
def
checkRequiredSlotsExceedAvailableSlots(canonicalProcess: CanonicalProcess, currentlyDeployedJobsIds: List[ExternalDeploymentId]): Future[Unit]
- Attributes
- protected
-
abstract
def
close(): Unit
- Definition Classes
- AutoCloseable
- Annotations
- @throws( classOf[java.lang.Exception] )
-
abstract
def
deploymentSynchronisationSupport: DeploymentSynchronisationSupport
- Definition Classes
- DeploymentManager
-
abstract
def
getProcessStates(name: ProcessName)(implicit freshnessPolicy: DataFreshnessPolicy): Future[WithDataFreshnessStatus[List[StatusDetails]]]
- Definition Classes
- DeploymentManager
-
abstract
def
makeSavepoint(deploymentId: ExternalDeploymentId, savepointDir: Option[String]): Future[SavepointResult]
- Attributes
- protected
-
abstract
def
runProgram(processName: ProcessName, mainClass: String, args: List[String], savepointPath: Option[String], deploymentId: Option[DeploymentId]): Future[Option[ExternalDeploymentId]]
- Attributes
- protected
-
abstract
def
stop(deploymentId: ExternalDeploymentId, savepointDir: Option[String]): Future[SavepointResult]
- Attributes
- protected
-
abstract
def
waitForDuringDeployFinished(processName: ProcessName, deploymentId: ExternalDeploymentId): Future[Unit]
- Attributes
- protected
Concrete 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( ... ) @native() @HotSpotIntrinsicCandidate()
-
def
customActionsDefinitions: List[CustomActionDefinition]
- Definition Classes
- FlinkDeploymentManager → DeploymentManager
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
getProcessState(idWithName: ProcessIdWithName, lastStateAction: Option[ProcessAction])(implicit freshnessPolicy: DataFreshnessPolicy): Future[WithDataFreshnessStatus[ProcessState]]
- Definition Classes
- DeploymentManager
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
lazy val
logger: Logger
- Attributes
- protected
- Definition Classes
- LazyLogging
- Annotations
- @transient()
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notImplemented: Future[Nothing]
- Attributes
- protected
- Definition Classes
- DeploymentManager
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
processCommand[Result](command: DMScenarioCommand[Result]): Future[Result]
- Definition Classes
- FlinkDeploymentManager → DeploymentManager
-
def
processCustomAction(command: DMCustomActionCommand): Future[CustomActionResult]
- Attributes
- protected
-
def
processStateDefinitionManager: ProcessStateDefinitionManager
- Definition Classes
- FlinkDeploymentManager → DeploymentManager
-
def
resolve(idWithName: ProcessIdWithName, statusDetails: List[StatusDetails], lastStateAction: Option[ProcessAction]): Future[ProcessState]
Gets status from engine, handles finished state, resolves possible inconsistency with lastAction and formats status using
ProcessStateDefinitionManager
Gets status from engine, handles finished state, resolves possible inconsistency with lastAction and formats status using
ProcessStateDefinitionManager
- Definition Classes
- FlinkDeploymentManager → DeploymentManager
-
def
runDeployment(command: DMRunDeploymentCommand): Future[Option[ExternalDeploymentId]]
- Attributes
- protected
-
def
scenarioActivityHandling: ScenarioActivityHandling
- Definition Classes
- FlinkDeploymentManager → DeploymentManager
-
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( ... )
-
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.