anotherhadi/eleakxir
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

pretty print the query

Browse Source 
Signed-off-by: Hadi <112569860+anotherhadi@users.noreply.github.com>
This commit is contained in:
Hadi
2025-09-25 17:50:55 +02:00
parent 66382db894
commit 47fddbb1cc
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
leak-utils/parquet/parquet.go
View File

@@ -226,13 +226,13 @@ func transformParquet(lu settings.LeakUtils, input, output Parquet, operations [
COPY ( COPY (
SELECT %s SELECT %s
FROM read_parquet('%s') FROM read_parquet('%s')
WHERE (%s) < %d WHERE (%s) < %d %s
%s
) TO '%s' (FORMAT PARQUET, ROW_GROUP_SIZE 200_000 %s) ) TO '%s' (FORMAT PARQUET, ROW_GROUP_SIZE 200_000 %s)
`, selectClause, input.Filepath, strings.Join(columnsLength, "+"), allowedRowSize, offset, output.Filepath, compression) `, selectClause, input.Filepath, strings.Join(columnsLength, "+"), allowedRowSize, offset, output.Filepath, compression)
if printQuery { if printQuery {
fmt.Println("Query:", query) // TODO: Remove tabs fmt.Println(settings.Base.Render("\nQuery:"))
fmt.Println(settings.Accent.Render(strings.ReplaceAll(strings.TrimSpace(query), "\t", "")))
return nil return nil
} }