Skip to content

Commit 7ea3109

Browse files
committed
default impls
1 parent 951943e commit 7ea3109

3 files changed

Lines changed: 15 additions & 0 deletions

File tree

runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/BatchViewOverrides.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1378,6 +1378,11 @@ public T getValue() {
13781378
return value;
13791379
}
13801380

1381+
@Override
1382+
public @Nullable Boolean isDraining() {
1383+
return null;
1384+
}
1385+
13811386
@Override
13821387
public Instant getTimestamp() {
13831388
return BoundedWindow.TIMESTAMP_MIN_VALUE;

runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/ValueInEmptyWindows.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -59,6 +59,11 @@ public PaneInfo getPaneInfo() {
5959
return null;
6060
}
6161

62+
@Override
63+
public @Nullable Boolean isDraining() {
64+
return null;
65+
}
66+
6267
@Override
6368
public Iterable<WindowedValue<T>> explodeWindows() {
6469
return Collections.emptyList();

runners/spark/src/main/java/org/apache/beam/runners/spark/util/TimerUtils.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -115,6 +115,11 @@ public PaneInfo getPaneInfo() {
115115
return null;
116116
}
117117

118+
@Override
119+
public @Nullable Boolean isDraining() {
120+
return null;
121+
}
122+
118123
@Override
119124
public @Nullable Long getRecordOffset() {
120125
return null;

0 commit comments

Comments
 (0)