Skip to content

Commit 8e82e2e

Browse files
authored
Merge pull request #102 from data-integrations/fix/update-api
Fix compilation issue.
2 parents 9af8e5b + 9f78ee7 commit 8e82e2e

1 file changed

Lines changed: 6 additions & 0 deletions

File tree

delta-plugins-common/src/main/java/io/cdap/delta/plugin/mock/MockContext.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
import io.cdap.cdap.api.macro.MacroEvaluator;
2020
import io.cdap.cdap.api.metrics.Metrics;
2121
import io.cdap.cdap.api.plugin.PluginProperties;
22+
import io.cdap.delta.api.DeltaPipelineId;
2223
import io.cdap.delta.api.DeltaSourceContext;
2324
import io.cdap.delta.api.ReplicationError;
2425

@@ -109,6 +110,11 @@ public void putState(String s, byte[] bytes) {
109110
state.put(s, bytes);
110111
}
111112

113+
@Override
114+
public DeltaPipelineId getPipelineId() {
115+
return new DeltaPipelineId("default", "app", 0L);
116+
}
117+
112118
@Override
113119
public PluginProperties getPluginProperties(String pluginId) {
114120
return PluginProperties.builder().build();

0 commit comments

Comments
 (0)