Skip to content

Commit 459c47e

Browse files
committed
format modified codebase to google-java-format 1.17.0
1 parent 4ad9ad5 commit 459c47e

4 files changed

Lines changed: 5 additions & 6 deletions

File tree

runners/core-java/src/main/java/org/apache/beam/runners/core/ReduceFnRunner.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -100,6 +100,7 @@ public class ReduceFnRunner<K, InputT, OutputT, W extends BoundedWindow> {
100100
"unstable_not_update_compatible_new_window_optimization";
101101
public static final String UNSTABLE_DISABLE_WATERMARK_KNOWN_EMPTY_OPTIMIZATION =
102102
"unstable_disable_watermark_known_empty_optimization";
103+
103104
/**
104105
* The {@link ReduceFnRunner} depends on most aspects of the {@link WindowingStrategy}.
105106
*

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

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1342,8 +1342,7 @@ public DataflowPipelineJob run(Pipeline pipeline) {
13421342
// need the default environment.
13431343
SdkComponents portableComponents = SdkComponents.create();
13441344
portableComponents.registerEnvironment(
1345-
defaultEnvironmentForDataflow
1346-
.toBuilder()
1345+
defaultEnvironmentForDataflow.toBuilder()
13471346
.addAllDependencies(getDefaultArtifacts())
13481347
.addAllCapabilities(Environments.getJavaCapabilities())
13491348
.build());
@@ -1384,8 +1383,7 @@ public DataflowPipelineJob run(Pipeline pipeline) {
13841383
// Capture the SdkComponents for look up during step translations
13851384
SdkComponents dataflowV1Components = SdkComponents.create();
13861385
dataflowV1Components.registerEnvironment(
1387-
defaultEnvironmentForDataflow
1388-
.toBuilder()
1386+
defaultEnvironmentForDataflow.toBuilder()
13891387
.addAllDependencies(getDefaultArtifacts())
13901388
.addAllCapabilities(Environments.getJavaCapabilities())
13911389
.build());

runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/DataflowRunnerTest.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2788,8 +2788,7 @@ public void process() {}
27882788
@Category({ValidatesRunner.class})
27892789
public void testValueKindParameterAndOutputWithKind() {
27902790
boolean isRunnerV2 = false;
2791-
@Nullable
2792-
List<String> experiments =
2791+
@Nullable List<String> experiments =
27932792
pipeline.getOptions().as(DataflowPipelineOptions.class).getExperiments();
27942793
if (experiments != null
27952794
&& (experiments.contains("use_unified_worker") || experiments.contains("use_runner_v2"))) {

runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillWatermarkHold.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,7 @@ public class WindmillWatermarkHold extends WindmillState implements WatermarkHol
5050

5151
private boolean cleared = false;
5252
private boolean knownEmpty = false;
53+
5354
/**
5455
* If non-{@literal null}, the known current hold value, or absent if we know there are no output
5556
* watermark holds. If {@literal null}, the current hold value could depend on holds in Windmill

0 commit comments

Comments
 (0)