2222#include " iceberg/arrow/arrow_file_io.h"
2323#include " iceberg/avro/avro_register.h"
2424#include " iceberg/catalog/memory/in_memory_catalog.h"
25+ #include " iceberg/data/delete_loader.h"
2526#include " iceberg/manifest/manifest_entry.h"
2627#include " iceberg/parquet/parquet_register.h"
2728#include " iceberg/table.h"
@@ -39,50 +40,54 @@ int main(int argc, char** argv) {
3940 const std::string table_location = argv[3 ];
4041 const std::unordered_map<std::string, std::string> properties;
4142
42- iceberg::avro::RegisterAll ();
43- iceberg::parquet::RegisterAll ();
43+ // iceberg::avro::RegisterAll();
44+ // iceberg::parquet::RegisterAll();
4445
45- auto catalog = iceberg::InMemoryCatalog::Make ( " test " , iceberg::arrow::MakeLocalFileIO (),
46- warehouse_location, properties );
46+ // Exercise data-library symbols in the example binary.
47+ [[maybe_unused]] iceberg::DeleteLoader delete_loader ( nullptr );
4748
48- auto register_result = catalog->RegisterTable ({.name = table_name}, table_location);
49- if (!register_result.has_value ()) {
50- std::cerr << " Failed to register table: " << register_result.error ().message
51- << std::endl;
52- return 1 ;
53- }
49+ // auto catalog = iceberg::InMemoryCatalog::Make("test",
50+ // iceberg::arrow::MakeLocalFileIO(),
51+ // warehouse_location, properties);
5452
55- auto load_result = catalog->LoadTable ({.name = table_name});
56- if (!load_result.has_value ()) {
57- std::cerr << " Failed to load table: " << load_result.error ().message << std::endl;
58- return 1 ;
59- }
53+ // auto register_result = catalog->RegisterTable({.name = table_name}, table_location);
54+ // if (!register_result.has_value()) {
55+ // std::cerr << "Failed to register table: " << register_result.error().message
56+ // << std::endl;
57+ // return 1;
58+ // }
6059
61- auto table = std::move (load_result.value ());
62- auto scan_builder = table->NewScan ();
63- if (!scan_builder.has_value ()) {
64- std::cerr << " Failed to create scan builder: " << scan_builder.error ().message
65- << std::endl;
66- return 1 ;
67- }
68- auto scan_result = scan_builder.value ()->Build ();
69- if (!scan_result.has_value ()) {
70- std::cerr << " Failed to build scan: " << scan_result.error ().message << std::endl;
71- return 1 ;
72- }
60+ // auto load_result = catalog->LoadTable({.name = table_name});
61+ // if (!load_result.has_value()) {
62+ // std::cerr << "Failed to load table: " << load_result.error().message << std::endl;
63+ // return 1;
64+ // }
7365
74- auto scan = std::move (scan_result.value ());
75- auto plan_result = scan->PlanFiles ();
76- if (!plan_result.has_value ()) {
77- std::cerr << " Failed to plan files: " << plan_result.error ().message << std::endl;
78- return 1 ;
79- }
66+ // auto table = std::move(load_result.value());
67+ // auto scan_builder = table->NewScan();
68+ // if (!scan_builder.has_value()) {
69+ // std::cerr << "Failed to create scan builder: " << scan_builder.error().message
70+ // << std::endl;
71+ // return 1;
72+ // }
73+ // auto scan_result = scan_builder.value()->Build();
74+ // if (!scan_result.has_value()) {
75+ // std::cerr << "Failed to build scan: " << scan_result.error().message << std::endl;
76+ // return 1;
77+ // }
8078
81- std::cout << " Scan tasks: " << std::endl;
82- auto scan_tasks = std::move (plan_result.value ());
83- for (const auto & scan_task : scan_tasks) {
84- std::cout << " - " << scan_task->data_file ()->file_path << std::endl;
85- }
79+ // auto scan = std::move(scan_result.value());
80+ // auto plan_result = scan->PlanFiles();
81+ // if (!plan_result.has_value()) {
82+ // std::cerr << "Failed to plan files: " << plan_result.error().message << std::endl;
83+ // return 1;
84+ // }
85+
86+ // std::cout << "Scan tasks: " << std::endl;
87+ // auto scan_tasks = std::move(plan_result.value());
88+ // for (const auto& scan_task : scan_tasks) {
89+ // std::cout << " - " << scan_task->data_file()->file_path << std::endl;
90+ // }
8691
8792 return 0 ;
8893}
0 commit comments