Skip to content

Commit

Permalink
remove parquet override
Browse files Browse the repository at this point in the history
  • Loading branch information
samansmink committed May 29, 2024
1 parent b0acfc0 commit 870b32e
Show file tree
Hide file tree
Showing 5 changed files with 2 additions and 963 deletions.
1 change: 0 additions & 1 deletion CMakeLists.txt
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,6 @@ include_directories(duckdb/third_party/parquet)
include_directories(duckdb/third_party/thrift)

set(EXTENSION_SOURCES
src/inlined_parquet/parquet_extension.cpp
src/delta_extension.cpp
src/delta_functions.cpp
src/functions/delta_scan.cpp)
Expand Down
7 changes: 2 additions & 5 deletions src/functions/delta_scan.cpp
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
#include "duckdb/function/table_function.hpp"

#include "parquet_override.hpp"
#include "delta_functions.hpp"
#include "functions/delta_scan.hpp"
#include "duckdb/optimizer/filter_combiner.hpp"
Expand Down Expand Up @@ -595,10 +594,8 @@ TableFunctionSet DeltaFunctions::GetDeltaScanFunction(DatabaseInstance &instance
// The delta_scan function is constructed by grabbing the parquet scan from the Catalog, then injecting the
// DeltaMultiFileReader into it to create a Delta-based multi file read

// FIXME revert when all required changes are applied upstream
// auto &parquet_scan = ExtensionUtil::GetTableFunction(instance, "parquet_scan");
// auto parquet_scan_copy = parquet_scan.functions;
auto parquet_scan_copy = ParquetOverrideFunction::GetFunctionSet();
auto &parquet_scan = ExtensionUtil::GetTableFunction(instance, "parquet_scan");
auto parquet_scan_copy = parquet_scan.functions;

for (auto &function : parquet_scan_copy.functions) {
// Register the MultiFileReader as the driver for reads
Expand Down
12 changes: 0 additions & 12 deletions src/include/parquet_override.hpp

This file was deleted.

24 changes: 0 additions & 24 deletions src/inlined_parquet/README.md

This file was deleted.

Loading

0 comments on commit 870b32e

Please sign in to comment.