Skip to content

Commit

Permalink
Minor touchups
Browse files Browse the repository at this point in the history
  • Loading branch information
malhotrashivam committed Mar 11, 2024
1 parent 1d98927 commit 5018feb
Showing 1 changed file with 2 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -144,8 +144,7 @@ static void write(
}
}
write(t, definition, writeInstructions, destFilePath, destFilePathForMetadata, incomingMeta,
tableInfoBuilder,
metadataFileWriter, computedCache);
tableInfoBuilder, metadataFileWriter, computedCache);
} catch (Exception e) {
if (cleanupFiles != null) {
for (final File cleanupFile : cleanupFiles) {
Expand Down Expand Up @@ -193,8 +192,7 @@ static void write(
final Map<String, ? extends ColumnSource<?>> columnSourceMap = t.getColumnSourceMap();
final ParquetFileWriter parquetFileWriter = getParquetFileWriter(computedCache, definition, tableRowSet,
columnSourceMap, destFilePath, destFilePathForMetadata, writeInstructions, tableMeta,
tableInfoBuilder,
metadataFileWriter);
tableInfoBuilder, metadataFileWriter);
// Given the transformation, do not use the original table's "definition" for writing
write(t, writeInstructions, parquetFileWriter, computedCache);
}
Expand Down

0 comments on commit 5018feb

Please sign in to comment.