File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -328,6 +328,10 @@ private List<PTransformOverride> getOverrides(boolean streaming) {
328
328
new StreamingFnApiCreateOverrideFactory ()));
329
329
}
330
330
overridesBuilder
331
+ .add (
332
+ PTransformOverride .of (
333
+ PTransformMatchers .writeWithRunnerDeterminedSharding (),
334
+ new StreamingShardedWriteFactory (options )))
331
335
.add (
332
336
// Streaming Bounded Read is implemented in terms of Streaming Unbounded Read, and
333
337
// must precede it
@@ -338,10 +342,6 @@ private List<PTransformOverride> getOverrides(boolean streaming) {
338
342
PTransformOverride .of (
339
343
PTransformMatchers .classEqualTo (Read .Unbounded .class ),
340
344
new ReflectiveRootOverrideFactory (StreamingUnboundedRead .class , this )))
341
- .add (
342
- PTransformOverride .of (
343
- PTransformMatchers .writeWithRunnerDeterminedSharding (),
344
- new StreamingShardedWriteFactory (options )))
345
345
.add (
346
346
PTransformOverride .of (
347
347
PTransformMatchers .classEqualTo (View .CreatePCollectionView .class ),
You can’t perform that action at this time.
0 commit comments