Home
last modified time | relevance | path

Searched defs:InputReceived (Results 1 – 12 of 12) sorted by relevance

/dports/databases/arrow/apache-arrow-6.0.1/cpp/src/arrow/compute/exec/
H A Dsink_node.cc98 void InputReceived(ExecNode* input, ExecBatch batch) override { in InputReceived() function in arrow::compute::__anon0b79cf350111::SinkNode
182 void InputReceived(ExecNode* input, ExecBatch batch) override { in InputReceived() function in arrow::compute::__anon0b79cf350111::ConsumingSinkNode
277 void InputReceived(ExecNode* input, ExecBatch batch) override { in InputReceived() function
H A Dfilter_node.cc95 void InputReceived(ExecNode* input, ExecBatch batch) override { in InputReceived() function in arrow::compute::__anon60426a060111::FilterNode
H A Dorder_by_impl.cc44 void InputReceived(const std::shared_ptr<RecordBatch>& batch) override { in InputReceived() function in arrow::compute::SortBasicImpl
H A Dproject_node.cc91 void InputReceived(ExecNode* input, ExecBatch batch) override { in InputReceived() function in arrow::compute::__anon29ac6e170111::ProjectNode
H A Dunion_node.cc77 void InputReceived(ExecNode* input, ExecBatch batch) override { in InputReceived() function in arrow::compute::UnionNode
H A Dsource_node.cc64 [[noreturn]] void InputReceived(ExecNode*, ExecBatch) override { NoInputs(); } in InputReceived() function
H A Dtest_util.cc70 void InputReceived(ExecNode* input, ExecBatch batch) override {} in InputReceived() function
H A Daggregate_node.cc178 void InputReceived(ExecNode* input, ExecBatch batch) override { in InputReceived() function in arrow::compute::__anon5871d7e70111::ScalarAggregateNode
486 void InputReceived(ExecNode* input, ExecBatch batch) override { in InputReceived() function in arrow::compute::__anon5871d7e70111::GroupByNode
H A Dhash_join_node.cc331 void InputReceived(ExecNode* input, ExecBatch batch) override { in InputReceived() function in arrow::compute::HashJoinNode
H A Dhash_join.cc41 Status InputReceived(size_t thread_index, int side, ExecBatch batch) override { in InputReceived() function in arrow::compute::HashJoinBasicImpl
/dports/databases/arrow/apache-arrow-6.0.1/cpp/examples/arrow/
H A Dcompute_register_example.cc101 void InputReceived(ExecNode* input, cp::ExecBatch batch) override {} in InputReceived() function in ExampleNode
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Workflow.Activities/
H A DWebServiceReceive.cs149 public event EventHandler InputReceived property in System.Workflow.Activities.WebServiceInputActivity