Skip to content

Commit 32e8683

Browse files
committed
check style
1 parent c3dfa05 commit 32e8683

2 files changed

Lines changed: 4 additions & 4 deletions

File tree

sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileSystems.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -410,8 +410,8 @@ public ResourceId apply(@Nonnull Metadata input) {
410410
* <p>- Otherwise, report top level only.
411411
*/
412412
public static void reportSourceLineage(List<ResourceId> resourceIds) {
413-
final int MAX_LINEAGE_TARGETS = 100;
414-
if (resourceIds.size() <= MAX_LINEAGE_TARGETS) {
413+
final int maxLineageTargets = 100;
414+
if (resourceIds.size() <= maxLineageTargets) {
415415
for (ResourceId resourceId : resourceIds) {
416416
FileSystems.reportSourceLineage(resourceId);
417417
}
@@ -420,7 +420,7 @@ public static void reportSourceLineage(List<ResourceId> resourceIds) {
420420
for (ResourceId resourceId : resourceIds) {
421421
ResourceId dir = resourceId.getCurrentDirectory();
422422
uniqueDirs.add(dir);
423-
if (uniqueDirs.size() > MAX_LINEAGE_TARGETS) {
423+
if (uniqueDirs.size() > maxLineageTargets) {
424424
FileSystems.reportSourceLineage(dir, LineageLevel.TOP_LEVEL);
425425
return;
426426
}

sdks/java/io/hadoop-format/src/main/java/org/apache/beam/sdk/io/hadoop/format/HadoopFormatIO.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -748,7 +748,7 @@ public List<BoundedSource<KV<K, V>>> split(long desiredBundleSizeBytes, Pipeline
748748
.collect(Collectors.toList());
749749
}
750750

751-
/** Report only file-based sources */
751+
/** Report only file-based sources. */
752752
private void reportSourceLineage(final List<SerializableSplit> inputSplits) {
753753
List<ResourceId> fileResources =
754754
inputSplits.stream()

0 commit comments

Comments
 (0)