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 D | sink_node.cc | 98 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 D | filter_node.cc | 95 void InputReceived(ExecNode* input, ExecBatch batch) override { in InputReceived() function in arrow::compute::__anon60426a060111::FilterNode
|
H A D | order_by_impl.cc | 44 void InputReceived(const std::shared_ptr<RecordBatch>& batch) override { in InputReceived() function in arrow::compute::SortBasicImpl
|
H A D | project_node.cc | 91 void InputReceived(ExecNode* input, ExecBatch batch) override { in InputReceived() function in arrow::compute::__anon29ac6e170111::ProjectNode
|
H A D | union_node.cc | 77 void InputReceived(ExecNode* input, ExecBatch batch) override { in InputReceived() function in arrow::compute::UnionNode
|
H A D | source_node.cc | 64 [[noreturn]] void InputReceived(ExecNode*, ExecBatch) override { NoInputs(); } in InputReceived() function
|
H A D | test_util.cc | 70 void InputReceived(ExecNode* input, ExecBatch batch) override {} in InputReceived() function
|
H A D | aggregate_node.cc | 178 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 D | hash_join_node.cc | 331 void InputReceived(ExecNode* input, ExecBatch batch) override { in InputReceived() function in arrow::compute::HashJoinNode
|
H A D | hash_join.cc | 41 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 D | compute_register_example.cc | 101 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 D | WebServiceReceive.cs | 149 public event EventHandler InputReceived property in System.Workflow.Activities.WebServiceInputActivity
|