File tree Expand file tree Collapse file tree
delta-plugins-common/src/main/java/io/cdap/delta/plugin/mock Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2222import io .cdap .delta .api .DeltaPipelineId ;
2323import io .cdap .delta .api .DeltaSourceContext ;
2424import io .cdap .delta .api .ReplicationError ;
25+ import io .cdap .delta .api .SourceTable ;
2526
2627import java .util .Collections ;
2728import java .util .HashMap ;
2829import java .util .Map ;
30+ import java .util .Set ;
2931import javax .annotation .Nullable ;
3032
3133/**
@@ -115,6 +117,11 @@ public DeltaPipelineId getPipelineId() {
115117 return new DeltaPipelineId ("default" , "app" , 0L );
116118 }
117119
120+ @ Override
121+ public Set <SourceTable > getAllTables () {
122+ return Collections .emptySet ();
123+ }
124+
118125 @ Override
119126 public PluginProperties getPluginProperties (String pluginId ) {
120127 return PluginProperties .builder ().build ();
You can’t perform that action at this time.
0 commit comments