| Package | Description |
|---|---|
| com.ververica.cdc.connectors.mysql.source.assigners | |
| com.ververica.cdc.connectors.mysql.source.assigners.state |
| Modifier and Type | Method and Description |
|---|---|
static AssignerStatus |
AssignerStatus.fromStatusCode(int statusCode)
Gets the
AssignerStatus from status code. |
AssignerStatus |
MySqlSnapshotSplitAssigner.getAssignerStatus() |
AssignerStatus |
MySqlBinlogSplitAssigner.getAssignerStatus() |
AssignerStatus |
MySqlSplitAssigner.getAssignerStatus()
Gets the split assigner status, see
AssignerStatus. |
AssignerStatus |
MySqlHybridSplitAssigner.getAssignerStatus() |
abstract AssignerStatus |
AssignerStatus.getNextStatus() |
AssignerStatus |
AssignerStatus.onFinish() |
AssignerStatus |
AssignerStatus.suspend() |
static AssignerStatus |
AssignerStatus.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static AssignerStatus[] |
AssignerStatus.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
AssignerStatus |
AssignerStatus.wakeup() |
| Modifier and Type | Method and Description |
|---|---|
static boolean |
AssignerStatus.isAssigning(AssignerStatus assignerStatus)
Returns whether the split assigner is assigning snapshot splits.
|
static boolean |
AssignerStatus.isAssigningFinished(AssignerStatus assignerStatus)
Returns whether the split assigner has assigned all snapshot splits, which indicates there is
no more splits and all records of splits have been completely processed in the pipeline.
|
static boolean |
AssignerStatus.isInitialAssigningFinished(AssignerStatus assignerStatus)
Returns whether the split assigner has finished its initial tables assignment.
|
static boolean |
AssignerStatus.isNewlyAddedAssigning(AssignerStatus assignerStatus)
Returns whether the split assigner is assigning newly added snapshot splits.
|
static boolean |
AssignerStatus.isNewlyAddedAssigningFinished(AssignerStatus assignerStatus)
Returns whether the split assigner has finished its newly added tables assignment.
|
static boolean |
AssignerStatus.isSuspended(AssignerStatus assignerStatus)
Returns whether the split assigner state is suspended.
|
| Modifier and Type | Method and Description |
|---|---|
AssignerStatus |
SnapshotPendingSplitsState.getSnapshotAssignerStatus() |
| Constructor and Description |
|---|
SnapshotPendingSplitsState(List<io.debezium.relational.TableId> alreadyProcessedTables,
List<MySqlSnapshotSplit> remainingSplits,
Map<String,MySqlSnapshotSplit> assignedSplits,
Map<String,BinlogOffset> splitFinishedOffsets,
AssignerStatus assignerStatus,
List<io.debezium.relational.TableId> remainingTables,
boolean isTableIdCaseSensitive,
boolean isRemainingTablesCheckpointed) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.