This is an automated email from the ASF dual-hosted git repository.
nevime pushed a change to branch rust-parquet-arrow-writer
in repository https://gitbox.apache.org/repos/asf/arrow.git.
discard 228aec1 ARROW-10095: [Rust] Update rust-parquet-arrow-writer branch's
encode_arrow_schema with ipc changes
omit 8f0ed91 ARROW-8423: [Rust] [Parquet] Serialize Arrow schema metadata
omit adea0c3 ARROW-8289: [Rust] Parquet Arrow writer with nested support
add 728dec5 ARROW-10022: [C++] Fix divide by zero and overflow error for
scalar arithmetic benchmark
add 0b83c92 ARROW-7302: [C++] CSV: allow dictionary types in explicit
column types
add ca12cd1 ARROW-10024: [C++][Parquet] Create nested reading benchmarks
add 7a532ed ARROW-8678: [C++/Python][Parquet] Remove old writer code path
add 4716cd3 ARROW-3757: [R] R bindings for Flight RPC client
add eba7347 ARROW-9971: [Rust] Improve speed of `take` by 2x-3x (change
scaling with batch size)
add 6b3df45 ARROW-9990: [Rust] [DataFusion] Fixed the NOT operator
add f09e7f7 ARROW-10028: [Rust] Simplified macro
add 5e53d8c ARROW-9977: [Rust] Added min/max of [Large]StringArray
add 31025a0 ARROW-9987: [Rust] [DataFusion] Improved docs for `Expr`
add 9b35e96 ARROW-10001 [Rust] [DataFusion] Added developer guide to
README.
add 84b1512 ARROW-10034: [Rust] Fix Rust build on master
add 1f30466 ARROW-10002: [Rust] Remove `default fn` from
`PrimitiveArrayOps`
add 7ca8ee0 ARROW-9338: [Rust] Add clippy instructions
add 24a4a44 ARROW-9902: [Rust] [DataFusion] Add array() built-in function
add e067dea ARROW-9937: [Rust] [DataFusion] Improved aggregations
add a17717f ARROW-10017: [Java] Fix LargeMemoryUtil long conversion
add 0b4fa2a ARROW-9969: [C++] Fix RecordBatchBuilder with dictionary types
add 8cb15e6 ARROW-10048: [Rust] Fixed error in computing min/max with
null entries.
add bc987cd ARROW-9922: [Rust] Add StructArray::TryFrom (+40%)
add 5e1344b ARROW-10037: [C++] Workaround to force find AWS SDK to look
for shared libraries
add 9875d29 ARROW-9946: [R] Check `sink` argument class in
`ParquetFileWriter`
add 248803c ARROW-9775: [C++] Automatic S3 region selection
add 44f3de2 ARROW-8494: [C++][Parquet] Full support for reading mixed
list and structs
add 9dd18a1 ARROW-10055: [Rust] DoubleEndedIterator implementation for
NullableIter
add c47b58a ARROW-10013: [FlightRPC][C++] fix setting generic client
options
add c557ac3 ARROW-10035: [C++] Update vendored libraries
add 40d6475 ARROW-10049: [C++/Python] Sync conda recipe with conda-forge
add 9546388 ARROW-4189: [Rust] Added coverage report.
add de7cc0f ARROW-10062: [Rust] Fix for null elems at key position in
dictionary arrays
add 8595406 ARROW-10060: [Rust] [DataFusion] Fixed error on which Err
were discarded in MergeExec.
add 69d57d4 ARROW-10064: [C++] Resolve compile warnings on Apple Clang 12
add 02287b4 ARROW-9078: [C++] Parquet read / write extension type with
nested storage type
add 8563b42 PARQUET-1878: [C++] lz4 codec is not compatible with Hadoop
Lz4Codec
add 66aad9d ARROW-9010: [Java] Framework and interface changes for
RecordBatch IPC buffer compression
add 697f141 ARROW-10016: [Rust] Implement is null / is not null kernels
add e3a8d06 ARROW-10044: [Rust] Improved Arrow's README.
add f1f4001 ARROW-9897: [C++][Gandiva] Added to_date function
add 10e29a2 ARROW-10073: [Python] Don't rely on dict item order in
test_parquet_nested_storage
add 152f8b0 ARROW-10066: [C++] Make sure default AWS region selection
algorithm is used
add ac86123 ARROW-9970: [Go] fix checkptr failure in sum methods
add f7f5baa ARROW-10077: [C++] Fix possible integer multiplication
overflow
add 3a32019 ARROW-9934 [Rust] Shape and stride check in tensor
add 8eef4fd ARROW-10075: [C++] Use nullopt from arrow::util instead of
vendored namespace
add a4115ba ARROW-10074: [C++] Use string constructor instead of
string_view.to_string
add ea4a405 ARROW-10051: [C++][Compute] Move kernel state when merging
add 04eb733 ARROW-9603: [C++] Fix parquet write to not assume leaf-array
validity bitmaps have the same values as parent structs
add 171e8bf ARROW-10027: [C++] Fix Take array kernel for NullType
add f358a29 ARROW-10076: [C++] Use temporary directory facility in all
unit tests
add c3e399c ARROW-10065: [Rust] Simplify code (+500, -1k)
add 5e150bb ARROW-9557: [R] Iterating over parquet columns is slow in R
add 6c31940 ARROW-10083: [C++] Improve Parquet fuzz seed corpus
add 512e4d1 ARROW-10085: [C++] Fix S3 region resolution on Windows
add cadaaa9 ARROW-10003: [C++] Create parent dir for any destination fs
in CopyFiles
add c0dd2e2 ARROW-8601: [Go][Flight] Implementations Flight RPC server
and client
add 6a35f8a ARROW-10081: [C++/Python] Fix bash syntax in drone.io conda
builds
add b470be3 ARROW-10063: [Archery][CI] Fetch main branch in archery build
only when it is a pull request
add 3176548 ARROW-10092: [Dev][Go] Add grpc generated go files to rat
exclusion list
add a67d30c ARROW-10087: [CI] Fix nightly docs job
new 32d328b ARROW-8289: [Rust] Parquet Arrow writer with nested support
new 28b075d ARROW-8423: [Rust] [Parquet] Serialize Arrow schema metadata
new ac971db ARROW-10095: [Rust] Update rust-parquet-arrow-writer branch's
encode_arrow_schema with ipc changes
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (228aec1)
\
N -- N -- N refs/heads/rust-parquet-arrow-writer (ac971db)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/archery.yml | 1 +
.github/workflows/rust_cron.yml | 56 +
LICENSE.txt | 4 +-
ci/appveyor-cpp-build.bat | 2 +-
ci/appveyor-cpp-setup.bat | 1 -
ci/docker/linux-apt-docs.dockerfile | 8 +
ci/scripts/rust_coverage.sh | 39 +
cpp/cmake_modules/SetupCxxFlags.cmake | 4 +-
cpp/cmake_modules/ThirdpartyToolchain.cmake | 20 +
cpp/src/arrow/array/array_dict_test.cc | 17 +-
cpp/src/arrow/array/builder_dict.cc | 41 +-
cpp/src/arrow/array/builder_dict.h | 76 +-
cpp/src/arrow/array/dict_internal.h | 11 -
cpp/src/arrow/buffer.cc | 2 +-
cpp/src/arrow/builder.cc | 6 +
cpp/src/arrow/compute/exec.cc | 2 +-
cpp/src/arrow/compute/kernel.h | 2 +-
cpp/src/arrow/compute/kernels/aggregate_basic.cc | 6 +-
.../compute/kernels/aggregate_basic_internal.h | 6 +-
cpp/src/arrow/compute/kernels/aggregate_mode.cc | 10 +-
.../compute/kernels/scalar_arithmetic_benchmark.cc | 21 +-
cpp/src/arrow/compute/kernels/vector_selection.cc | 4 +-
.../arrow/compute/kernels/vector_selection_test.cc | 1 +
cpp/src/arrow/csv/converter.cc | 763 +--
cpp/src/arrow/csv/converter.h | 3 +
cpp/src/arrow/csv/converter_test.cc | 89 +-
cpp/src/arrow/dataset/discovery.cc | 2 +-
cpp/src/arrow/dataset/file_base.cc | 2 +-
cpp/src/arrow/dataset/file_csv.cc | 2 +-
cpp/src/arrow/dataset/filter.cc | 2 +-
cpp/src/arrow/dataset/partition.cc | 2 +-
cpp/src/arrow/extension_type.cc | 26 +
cpp/src/arrow/extension_type.h | 10 +
cpp/src/arrow/filesystem/filesystem.cc | 44 +-
cpp/src/arrow/filesystem/filesystem.h | 24 +-
cpp/src/arrow/filesystem/filesystem_test.cc | 47 +-
cpp/src/arrow/filesystem/path_util.cc | 38 +-
cpp/src/arrow/filesystem/path_util.h | 6 +
cpp/src/arrow/filesystem/s3fs.cc | 247 +-
cpp/src/arrow/filesystem/s3fs.h | 23 +-
cpp/src/arrow/filesystem/s3fs_narrative_test.cc | 6 +-
cpp/src/arrow/filesystem/s3fs_test.cc | 100 +-
cpp/src/arrow/flight/client.cc | 16 +-
cpp/src/arrow/flight/flight_test.cc | 2 +-
cpp/src/arrow/io/buffered_test.cc | 10 +-
cpp/src/arrow/io/file_test.cc | 64 +-
cpp/src/arrow/io/memory_test.cc | 4 +-
cpp/src/arrow/ipc/metadata_internal.cc | 2 +-
cpp/src/arrow/ipc/read_write_test.cc | 41 +-
cpp/src/arrow/json/parser.cc | 2 +-
cpp/src/arrow/scalar.cc | 7 +-
cpp/src/arrow/scalar_test.cc | 2 +-
cpp/src/arrow/table_builder.cc | 16 +-
cpp/src/arrow/table_builder_test.cc | 27 +
cpp/src/arrow/testing/gtest_util.cc | 21 +
cpp/src/arrow/testing/gtest_util.h | 11 +
cpp/src/arrow/testing/random.cc | 35 +-
cpp/src/arrow/testing/random.h | 49 +-
cpp/src/arrow/type_traits.h | 28 +-
cpp/src/arrow/util/atomic_shared_ptr.h | 34 +-
cpp/src/arrow/util/bit_stream_utils.h | 3 +-
cpp/src/arrow/util/compression.cc | 15 +
cpp/src/arrow/util/compression.h | 13 +-
cpp/src/arrow/util/compression_internal.h | 3 +
cpp/src/arrow/util/compression_lz4.cc | 107 +
cpp/src/arrow/util/compression_test.cc | 70 +-
cpp/src/arrow/util/cpu_info.h | 5 +
cpp/src/arrow/util/hashing.h | 9 -
cpp/src/arrow/util/io_util_test.cc | 11 +-
cpp/src/arrow/util/simd.h | 4 +
cpp/src/arrow/util/string.cc | 2 +-
cpp/src/arrow/util/uri.cc | 2 +-
cpp/src/arrow/util/utf8.cc | 7 +-
cpp/src/arrow/vendored/datetime.h | 5 +
cpp/src/arrow/vendored/datetime/README.md | 2 +-
cpp/src/arrow/vendored/datetime/date.h | 101 +-
cpp/src/arrow/vendored/datetime/ios.h | 4 +-
cpp/src/arrow/vendored/datetime/ios.mm | 526 +--
cpp/src/arrow/vendored/datetime/tz.cpp | 145 +-
cpp/src/arrow/vendored/datetime/tz.h | 269 +-
cpp/src/arrow/vendored/datetime/tz_private.h | 6 +-
cpp/src/arrow/vendored/string_view.hpp | 49 +-
cpp/src/arrow/vendored/utfcpp/README.md | 28 +
.../arrow/vendored/{utf8cpp => utfcpp}/checked.h | 64 +-
cpp/src/arrow/vendored/{utf8cpp => utfcpp}/core.h | 45 +-
cpp/src/arrow/vendored/utfcpp/cpp11.h | 103 +
cpp/src/arrow/vendored/xxhash.h | 10 -
cpp/src/arrow/vendored/xxhash/README.md | 3 +-
cpp/src/arrow/vendored/xxhash/xxh3.h | 1583 -------
cpp/src/arrow/vendored/xxhash/xxhash.c | 1141 +----
cpp/src/arrow/vendored/xxhash/xxhash.h | 4854 ++++++++++++++++++--
cpp/src/gandiva/function_registry_datetime.cc | 7 +
cpp/src/gandiva/gdv_function_stubs.cc | 25 +
cpp/src/gandiva/tests/projector_test.cc | 49 +-
cpp/src/gandiva/tests/test_util.h | 2 +
cpp/src/gandiva/to_date_holder.cc | 35 +-
cpp/src/parquet/CMakeLists.txt | 22 +
cpp/src/parquet/arrow/arrow_reader_writer_test.cc | 56 +-
cpp/src/parquet/arrow/generate_fuzz_corpus.cc | 83 +-
cpp/src/parquet/arrow/path_internal.cc | 3 +
cpp/src/parquet/arrow/path_internal.h | 3 +
cpp/src/parquet/arrow/reader.cc | 524 ++-
cpp/src/parquet/arrow/reader_internal.cc | 136 -
cpp/src/parquet/arrow/reader_internal.h | 10 -
cpp/src/parquet/arrow/reader_writer_benchmark.cc | 142 +-
cpp/src/parquet/arrow/reconstruct_internal_test.cc | 149 +-
cpp/src/parquet/arrow/schema.cc | 84 +-
cpp/src/parquet/arrow/schema.h | 11 +-
cpp/src/parquet/arrow/writer.cc | 381 +-
cpp/src/parquet/arrow/writer.h | 2 -
cpp/src/parquet/column_reader.cc | 135 +-
cpp/src/parquet/column_reader.h | 23 +-
cpp/src/parquet/column_writer.cc | 307 +-
cpp/src/parquet/column_writer.h | 11 +-
cpp/src/parquet/column_writer_test.cc | 10 +-
cpp/src/parquet/exception.h | 7 +
cpp/src/parquet/file_deserialize_test.cc | 8 +-
cpp/src/parquet/file_serialize_test.cc | 15 +-
cpp/src/parquet/level_comparison.cc | 82 +
.../util/simd.h => parquet/level_comparison.h} | 38 +-
.../src/parquet/level_comparison_avx2.cc | 26 +-
cpp/src/parquet/level_comparison_inc.h | 64 +
cpp/src/parquet/level_conversion.cc | 306 +-
cpp/src/parquet/level_conversion.h | 97 +-
cpp/src/parquet/level_conversion_benchmark.cc | 16 +-
.../src/parquet/level_conversion_bmi2.cc | 29 +-
cpp/src/parquet/level_conversion_inc.h | 140 +
cpp/src/parquet/level_conversion_test.cc | 305 +-
cpp/src/parquet/reader_test.cc | 74 +-
cpp/src/parquet/statistics.cc | 8 +-
cpp/src/parquet/thrift_internal.h | 5 +-
cpp/src/parquet/types.cc | 41 +-
cpp/src/parquet/types.h | 9 -
cpp/src/plasma/client.cc | 1 -
cpp/submodules/parquet-testing | 2 +-
dev/release/rat_exclude_files.txt | 1 +
.../linux_aarch64_python3.6.____cpython.yaml | 16 +-
.../linux_aarch64_python3.7.____cpython.yaml | 16 +-
.../linux_aarch64_python3.8.____cpython.yaml | 16 +-
...a_compiler_version9.2python3.6.____cpython.yaml | 10 +-
...a_compiler_version9.2python3.7.____cpython.yaml | 10 +-
...a_compiler_version9.2python3.8.____cpython.yaml | 10 +-
..._compiler_versionNonepython3.6.____cpython.yaml | 10 +-
..._compiler_versionNonepython3.7.____cpython.yaml | 10 +-
..._compiler_versionNonepython3.8.____cpython.yaml | 10 +-
.../.ci_support/osx_python3.6.____cpython.yaml | 14 +-
.../.ci_support/osx_python3.7.____cpython.yaml | 14 +-
.../.ci_support/osx_python3.8.____cpython.yaml | 14 +-
.../.ci_support/win_python3.6.____cpython.yaml | 12 +-
.../.ci_support/win_python3.7.____cpython.yaml | 12 +-
.../.ci_support/win_python3.8.____cpython.yaml | 12 +-
dev/tasks/conda-recipes/arrow-cpp/bld-arrow.bat | 3 +-
dev/tasks/conda-recipes/arrow-cpp/build-arrow.sh | 1 +
dev/tasks/conda-recipes/arrow-cpp/meta.yaml | 25 +-
dev/tasks/conda-recipes/drone-steps.sh | 2 +-
docs/source/developers/cpp/conventions.rst | 21 +
format/Flight.proto | 2 +
go/arrow/flight/Flight.pb.go | 1473 ++++++
go/arrow/flight/Flight_grpc.pb.go | 877 ++++
go/arrow/flight/client.go | 89 +
go/arrow/flight/client_auth.go | 91 +
go/arrow/flight/example_flight_server_test.go | 86 +
go/arrow/flight/flight_test.go | 305 ++
go/arrow/{go.mod => flight/gen.go} | 12 +-
go/arrow/flight/server.go | 118 +
go/arrow/flight/server_auth.go | 145 +
go/arrow/go.mod | 8 +
go/arrow/go.sum | 94 +
go/arrow/ipc/flight_data_reader.go | 210 +
go/arrow/ipc/flight_data_writer.go | 150 +
go/arrow/math/float64_avx2_amd64.go | 4 +-
go/arrow/math/float64_sse4_amd64.go | 4 +-
go/arrow/math/int64_avx2_amd64.go | 4 +-
go/arrow/math/int64_sse4_amd64.go | 4 +-
go/arrow/math/type_simd_amd64.go.tmpl | 4 +-
go/arrow/math/uint64_avx2_amd64.go | 4 +-
go/arrow/math/uint64_sse4_amd64.go | 4 +-
.../java/org/apache/arrow/flight/ArrowMessage.java | 9 +
.../apache/arrow/memory/util/LargeMemoryUtil.java | 4 +-
.../arrow/memory/util/TestLargeMemoryUtil.java | 105 +
.../java/org/apache/arrow/vector/VectorLoader.java | 13 +-
.../org/apache/arrow/vector/VectorUnloader.java | 30 +-
.../arrow/vector/compression/CompressionCodec.java | 51 +
.../arrow/vector/compression/CompressionUtil.java | 60 +
.../vector/compression/NoCompressionCodec.java | 54 +
.../vector/ipc/message/ArrowBodyCompression.java} | 59 +-
.../arrow/vector/ipc/message/ArrowRecordBatch.java | 41 +-
.../vector/ipc/message/MessageSerializer.java | 8 +-
python/pyarrow/_dataset.pyx | 3 +-
python/pyarrow/_flight.pyx | 3 +-
python/pyarrow/_parquet.pyx | 1 +
python/pyarrow/_s3fs.pyx | 7 +
python/pyarrow/includes/libarrow_fs.pxd | 1 +
python/pyarrow/parquet.py | 7 +-
python/pyarrow/tests/test_compute.py | 28 +
python/pyarrow/tests/test_csv.py | 32 +
python/pyarrow/tests/test_extension_type.py | 75 +-
python/pyarrow/tests/test_flight.py | 2 +
python/pyarrow/tests/test_fs.py | 29 +-
python/pyarrow/tests/test_parquet.py | 24 +-
r/DESCRIPTION | 1 +
r/NAMESPACE | 5 +
r/R/arrow-package.R | 2 +-
r/R/arrowExports.R | 32 +-
r/R/filesystem.R | 19 +-
r/R/flight.R | 81 +
r/R/parquet.R | 77 +-
r/_pkgdown.yml | 6 +
r/inst/demo_flight_server.py | 120 +
r/man/ParquetFileReader.Rd | 21 +-
r/man/ParquetFileWriter.Rd | 9 +
r/man/flight_connect.Rd | 21 +
r/man/flight_get.Rd | 19 +
r/man/load_flight_server.Rd | 17 +
r/man/push_data.Rd | 21 +
r/src/arrowExports.cpp | 135 +-
r/src/filesystem.cpp | 20 +-
r/src/parquet.cpp | 55 +
r/tests/testthat/test-parquet.R | 35 +
r/vignettes/flight.Rmd | 78 +
rust/README.md | 21 +
rust/arrow/README.md | 56 +-
rust/arrow/benches/array_from_vec.rs | 53 +
rust/arrow/benches/take_kernels.rs | 79 +-
rust/arrow/examples/tensor_builder.rs | 67 +
rust/arrow/src/array/array.rs | 1470 +++---
rust/arrow/src/array/equal.rs | 809 +---
rust/arrow/src/array/mod.rs | 8 +-
rust/arrow/src/compute/kernels/aggregate.rs | 85 +-
rust/arrow/src/compute/kernels/boolean.rs | 240 +-
rust/arrow/src/compute/kernels/concat.rs | 2 +-
rust/arrow/src/compute/kernels/filter.rs | 34 +-
rust/arrow/src/compute/kernels/sort.rs | 2 +-
rust/arrow/src/compute/kernels/take.rs | 241 +-
rust/arrow/src/datatypes.rs | 146 +-
rust/arrow/src/tensor.rs | 307 +-
rust/arrow/src/util/pretty.rs | 1 +
rust/datafusion/Cargo.toml | 1 +
rust/datafusion/README.md | 104 +
rust/datafusion/benches/aggregate_query_sql.rs | 137 +-
rust/datafusion/examples/simple_udf.rs | 4 +-
rust/datafusion/src/datasource/parquet.rs | 1 +
rust/datafusion/src/execution/context.rs | 57 +-
rust/datafusion/src/lib.rs | 1 +
rust/datafusion/src/logical_plan/mod.rs | 189 +-
rust/datafusion/src/logical_plan/operators.rs | 3 -
rust/datafusion/src/physical_plan/aggregates.rs | 22 +-
.../src/physical_plan/array_expressions.rs | 108 +
rust/datafusion/src/physical_plan/common.rs | 159 +-
.../src/physical_plan/datetime_expressions.rs | 4 +-
rust/datafusion/src/physical_plan/explain.rs | 6 +-
rust/datafusion/src/physical_plan/expressions.rs | 1791 ++++----
rust/datafusion/src/physical_plan/filter.rs | 7 +-
rust/datafusion/src/physical_plan/functions.rs | 98 +-
.../datafusion/src/physical_plan/hash_aggregate.rs | 852 ++--
.../src/physical_plan/math_expressions.rs | 4 +-
rust/datafusion/src/physical_plan/merge.rs | 6 +-
rust/datafusion/src/physical_plan/mod.rs | 100 +-
rust/datafusion/src/physical_plan/planner.rs | 69 +-
rust/datafusion/src/prelude.rs | 2 +-
rust/datafusion/src/scalar.rs | 305 ++
rust/datafusion/src/sql/planner.rs | 21 +-
rust/datafusion/src/test/mod.rs | 1 +
rust/datafusion/src/test/variable.rs | 6 +-
rust/datafusion/src/variable/mod.rs | 2 +-
rust/datafusion/tests/sql.rs | 276 +-
rust/datafusion/tests/user_defined_plan.rs | 5 +-
267 files changed, 18988 insertions(+), 9140 deletions(-)
create mode 100644 .github/workflows/rust_cron.yml
create mode 100755 ci/scripts/rust_coverage.sh
create mode 100644 cpp/src/arrow/vendored/utfcpp/README.md
rename cpp/src/arrow/vendored/{utf8cpp => utfcpp}/checked.h (87%)
rename cpp/src/arrow/vendored/{utf8cpp => utfcpp}/core.h (93%)
create mode 100644 cpp/src/arrow/vendored/utfcpp/cpp11.h
delete mode 100644 cpp/src/arrow/vendored/xxhash/xxh3.h
create mode 100644 cpp/src/parquet/level_comparison.cc
copy cpp/src/{arrow/util/simd.h => parquet/level_comparison.h} (61%)
copy rust/datafusion/src/variable/mod.rs =>
cpp/src/parquet/level_comparison_avx2.cc (63%)
create mode 100644 cpp/src/parquet/level_comparison_inc.h
copy rust/datafusion/src/variable/mod.rs =>
cpp/src/parquet/level_conversion_bmi2.cc (55%)
create mode 100644 cpp/src/parquet/level_conversion_inc.h
create mode 100644 go/arrow/flight/Flight.pb.go
create mode 100644 go/arrow/flight/Flight_grpc.pb.go
create mode 100644 go/arrow/flight/client.go
create mode 100644 go/arrow/flight/client_auth.go
create mode 100644 go/arrow/flight/example_flight_server_test.go
create mode 100644 go/arrow/flight/flight_test.go
copy go/arrow/{go.mod => flight/gen.go} (73%)
create mode 100644 go/arrow/flight/server.go
create mode 100644 go/arrow/flight/server_auth.go
create mode 100644 go/arrow/ipc/flight_data_reader.go
create mode 100644 go/arrow/ipc/flight_data_writer.go
create mode 100755
java/memory/memory-core/src/test/java/org/apache/arrow/memory/util/TestLargeMemoryUtil.java
create mode 100644
java/vector/src/main/java/org/apache/arrow/vector/compression/CompressionCodec.java
create mode 100644
java/vector/src/main/java/org/apache/arrow/vector/compression/CompressionUtil.java
create mode 100644
java/vector/src/main/java/org/apache/arrow/vector/compression/NoCompressionCodec.java
copy
java/{memory/memory-core/src/main/java/org/apache/arrow/memory/util/LargeMemoryUtil.java
=>
vector/src/main/java/org/apache/arrow/vector/ipc/message/ArrowBodyCompression.java}
(50%)
create mode 100644 r/R/flight.R
create mode 100644 r/inst/demo_flight_server.py
create mode 100644 r/man/flight_connect.Rd
create mode 100644 r/man/flight_get.Rd
create mode 100644 r/man/load_flight_server.Rd
create mode 100644 r/man/push_data.Rd
create mode 100644 r/vignettes/flight.Rmd
create mode 100644 rust/arrow/examples/tensor_builder.rs
create mode 100644 rust/datafusion/src/physical_plan/array_expressions.rs
create mode 100644 rust/datafusion/src/scalar.rs
