Skip to content

Commit

Permalink
format
Browse files Browse the repository at this point in the history
  • Loading branch information
samansmink committed Nov 20, 2024
1 parent 6f25451 commit 35e9d52
Show file tree
Hide file tree
Showing 3 changed files with 12 additions and 12 deletions.
20 changes: 10 additions & 10 deletions src/functions/delta_scan.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -643,9 +643,9 @@ void DeltaMultiFileReader::BindOptions(MultiFileReaderOptions &options, MultiFil
void DeltaMultiFileReader::FinalizeBind(const MultiFileReaderOptions &file_options,
const MultiFileReaderBindData &options, const string &filename,
const vector<string> &local_names, const vector<LogicalType> &global_types,
const vector<string> &global_names, const vector<ColumnIndex> &global_column_ids,
MultiFileReaderData &reader_data, ClientContext &context,
optional_ptr<MultiFileReaderGlobalState> global_state) {
const vector<string> &global_names,
const vector<ColumnIndex> &global_column_ids, MultiFileReaderData &reader_data,
ClientContext &context, optional_ptr<MultiFileReaderGlobalState> global_state) {
MultiFileReader::FinalizeBind(file_options, options, filename, local_names, global_types, global_names,
global_column_ids, reader_data, context, global_state);

Expand Down Expand Up @@ -982,14 +982,14 @@ bool DeltaMultiFileReader::ParseOption(const string &key, const Value &val, Mult
}

static InsertionOrderPreservingMap<string> DeltaFunctionToString(TableFunctionToStringInput &input) {
InsertionOrderPreservingMap<string> result;
InsertionOrderPreservingMap<string> result;

if (input.table_function.function_info) {
auto& table_info = input.table_function.function_info->Cast<DeltaFunctionInfo>();
result["Table"] = table_info.table_name;
}
if (input.table_function.function_info) {
auto &table_info = input.table_function.function_info->Cast<DeltaFunctionInfo>();
result["Table"] = table_info.table_name;
}

return result;
return result;
}

TableFunctionSet DeltaFunctions::GetDeltaScanFunction(DatabaseInstance &instance) {
Expand All @@ -1013,7 +1013,7 @@ TableFunctionSet DeltaFunctions::GetDeltaScanFunction(DatabaseInstance &instance
function.table_scan_progress = nullptr;
function.get_bind_info = nullptr;

function.to_string = DeltaFunctionToString;
function.to_string = DeltaFunctionToString;

// Schema param is just confusing here
function.named_parameters.erase("schema");
Expand Down
2 changes: 1 addition & 1 deletion src/include/functions/delta_scan.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ struct DeltaSnapshot;
struct DeltaFunctionInfo : public TableFunctionInfo {
shared_ptr<DeltaSnapshot> snapshot;
string expected_path;
string table_name;
string table_name;
};

struct DeltaFileMetaData {
Expand Down
2 changes: 1 addition & 1 deletion src/storage/delta_table_entry.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@ TableFunction DeltaTableEntry::GetScanFunction(ClientContext &context, unique_pt
auto function_info = make_shared_ptr<DeltaFunctionInfo>();

function_info->snapshot = this->snapshot;
function_info->table_name = delta_catalog.GetName();
function_info->table_name = delta_catalog.GetName();
delta_scan_function.function_info = std::move(function_info);

vector<Value> inputs = {delta_catalog.GetDBPath()};
Expand Down

0 comments on commit 35e9d52

Please sign in to comment.