Rename arrow2 -> re_arrow2

arrow-odbc-integration-testing/src/lib.rs

@@ -3,8 +3,8 @@
 mod read;
 mod write;
 
-use arrow2::io::odbc::api::{Connection, Environment, Error as OdbcError};
 use lazy_static::lazy_static;
+use re_arrow2::io::odbc::api::{Connection, Environment, Error as OdbcError};
 
 lazy_static! {
     /// This is an example for using doc comment attributes

arrow-odbc-integration-testing/src/read.rs

@@ -1,11 +1,11 @@
 use stdext::function_name;
 
-use arrow2::array::{Array, BinaryArray, BooleanArray, Int32Array, Int64Array, Utf8Array};
-use arrow2::chunk::Chunk;
-use arrow2::datatypes::{DataType, Field, TimeUnit};
-use arrow2::error::Result;
-use arrow2::io::odbc::api::{Connection, Cursor};
-use arrow2::io::odbc::read::{buffer_from_metadata, deserialize, infer_schema};
+use re_arrow2::array::{Array, BinaryArray, BooleanArray, Int32Array, Int64Array, Utf8Array};
+use re_arrow2::chunk::Chunk;
+use re_arrow2::datatypes::{DataType, Field, TimeUnit};
+use re_arrow2::error::Result;
+use re_arrow2::io::odbc::api::{Connection, Cursor};
+use re_arrow2::io::odbc::read::{buffer_from_metadata, deserialize, infer_schema};
 
 use super::{setup_empty_table, ENV, MSSQL};
 

arrow-odbc-integration-testing/src/write.rs

@@ -1,10 +1,10 @@
 use stdext::function_name;
 
-use arrow2::array::{Array, BinaryArray, BooleanArray, Int32Array, Utf8Array};
-use arrow2::chunk::Chunk;
-use arrow2::datatypes::{DataType, Field};
-use arrow2::error::Result;
-use arrow2::io::odbc::write::{buffer_from_description, infer_descriptions, serialize};
+use re_arrow2::array::{Array, BinaryArray, BooleanArray, Int32Array, Utf8Array};
+use re_arrow2::chunk::Chunk;
+use re_arrow2::datatypes::{DataType, Field};
+use re_arrow2::error::Result;
+use re_arrow2::io::odbc::write::{buffer_from_description, infer_descriptions, serialize};
 
 use super::read::read;
 use super::{setup_empty_table, ENV, MSSQL};

arrow-parquet-integration-testing/src/main.rs

@@ -1,9 +1,11 @@
 use std::fs::File;
 use std::io::Read;
 
-use arrow2::array::Array;
-use arrow2::io::ipc::IpcField;
-use arrow2::{
+use clap::Parser;
+use flate2::read::GzDecoder;
+use re_arrow2::array::Array;
+use re_arrow2::io::ipc::IpcField;
+use re_arrow2::{
     chunk::Chunk,
     datatypes::{DataType, Schema},
     error::Result,
@@ -17,8 +19,6 @@ use arrow2::{
     },
     AHashMap,
 };
-use clap::Parser;
-use flate2::read::GzDecoder;
 
 /// Read gzipped JSON file
 pub fn read_gzip_json(

arrow-pyarrow-integration-testing/src/c_stream.rs

@@ -3,9 +3,9 @@
 use pyo3::ffi::Py_uintptr_t;
 use pyo3::prelude::*;
 
-use arrow2::array::{Int32Array, StructArray};
-use arrow2::datatypes::DataType;
-use arrow2::ffi;
+use re_arrow2::array::{Int32Array, StructArray};
+use re_arrow2::datatypes::DataType;
+use re_arrow2::ffi;
 
 use super::*;
 

arrow-pyarrow-integration-testing/src/lib.rs

@@ -10,7 +10,7 @@ use pyo3::ffi::Py_uintptr_t;
 use pyo3::prelude::*;
 use pyo3::wrap_pyfunction;
 
-use arrow2::{array::Array, datatypes::Field, error::Error, ffi};
+use re_arrow2::{array::Array, datatypes::Field, error::Error, ffi};
 
 /// an error that bridges Error with a Python error
 #[derive(Debug)]
@@ -80,8 +80,8 @@ fn to_py_array(array: Box<dyn Array>, py: Python) -> PyResult<PyObject> {
     )));
     let array = Box::new(ffi::export_array_to_c(array));
 
-    let schema_ptr: *const arrow2::ffi::ArrowSchema = &*schema;
-    let array_ptr: *const arrow2::ffi::ArrowArray = &*array;
+    let schema_ptr: *const re_arrow2::ffi::ArrowSchema = &*schema;
+    let array_ptr: *const re_arrow2::ffi::ArrowArray = &*array;
 
     let pa = py.import("pyarrow")?;
 
@@ -110,7 +110,7 @@ fn to_rust_field(ob: PyObject, py: Python) -> PyResult<Field> {
 
 fn to_py_field(field: &Field, py: Python) -> PyResult<PyObject> {
     let schema = Box::new(ffi::export_field_to_c(field));
-    let schema_ptr: *const arrow2::ffi::ArrowSchema = &*schema;
+    let schema_ptr: *const re_arrow2::ffi::ArrowSchema = &*schema;
 
     let pa = py.import("pyarrow")?;
 

benches/aggregate.rs

@@ -1,8 +1,8 @@
 use criterion::{criterion_group, criterion_main, Criterion};
 
-use arrow2::array::*;
-use arrow2::compute::aggregate::*;
-use arrow2::util::bench_util::*;
+use re_arrow2::array::*;
+use re_arrow2::compute::aggregate::*;
+use re_arrow2::util::bench_util::*;
 
 fn bench_sum(arr_a: &dyn Array) {
     sum(criterion::black_box(arr_a)).unwrap();

benches/arithmetic_kernels.rs

@@ -1,10 +1,10 @@
-use arrow2::compute::arithmetics::basic::NativeArithmetics;
 use criterion::{criterion_group, criterion_main, Criterion};
+use re_arrow2::compute::arithmetics::basic::NativeArithmetics;
 
-use arrow2::array::*;
-use arrow2::util::bench_util::*;
-use arrow2::{compute::arithmetics::basic::add, compute::arithmetics::basic::div_scalar};
 use num_traits::NumCast;
+use re_arrow2::array::*;
+use re_arrow2::util::bench_util::*;
+use re_arrow2::{compute::arithmetics::basic::add, compute::arithmetics::basic::div_scalar};
 use std::ops::{Add, Div};
 
 fn bench_div_scalar<T>(lhs: &PrimitiveArray<T>, rhs: &T)

benches/assign_ops.rs

@@ -1,7 +1,7 @@
 use criterion::{criterion_group, criterion_main, Criterion};
 
-use arrow2::compute::arity_assign::{binary, unary};
-use arrow2::{
+use re_arrow2::compute::arity_assign::{binary, unary};
+use re_arrow2::{
     compute::arithmetics::basic::{mul, mul_scalar},
     util::bench_util::*,
 };

benches/avro_read.rs

@@ -3,11 +3,11 @@ use std::io::Cursor;
 use avro_rs::types::Record;
 use criterion::*;
 
-use arrow2::error::Result;
-use arrow2::io::avro::avro_schema::read::read_metadata;
-use arrow2::io::avro::read;
 use avro_rs::*;
 use avro_rs::{Codec, Schema as AvroSchema};
+use re_arrow2::error::Result;
+use re_arrow2::io::avro::avro_schema::read::read_metadata;
+use re_arrow2::io::avro::read;
 
 fn schema() -> AvroSchema {
     let raw_schema = r#"

benches/bitmap.rs

@@ -2,7 +2,7 @@ use std::iter::FromIterator;
 
 use criterion::{criterion_group, criterion_main, Criterion};
 
-use arrow2::bitmap::*;
+use re_arrow2::bitmap::*;
 
 fn add_benchmark(c: &mut Criterion) {
     (10..=20).step_by(2).for_each(|log2_size| {

benches/bitmap_assign_ops.rs

@@ -1,7 +1,7 @@
 use criterion::{criterion_group, criterion_main, Criterion};
 
-use arrow2::bitmap::{binary_assign, unary_assign};
-use arrow2::bitmap::{Bitmap, MutableBitmap};
+use re_arrow2::bitmap::{binary_assign, unary_assign};
+use re_arrow2::bitmap::{Bitmap, MutableBitmap};
 
 fn add_benchmark(c: &mut Criterion) {
     (10..=20).step_by(2).for_each(|log2_size| {

benches/bitmap_ops.rs

@@ -1,6 +1,6 @@
 use criterion::{criterion_group, criterion_main, Criterion};
 
-use arrow2::bitmap::Bitmap;
+use re_arrow2::bitmap::Bitmap;
 
 fn bench_arrow2(lhs: &Bitmap, rhs: &Bitmap) {
     let r = lhs | rhs;

benches/bitwise.rs

@@ -3,7 +3,7 @@ use std::ops::{BitAnd, BitOr, BitXor, Not};
 use criterion::{criterion_group, criterion_main, Criterion};
 use num_traits::NumCast;
 
-use arrow2::{
+use re_arrow2::{
     array::PrimitiveArray, compute::bitwise::*, types::NativeType,
     util::bench_util::create_primitive_array_with_seed,
 };

benches/cast_kernels.rs

@@ -19,10 +19,10 @@ use criterion::{criterion_group, criterion_main, Criterion};
 use rand::distributions::Uniform;
 use rand::Rng;
 
-use arrow2::array::*;
-use arrow2::compute::cast;
-use arrow2::datatypes::*;
-use arrow2::util::bench_util::*;
+use re_arrow2::array::*;
+use re_arrow2::compute::cast;
+use re_arrow2::datatypes::*;
+use re_arrow2::util::bench_util::*;
 
 fn build_utf8_date_array(size: usize, with_nulls: bool) -> Utf8Array<i32> {
     use chrono::NaiveDate;

benches/comparison_kernels.rs

@@ -1,8 +1,8 @@
 use criterion::{criterion_group, criterion_main, Criterion};
 
-use arrow2::compute::comparison::{eq, eq_scalar};
-use arrow2::scalar::*;
-use arrow2::util::bench_util::*;
+use re_arrow2::compute::comparison::{eq, eq_scalar};
+use re_arrow2::scalar::*;
+use re_arrow2::util::bench_util::*;
 
 fn add_benchmark(c: &mut Criterion) {
     (10..=20).step_by(2).for_each(|log2_size| {

benches/concatenate.rs

@@ -1,6 +1,6 @@
 use criterion::{criterion_group, criterion_main, Criterion};
 
-use arrow2::{
+use re_arrow2::{
     compute::concatenate::concatenate,
     util::bench_util::{create_boolean_array, create_primitive_array},
 };

benches/count_zeros.rs

@@ -1,6 +1,6 @@
 use criterion::{criterion_group, criterion_main, Criterion};
 
-use arrow2::bitmap::utils::count_zeros;
+use re_arrow2::bitmap::utils::count_zeros;
 
 fn add_benchmark(c: &mut Criterion) {
     (10..=20).step_by(2).for_each(|log2_size| {

benches/filter_kernels.rs

@@ -16,11 +16,13 @@
 // under the License.
 use criterion::{criterion_group, criterion_main, Criterion};
 
-use arrow2::array::*;
-use arrow2::chunk::Chunk;
-use arrow2::compute::filter::{build_filter, filter, filter_chunk, Filter};
-use arrow2::datatypes::DataType;
-use arrow2::util::bench_util::{create_boolean_array, create_primitive_array, create_string_array};
+use re_arrow2::array::*;
+use re_arrow2::chunk::Chunk;
+use re_arrow2::compute::filter::{build_filter, filter, filter_chunk, Filter};
+use re_arrow2::datatypes::DataType;
+use re_arrow2::util::bench_util::{
+    create_boolean_array, create_primitive_array, create_string_array,
+};
 
 fn bench_filter(data_array: &dyn Array, filter_array: &BooleanArray) {
     criterion::black_box(filter(data_array, filter_array).unwrap());

benches/growable.rs

@@ -1,6 +1,6 @@
 use criterion::{criterion_group, criterion_main, Criterion};
 
-use arrow2::{
+use re_arrow2::{
     array::growable::{Growable, GrowablePrimitive},
     util::bench_util::create_primitive_array,
 };

benches/hash_kernel.rs

@@ -1,7 +1,7 @@
 use criterion::{criterion_group, criterion_main, Criterion};
 
-use arrow2::compute::hash::hash;
-use arrow2::util::bench_util::*;
+use re_arrow2::compute::hash::hash;
+use re_arrow2::util::bench_util::*;
 
 fn add_benchmark(c: &mut Criterion) {
     let log2_size = 10;

benches/iter_list.rs

@@ -2,7 +2,7 @@ use std::iter::FromIterator;
 
 use criterion::{criterion_group, criterion_main, Criterion};
 
-use arrow2::{
+use re_arrow2::{
     array::{ListArray, PrimitiveArray},
     bitmap::Bitmap,
     buffer::Buffer,

benches/iter_utf8.rs

@@ -1,6 +1,6 @@
 use criterion::{criterion_group, criterion_main, Criterion};
 
-use arrow2::array::Utf8Array;
+use re_arrow2::array::Utf8Array;
 
 fn add_benchmark(c: &mut Criterion) {
     (10..=20).step_by(2).for_each(|log2_size| {

benches/length_kernel.rs

@@ -17,8 +17,8 @@
 
 use criterion::{criterion_group, criterion_main, Criterion};
 
-use arrow2::array::*;
-use arrow2::compute::length::length;
+use re_arrow2::array::*;
+use re_arrow2::compute::length::length;
 
 fn bench_length(array: &Utf8Array<i32>) {
     criterion::black_box(length(array).unwrap());

benches/like_kernels.rs

@@ -1,8 +1,8 @@
-use arrow2::util::bench_util::create_string_array;
 use criterion::{criterion_group, criterion_main, Criterion};
+use re_arrow2::util::bench_util::create_string_array;
 
-use arrow2::array::*;
-use arrow2::compute::like::like_utf8_scalar;
+use re_arrow2::array::*;
+use re_arrow2::compute::like::like_utf8_scalar;
 
 fn bench_like(array: &Utf8Array<i32>, pattern: &str) {
     criterion::black_box(like_utf8_scalar(array, pattern).unwrap());

benches/read_json.rs

@@ -1,9 +1,9 @@
-use arrow2::array::Array;
-use arrow2::datatypes::DataType;
 use criterion::{criterion_group, criterion_main, Criterion};
+use re_arrow2::array::Array;
+use re_arrow2::datatypes::DataType;
 
-use arrow2::io::json::{read, write};
-use arrow2::util::bench_util::*;
+use re_arrow2::io::json::{read, write};
+use re_arrow2::util::bench_util::*;
 
 fn prep(array: impl Array + 'static) -> (Vec<u8>, DataType) {
     let mut data = vec![];

benches/read_parquet.rs

@@ -3,8 +3,8 @@ use std::{fs, io::Cursor, path::PathBuf};
 
 use criterion::{criterion_group, criterion_main, Criterion};
 
-use arrow2::error::Result;
-use arrow2::io::parquet::read;
+use re_arrow2::error::Result;
+use re_arrow2::io::parquet::read;
 
 fn to_buffer(
     size: usize,

benches/slices_iterator.rs

@@ -1,6 +1,6 @@
 use criterion::{criterion_group, criterion_main, Criterion};
 
-use arrow2::bitmap::{utils::SlicesIterator, Bitmap};
+use re_arrow2::bitmap::{utils::SlicesIterator, Bitmap};
 
 fn bench_slices(lhs: &Bitmap) {
     let set_count = lhs.len() - lhs.unset_bits();

benches/sort_kernel.rs

@@ -17,9 +17,9 @@
 
 use criterion::{criterion_group, criterion_main, Criterion};
 
-use arrow2::array::*;
-use arrow2::compute::sort::{lexsort, sort, sort_to_indices, SortColumn, SortOptions};
-use arrow2::util::bench_util::*;
+use re_arrow2::array::*;
+use re_arrow2::compute::sort::{lexsort, sort, sort_to_indices, SortColumn, SortOptions};
+use re_arrow2::util::bench_util::*;
 
 fn bench_lexsort(arr_a: &dyn Array, array_b: &dyn Array) {
     let columns = vec![

benches/take_kernels.rs

@@ -2,9 +2,9 @@ use rand::{rngs::StdRng, Rng, SeedableRng};
 
 use criterion::{criterion_group, criterion_main, Criterion};
 
-use arrow2::array::*;
-use arrow2::compute::take;
-use arrow2::util::bench_util::*;
+use re_arrow2::array::*;
+use re_arrow2::compute::take;
+use re_arrow2::util::bench_util::*;
 
 fn create_random_index(size: usize, null_density: f32) -> PrimitiveArray<i32> {
     let mut rng = StdRng::seed_from_u64(42);

benches/unset_count.rs

@@ -1,6 +1,6 @@
 use criterion::{criterion_group, criterion_main, Criterion};
 
-use arrow2::bitmap::utils::count_zeros;
+use re_arrow2::bitmap::utils::count_zeros;
 
 fn add_benchmark(c: &mut Criterion) {
     (10..=20).step_by(2).for_each(|log2_size| {