Package | Description |
---|---|
org.apache.flink.runtime.taskexecutor |
Modifier and Type | Method and Description |
---|---|
JobTable.Connection |
JobTable.Job.connect(ResourceID resourceId,
JobMasterGateway jobMasterGateway,
TaskManagerActions taskManagerActions,
CheckpointResponder checkpointResponder,
GlobalAggregateManager aggregateManager,
PartitionProducerStateChecker partitionStateChecker)
Connects the job to a JobManager and associates the provided services with this
connection.
|
Modifier and Type | Method and Description |
---|---|
Optional<JobTable.Connection> |
JobTable.Job.asConnection()
Returns the associated
JobTable.Connection if the job is connected to a JobManager. |
Optional<JobTable.Connection> |
DefaultJobTable.getConnection(JobID jobId) |
Optional<JobTable.Connection> |
JobTable.getConnection(JobID jobId)
Gets the connection registered under jobId.
|
Optional<JobTable.Connection> |
DefaultJobTable.getConnection(ResourceID resourceId) |
Optional<JobTable.Connection> |
JobTable.getConnection(ResourceID resourceId)
Gets the connection registered under resourceId.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.