amoeba / arrow-cpp-examples

Various Arrow C++ examples

arrow-cpp-examples

Various examples of Arrow C++ usage. See subdirectories.

arrow-cpp-examples's Issues

Fix arrow_table_partition example

This example is close but currently failing with,

* thread #1, queue = 'com.apple.main-thread', stop reason = signal SIGABRT
  * frame #0: 0x00000001821d6a60 libsystem_kernel.dylib`__pthread_kill + 8
    frame #1: 0x000000018220ec20 libsystem_pthread.dylib`pthread_kill + 288
    frame #2: 0x000000018211ba20 libsystem_c.dylib`abort + 180
    frame #3: 0x00000001821c5d30 libc++abi.dylib`abort_message + 132
    frame #4: 0x00000001821b5fcc libc++abi.dylib`demangling_terminate_handler() + 320
    frame #5: 0x0000000181e541e0 libobjc.A.dylib`_objc_terminate() + 160
    frame #6: 0x00000001821c50f4 libc++abi.dylib`std::__terminate(void (*)()) + 16
    frame #7: 0x00000001821c8348 libc++abi.dylib`__cxxabiv1::failed_throw(__cxxabiv1::__cxa_exception*) + 88
    frame #8: 0x00000001821c828c libc++abi.dylib`__cxa_throw + 308
    frame #9: 0x00000001821b5e24 libc++abi.dylib`__cxa_bad_cast + 52
    frame #10: 0x000000010217df14 libarrow_acero.1600.dylib`arrow::acero::SourceNodeOptions const& arrow::internal::checked_cast<arrow::acero::SourceNodeOptions const&, arrow::acero::ExecNodeOptions const&>(value=0x0000600001113c68) at checked_cast.h:38:10
    frame #11: 0x000000010217d6e4 libarrow_acero.1600.dylib`arrow::acero::(anonymous namespace)::SourceNode::Make(plan=0x000000013971de80, inputs=size=0, options=0x0000600001113c68) at source_node.cc:107:34
    frame #12: 0x00000001020165dc libarrow_acero.1600.dylib`decltype(std::declval<arrow::Result<arrow::acero::ExecNode*> (*&)(arrow::acero::ExecPlan*, std::__1::vector<arrow::acero::ExecNode*, std::__1::allocator<arrow::acero::ExecNode*>>, arrow::acero::ExecNodeOptions const&)>()(std::declval<arrow::acero::ExecPlan*>(), std::declval<std::__1::vector<arrow::acero::ExecNode*, std::__1::allocator<arrow::acero::ExecNode*>>>(), std::declval<arrow::acero::ExecNodeOptions const&>())) std::__1::__invoke[abi:ue170006]<arrow::Result<arrow::acero::ExecNode*> (*&)(arrow::acero::ExecPlan*, std::__1::vector<arrow::acero::ExecNode*, std::__1::allocator<arrow::acero::ExecNode*>>, arrow::acero::ExecNodeOptions const&), arrow::acero::ExecPlan*, std::__1::vector<arrow::acero::ExecNode*, std::__1::allocator<arrow::acero::ExecNode*>>, arrow::acero::ExecNodeOptions const&>(__f=0x000000016fdfd4e8, __args=0x000000016fdfd418, __args=size=0, __args=0x0000600001113c68) at invoke.h:340:25
    frame #13: 0x0000000102016548 libarrow_acero.1600.dylib`arrow::Result<arrow::acero::ExecNode*> std::__1::__invoke_void_return_wrapper<arrow::Result<arrow::acero::ExecNode*>, false>::__call[abi:ue170006]<arrow::Result<arrow::acero::ExecNode*> (*&)(arrow::acero::ExecPlan*, std::__1::vector<arrow::acero::ExecNode*, std::__1::allocator<arrow::acero::ExecNode*>>, arrow::acero::ExecNodeOptions const&), arrow::acero::ExecPlan*, std::__1::vector<arrow::acero::ExecNode*, std::__1::allocator<arrow::acero::ExecNode*>>, arrow::acero::ExecNodeOptions const&>(__args=0x000000016fdfd4e8, __args=0x000000016fdfd418, __args=size=0, __args=0x0000600001113c68) at invoke.h:407:12
    frame #14: 0x0000000102016504 libarrow_acero.1600.dylib`std::__1::__function::__alloc_func<arrow::Result<arrow::acero::ExecNode*> (*)(arrow::acero::ExecPlan*, std::__1::vector<arrow::acero::ExecNode*, std::__1::allocator<arrow::acero::ExecNode*>>, arrow::acero::ExecNodeOptions const&), std::__1::allocator<arrow::Result<arrow::acero::ExecNode*> (*)(arrow::acero::ExecPlan*, std::__1::vector<arrow::acero::ExecNode*, std::__1::allocator<arrow::acero::ExecNode*>>, arrow::acero::ExecNodeOptions const&)>, arrow::Result<arrow::acero::ExecNode*> (arrow::acero::ExecPlan*, std::__1::vector<arrow::acero::ExecNode*, std::__1::allocator<arrow::acero::ExecNode*>>, arrow::acero::ExecNodeOptions const&)>::operator()[abi:ue170006](this=0x000000016fdfd4e8, __arg=0x000000016fdfd418, __arg=size=0, __arg=0x0000600001113c68) at function.h:193:16
    frame #15: 0x0000000102015354 libarrow_acero.1600.dylib`std::__1::__function::__func<arrow::Result<arrow::acero::ExecNode*> (*)(arrow::acero::ExecPlan*, std::__1::vector<arrow::acero::ExecNode*, std::__1::allocator<arrow::acero::ExecNode*>>, arrow::acero::ExecNodeOptions const&), std::__1::allocator<arrow::Result<arrow::acero::ExecNode*> (*)(arrow::acero::ExecPlan*, std::__1::vector<arrow::acero::ExecNode*, std::__1::allocator<arrow::acero::ExecNode*>>, arrow::acero::ExecNodeOptions const&)>, arrow::Result<arrow::acero::ExecNode*> (arrow::acero::ExecPlan*, std::__1::vector<arrow::acero::ExecNode*, std::__1::allocator<arrow::acero::ExecNode*>>, arrow::acero::ExecNodeOptions const&)>::operator()(this=0x000000016fdfd4e0, __arg=0x000000016fdfd418, __arg=size=0, __arg=0x0000600001113c68) at function.h:364:12
    frame #16: 0x0000000102055680 libarrow_acero.1600.dylib`std::__1::__function::__value_func<arrow::Result<arrow::acero::ExecNode*> (arrow::acero::ExecPlan*, std::__1::vector<arrow::acero::ExecNode*, std::__1::allocator<arrow::acero::ExecNode*>>, arrow::acero::ExecNodeOptions const&)>::operator()[abi:ue170006](this=0x000000016fdfd4e0, __args=0x000000016fdfd418, __args=size=0, __args=0x0000600001113c68) const at function.h:518:16
    frame #17: 0x00000001020553c8 libarrow_acero.1600.dylib`std::__1::function<arrow::Result<arrow::acero::ExecNode*> (arrow::acero::ExecPlan*, std::__1::vector<arrow::acero::ExecNode*, std::__1::allocator<arrow::acero::ExecNode*>>, arrow::acero::ExecNodeOptions const&)>::operator()(this= Function = arrow::acero::(anonymous namespace)::SourceNode::Make(arrow::acero::ExecPlan*, std::__1::vector<arrow::acero::ExecNode*, std::__1::allocator<arrow::acero::ExecNode*>>, arrow::acero::ExecNodeOptions const&) , __arg=0x000000013971de80, __arg=size=0, __arg=0x0000600001113c68) const at function.h:1169:12
    frame #18: 0x000000010203c108 libarrow_acero.1600.dylib`arrow::acero::MakeExecNode(factory_name="source", plan=0x000000013971de80, inputs=size=0, options=0x0000600001113c68, registry=0x00000001023094f0) at exec_plan.h:381:10
    frame #19: 0x000000010203bc98 libarrow_acero.1600.dylib`arrow::acero::Declaration::AddToPlan(this=0x000060000160cd20, plan=0x000000013971de80, registry=0x00000001023094f0) const at exec_plan.cc:585:3
    frame #20: 0x000000010203bb74 libarrow_acero.1600.dylib`arrow::acero::Declaration::AddToPlan(this=0x000060000160d020, plan=0x000000013971de80, registry=0x00000001023094f0) const at exec_plan.cc:581:5
    frame #21: 0x000000010203bb74 libarrow_acero.1600.dylib`arrow::acero::Declaration::AddToPlan(this=0x000000016fdfdb48, plan=0x000000013971de80, registry=0x00000001023094f0) const at exec_plan.cc:581:5
    frame #22: 0x000000010203d7d4 libarrow_acero.1600.dylib`arrow::acero::(anonymous namespace)::DeclarationToTableImpl(declaration=Declaration @ 0x000000016fdfde70, query_options=QueryOptions @ 0x000000016fdfde28, cpu_executor=0x0000600003201d40) at exec_plan.cc:660:3
    frame #23: 0x0000000102078dfc libarrow_acero.1600.dylib`arrow::acero::DeclarationToTable(arrow::acero::Declaration, bool, arrow::MemoryPool*, arrow::compute::FunctionRegistry*)::$_2::operator()(this=0x0000600001914078, executor=0x0000600003201d40) const at exec_plan.cc:785:16
    frame #24: 0x0000000102078d08 libarrow_acero.1600.dylib`arrow::internal::FnOnce<arrow::Future<std::__1::shared_ptr<arrow::Table>> (arrow::internal::Executor*)>::FnImpl<arrow::acero::DeclarationToTable(arrow::acero::Declaration, bool, arrow::MemoryPool*, arrow::compute::FunctionRegistry*)::$_2>::invoke(this=0x0000600001914070, a=0x000000016fdfdf58) at functional.h:152:42
    frame #25: 0x00000001020780e4 libarrow_acero.1600.dylib`arrow::internal::FnOnce<arrow::Future<std::__1::shared_ptr<arrow::Table>> (arrow::internal::Executor*)>::operator()(this=0x000000016fdfe090, a=0x0000600003201d40) && at functional.h:140:17
    frame #26: 0x000000010203e404 libarrow_acero.1600.dylib`arrow::Future<std::__1::shared_ptr<arrow::Table>>::SyncType arrow::internal::RunSynchronously<arrow::Future<std::__1::shared_ptr<arrow::Table>>, std::__1::shared_ptr<arrow::Table>>(get_future=FnOnce<arrow::Future<std::__1::shared_ptr<arrow::Table> > (arrow::internal::Executor *)> @ 0x000000016fdfe090, use_threads=true) at thread_pool.h:587:16
    frame #27: 0x000000010203e35c libarrow_acero.1600.dylib`arrow::acero::DeclarationToTable(declaration=Declaration @ 0x000000016fdfe1f0, use_threads=true, memory_pool=0x000000010a9a5c00, function_registry=0x0000000000000000) at exec_plan.cc:783:10
    frame #28: 0x0000000100002c98 example`RunMain(path="/Users/bryce/Data/starwars.parquet") at example.cc:36:3
    frame #29: 0x0000000100003e88 example`main(argc=1, argv=0x000000016fdfe9c8) at example.cc:45:22
    frame #30: 0x0000000181e860e0 dyld`start + 2360