Skip to content

Commit 15ce2dc

Browse files
checkstyle
1 parent b92b64f commit 15ce2dc

2 files changed

Lines changed: 21 additions & 2 deletions

File tree

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/parser/CustomAlterTableParserListener.java

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,15 @@
1717

1818
package org.apache.flink.cdc.connectors.mysql.source.parser;
1919

20-
import org.apache.flink.cdc.common.event.*;
20+
import org.apache.flink.cdc.common.event.AddColumnEvent;
21+
import org.apache.flink.cdc.common.event.AlterColumnTypeEvent;
22+
import org.apache.flink.cdc.common.event.AlterTableCommentEvent;
23+
import org.apache.flink.cdc.common.event.CreateTableEvent;
24+
import org.apache.flink.cdc.common.event.DropColumnEvent;
25+
import org.apache.flink.cdc.common.event.DropTableEvent;
26+
import org.apache.flink.cdc.common.event.RenameColumnEvent;
27+
import org.apache.flink.cdc.common.event.SchemaChangeEvent;
28+
import org.apache.flink.cdc.common.event.TruncateTableEvent;
2129
import org.apache.flink.cdc.common.schema.Schema;
2230
import org.apache.flink.cdc.common.types.DataType;
2331

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlPipelineITCase.java

Lines changed: 12 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,18 @@
2121
import org.apache.flink.api.common.restartstrategy.RestartStrategies;
2222
import org.apache.flink.cdc.common.configuration.Configuration;
2323
import org.apache.flink.cdc.common.data.binary.BinaryStringData;
24-
import org.apache.flink.cdc.common.event.*;
24+
import org.apache.flink.cdc.common.event.AddColumnEvent;
25+
import org.apache.flink.cdc.common.event.AlterColumnTypeEvent;
26+
import org.apache.flink.cdc.common.event.AlterTableCommentEvent;
27+
import org.apache.flink.cdc.common.event.CreateTableEvent;
28+
import org.apache.flink.cdc.common.event.DataChangeEvent;
29+
import org.apache.flink.cdc.common.event.DropColumnEvent;
30+
import org.apache.flink.cdc.common.event.DropTableEvent;
31+
import org.apache.flink.cdc.common.event.Event;
32+
import org.apache.flink.cdc.common.event.RenameColumnEvent;
33+
import org.apache.flink.cdc.common.event.SchemaChangeEvent;
34+
import org.apache.flink.cdc.common.event.TableId;
35+
import org.apache.flink.cdc.common.event.TruncateTableEvent;
2536
import org.apache.flink.cdc.common.factories.Factory;
2637
import org.apache.flink.cdc.common.factories.FactoryHelper;
2738
import org.apache.flink.cdc.common.schema.Column;

0 commit comments

Comments
 (0)