Skip to content

Commit 40a6a75

Browse files
committed
CDAP-17407 Update source to use SourceConfigurer.
1 parent 4130c45 commit 40a6a75

2 files changed

Lines changed: 4 additions & 2 deletions

File tree

mysql-delta-plugins/src/main/java/io/cdap/delta/mysql/MySqlDeltaSource.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626
import io.cdap.delta.api.EventEmitter;
2727
import io.cdap.delta.api.EventReader;
2828
import io.cdap.delta.api.EventReaderDefinition;
29+
import io.cdap.delta.api.SourceConfigurer;
2930
import io.cdap.delta.api.assessment.TableAssessor;
3031
import io.cdap.delta.api.assessment.TableDetail;
3132
import io.cdap.delta.api.assessment.TableRegistry;
@@ -49,7 +50,7 @@ public MySqlDeltaSource(MySqlConfig conf) {
4950
}
5051

5152
@Override
52-
public void configure(Configurer configurer) {
53+
public void configure(SourceConfigurer configurer) {
5354
// add MySql JDBC Plugin usage at configure time
5455
configurer.usePluginClass("jdbc", conf.getJdbcPluginName(), conf.getJDBCPluginId(),
5556
PluginProperties.builder().build());

sqlserver-delta-plugins/src/main/java/io/cdap/delta/sqlserver/SqlServerDeltaSource.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626
import io.cdap.delta.api.EventEmitter;
2727
import io.cdap.delta.api.EventReader;
2828
import io.cdap.delta.api.EventReaderDefinition;
29+
import io.cdap.delta.api.SourceConfigurer;
2930
import io.cdap.delta.api.assessment.TableAssessor;
3031
import io.cdap.delta.api.assessment.TableDetail;
3132
import io.cdap.delta.api.assessment.TableRegistry;
@@ -51,7 +52,7 @@ public SqlServerDeltaSource(SqlServerConfig config) {
5152
}
5253

5354
@Override
54-
public void configure(Configurer configurer) {
55+
public void configure(SourceConfigurer configurer) {
5556
// add Sql-Server JDBC Plugin usage
5657
configurer.usePluginClass("jdbc", config.getJdbcPluginName(), config.getJDBCPluginId(),
5758
PluginProperties.builder().build());

0 commit comments

Comments
 (0)