[arrow-datafusion] branch master updated (9c8bdfed1 -> 74b05fa08)

[tu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

tustvold pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git


    from 9c8bdfed1 Replace &Option<T> with Option<&T> (#5102)
     add 74b05fa08 Use DataFusionError instead of ArrowError in SendableRecordBatchStream (#5101)

No new revisions were added by this update.

Summary of changes:
 .../core/src/physical_plan/aggregates/mod.rs       |  3 +-
 .../src/physical_plan/aggregates/no_grouping.rs    |  9 ++---
 .../core/src/physical_plan/aggregates/row_hash.rs  | 14 ++-----
 datafusion/core/src/physical_plan/analyze.rs       |  3 +-
 .../core/src/physical_plan/coalesce_batches.rs     |  4 +-
 .../core/src/physical_plan/coalesce_partitions.rs  |  8 ++--
 datafusion/core/src/physical_plan/common.rs        | 27 ++++++-------
 .../core/src/physical_plan/file_format/csv.rs      |  2 +-
 .../src/physical_plan/file_format/file_stream.rs   | 26 +++++++------
 .../core/src/physical_plan/file_format/mod.rs      |  7 ++--
 .../core/src/physical_plan/file_format/parquet.rs  |  8 +++-
 datafusion/core/src/physical_plan/filter.rs        |  8 ++--
 .../core/src/physical_plan/joins/cross_join.rs     |  8 ++--
 .../core/src/physical_plan/joins/hash_join.rs      | 17 +++------
 .../src/physical_plan/joins/nested_loop_join.rs    | 16 +++-----
 .../src/physical_plan/joins/sort_merge_join.rs     | 40 ++++++++++----------
 datafusion/core/src/physical_plan/joins/utils.rs   | 14 +++----
 datafusion/core/src/physical_plan/limit.rs         |  5 +--
 datafusion/core/src/physical_plan/memory.rs        |  3 +-
 .../core/src/physical_plan/metrics/baseline.rs     |  9 +++--
 .../core/src/physical_plan/metrics/tracker.rs      |  7 ++--
 datafusion/core/src/physical_plan/mod.rs           |  5 +--
 datafusion/core/src/physical_plan/projection.rs    |  8 ++--
 .../core/src/physical_plan/repartition/mod.rs      | 35 +++++++----------
 datafusion/core/src/physical_plan/sorts/sort.rs    | 44 ++++++++++------------
 .../physical_plan/sorts/sort_preserving_merge.rs   | 20 ++++------
 datafusion/core/src/physical_plan/stream.rs        | 17 ++++-----
 datafusion/core/src/physical_plan/streaming.rs     |  4 +-
 datafusion/core/src/physical_plan/union.rs         |  5 +--
 .../windows/bounded_window_agg_exec.rs             | 13 +++----
 .../src/physical_plan/windows/window_agg_exec.rs   | 23 +++++------
 .../core/src/scheduler/pipeline/execution.rs       |  4 +-
 datafusion/core/src/scheduler/task.rs              |  5 +--
 datafusion/core/src/test/exec.rs                   | 17 ++++-----
 datafusion/core/tests/custom_sources.rs            |  5 +--
 datafusion/core/tests/sql/timestamp.rs             |  2 +-
 datafusion/core/tests/sql/window.rs                |  2 +-
 datafusion/core/tests/user_defined_plan.rs         | 20 +++++-----
 38 files changed, 213 insertions(+), 254 deletions(-)