Skip to content

Commit d47427d

Browse files
do spotlessApply
Signed-off-by: Shailesh-Kumar-Singh <shaileshkumarsingh260@gmail.com>
1 parent 0986aed commit d47427d

3 files changed

Lines changed: 5 additions & 9 deletions

File tree

sandbox/plugins/parquet-data-format/src/main/java/org/opensearch/parquet/engine/ParquetIndexingEngine.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,6 @@
1414
import org.opensearch.common.settings.Settings;
1515
import org.opensearch.index.IndexSettings;
1616
import org.opensearch.index.engine.dataformat.IndexingExecutionEngine;
17-
import org.opensearch.index.engine.dataformat.MergeResult;
1817
import org.opensearch.index.engine.dataformat.Merger;
1918
import org.opensearch.index.engine.dataformat.RefreshInput;
2019
import org.opensearch.index.engine.dataformat.RefreshResult;

sandbox/plugins/parquet-data-format/src/main/java/org/opensearch/parquet/merge/StreamingParquetMergeStrategy.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -52,9 +52,10 @@ public MergeResult mergeParquetFiles(MergeInput mergeInput) {
5252
}
5353

5454
List<Path> filePaths = new ArrayList<>();
55-
files.forEach(writerFileSet -> writerFileSet.files().forEach(
56-
file -> filePaths.add(shardDataPath.resolve(writerFileSet.directory()).resolve(file))
57-
));
55+
files.forEach(
56+
writerFileSet -> writerFileSet.files()
57+
.forEach(file -> filePaths.add(shardDataPath.resolve(writerFileSet.directory()).resolve(file)))
58+
);
5859

5960
String outputDirectory = shardDataPath.resolve(files.getFirst().directory()).toString();
6061
String mergedFilePath = getMergedFilePath(writerGeneration, outputDirectory);

server/src/main/java/org/opensearch/index/engine/dataformat/MergeInput.java

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,6 @@
1010

1111
import org.opensearch.common.annotation.ExperimentalApi;
1212
import org.opensearch.index.engine.exec.Segment;
13-
1413
import org.opensearch.index.engine.exec.WriterFileSet;
1514

1615
import java.util.ArrayList;
@@ -41,10 +40,7 @@ private MergeInput(Builder builder) {
4140
* @return list of writer file sets for the format across all segments
4241
*/
4342
public List<WriterFileSet> getFilesForFormat(String formatName) {
44-
return segments.stream()
45-
.map(seg -> seg.dfGroupedSearchableFiles().get(formatName))
46-
.filter(Objects::nonNull)
47-
.toList();
43+
return segments.stream().map(seg -> seg.dfGroupedSearchableFiles().get(formatName)).filter(Objects::nonNull).toList();
4844
}
4945

5046
/**

0 commit comments

Comments
 (0)