Skip to content

Commit 9d08b68

Browse files
authored
Merge pull request #287 from data-integrations/fix/remove-duplicate-method
Remove duplicate method from MysqlConnector
2 parents 19286b0 + 9ad84e9 commit 9d08b68

File tree

1 file changed

+0
-5
lines changed

1 file changed

+0
-5
lines changed

mysql-plugin/src/main/java/io/cdap/plugin/mysql/MysqlConnector.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -94,11 +94,6 @@ protected void setConnectorSpec(ConnectorSpecRequest request, DBConnectorPath pa
9494
properties.put(MysqlSink.MysqlSinkConfig.TABLE_NAME, table);
9595
}
9696

97-
@Override
98-
public StructuredRecord transform(LongWritable longWritable, MysqlDBRecord record) {
99-
return record.getRecord();
100-
}
101-
10297
@Override
10398
protected String getTableName(String database, String schema, String table) {
10499
return String.format("`%s`.`%s`", database, table);

0 commit comments

Comments
 (0)