Skip to content

Commit

Permalink
ARROW-8124: [Rust] Update library dependencies
Browse files Browse the repository at this point in the history
- Update rust dependencies to latest

I tried to update sqlparser but it was quite a substantial change so I left it at the current version for now

Closes #6626 from bryantbiggs/chore/update-dependencies

Authored-by: Bryant Biggs <bryantbiggs@gmail.com>
Signed-off-by: Andy Grove <andygrove73@gmail.com>
  • Loading branch information
bryantbiggs authored and andygrove committed Mar 16, 2020
1 parent ab21f0e commit 368037f
Show file tree
Hide file tree
Showing 12 changed files with 47 additions and 47 deletions.
6 changes: 3 additions & 3 deletions rust/arrow-flight/Cargo.toml
Expand Up @@ -26,15 +26,15 @@ repository = "https://github.com/apache/arrow"
license = "Apache-2.0"

[dependencies]
tonic = "0.1.0"
bytes = "0.4"
tonic = "0.1"
bytes = "0.5"
prost = "0.6"
prost-derive = "0.6"
tokio = {version = "0.2", features = ["macros"]}
futures = { version = "0.3", default-features = false, features = ["alloc"]}

[build-dependencies]
tonic-build = "0.1.0"
tonic-build = "0.1"

[lib]
name = "flight"
Expand Down
22 changes: 11 additions & 11 deletions rust/arrow/Cargo.toml
Expand Up @@ -37,18 +37,18 @@ path = "src/lib.rs"

[dependencies]
libc = "0.2"
serde = { version = "1.0.80", features = ["rc"] }
serde_derive = "1.0.80"
serde_json = { version = "1.0.13", features = ["preserve_order"] }
indexmap = "1.0"
rand = "0.6"
csv = "1.0"
serde = { version = "1.0", features = ["rc"] }
serde_derive = "1.0"
serde_json = { version = "1.0", features = ["preserve_order"] }
indexmap = "1.3"
rand = "0.7"
csv = "1.1"
num = "0.2"
regex = "1.1"
lazy_static = "1.2"
packed_simd = { version = "0.3.1", optional = true }
regex = "1.3"
lazy_static = "1.4"
packed_simd = { version = "0.3", optional = true }
chrono = "0.4"
flatbuffers = "0.6.0"
flatbuffers = "0.6"
hex = "0.4"
arrow-flight = { path = "../arrow-flight", optional = true }

Expand All @@ -58,7 +58,7 @@ flight = ["arrow-flight"]
default = ["simd", "flight"]

[dev-dependencies]
criterion = "0.2"
criterion = "0.3"
lazy_static = "1"
flate2 = "1"

Expand Down
4 changes: 2 additions & 2 deletions rust/arrow/benches/builder.rs
Expand Up @@ -45,7 +45,7 @@ fn bench_primitive(c: &mut Criterion) {
})
})
.throughput(Throughput::Bytes(
(data.len() * NUM_BATCHES * size_of::<i64>()) as u32,
((data.len() * NUM_BATCHES * size_of::<i64>()) as u32).into(),
)),
);
}
Expand All @@ -68,7 +68,7 @@ fn bench_bool(c: &mut Criterion) {
})
})
.throughput(Throughput::Bytes(
(data_len * NUM_BATCHES * size_of::<bool>()) as u32,
((data_len * NUM_BATCHES * size_of::<bool>()) as u32).into(),
)),
);
}
Expand Down
18 changes: 9 additions & 9 deletions rust/datafusion/Cargo.toml
Expand Up @@ -44,24 +44,24 @@ default = ["cli"]
cli = ["rustyline"]

[dependencies]
fnv = "1.0.3"
fnv = "1.0"
arrow = { path = "../arrow", version = "1.0.0-SNAPSHOT" }
parquet = { path = "../parquet", version = "1.0.0-SNAPSHOT" }
sqlparser = "0.2.0"
clap = "2.33.0"
sqlparser = "0.2"
clap = "2.33"
prettytable-rs = "0.8.0"
rustyline = {version = "4.1.0", optional = true}
crossbeam = "0.7.1"
paste = "0.1.6"
rustyline = {version = "6.0", optional = true}
crossbeam = "0.7"
paste = "0.1"

[dev-dependencies]
criterion = "0.2.0"
tempdir = "0.3.7"
criterion = "0.3"
tempdir = "0.3"
futures = "0.3"
prost = "0.6"
tokio = { version = "0.2", features = ["macros"] }
tonic = "0.1"
flatbuffers = "0.6.0"
flatbuffers = "0.6"
arrow-flight = { path = "../arrow-flight", version = "1.0.0-SNAPSHOT" }

[[bench]]
Expand Down
12 changes: 6 additions & 6 deletions rust/parquet/Cargo.toml
Expand Up @@ -33,16 +33,16 @@ parquet-format = "~2.6"
quick-error = "1.2"
byteorder = "1"
thrift = "0.12"
snap = "0.2"
brotli = "2.5"
flate2 = "1.0.2"
snap = "1.0"
brotli = "3.3"
flate2 = "1.0"
lz4 = "1.23"
zstd = "0.4"
zstd = "0.5"
chrono = "0.4"
num-bigint = "0.2"
arrow = { path = "../arrow", version = "1.0.0-SNAPSHOT" }
serde_json = { version = "1.0.13", features = ["preserve_order"] }
serde_json = { version = "1.0", features = ["preserve_order"] }

[dev-dependencies]
lazy_static = "1"
rand = "0.5"
rand = "0.6"
4 changes: 2 additions & 2 deletions rust/parquet/src/arrow/array_reader.rs
Expand Up @@ -964,7 +964,7 @@ mod tests {
DataType as ArrowType, Field, Int32Type as ArrowInt32, UInt32Type as ArrowUInt32,
UInt64Type as ArrowUInt64,
};
use rand::distributions::range::SampleRange;
use rand::distributions::uniform::SampleUniform;
use std::any::Any;
use std::collections::VecDeque;
use std::rc::Rc;
Expand All @@ -983,7 +983,7 @@ mod tests {
use_v2: bool,
num_chuncks: usize,
) where
T::T: PartialOrd + SampleRange + Copy,
T::T: PartialOrd + SampleUniform + Copy,
{
for _i in 0..num_chuncks {
let mut pages = VecDeque::new();
Expand Down
6 changes: 3 additions & 3 deletions rust/parquet/src/column/reader.rs
Expand Up @@ -506,7 +506,7 @@ impl<T: DataType> ColumnReaderImpl<T> {
mod tests {
use super::*;

use rand::distributions::range::SampleRange;
use rand::distributions::uniform::SampleUniform;
use std::{collections::VecDeque, rc::Rc, vec::IntoIter};

use crate::basic::Type as PhysicalType;
Expand Down Expand Up @@ -1102,7 +1102,7 @@ mod tests {

struct ColumnReaderTester<T: DataType>
where
T::T: PartialOrd + SampleRange + Copy,
T::T: PartialOrd + SampleUniform + Copy,
{
rep_levels: Vec<i16>,
def_levels: Vec<i16>,
Expand All @@ -1111,7 +1111,7 @@ mod tests {

impl<T: DataType> ColumnReaderTester<T>
where
T::T: PartialOrd + SampleRange + Copy,
T::T: PartialOrd + SampleUniform + Copy,
{
pub fn new() -> Self {
Self {
Expand Down
4 changes: 2 additions & 2 deletions rust/parquet/src/column/writer.rs
Expand Up @@ -848,7 +848,7 @@ impl EncodingWriteSupport for ColumnWriterImpl<FixedLenByteArrayType> {
mod tests {
use super::*;

use rand::distributions::range::SampleRange;
use rand::distributions::uniform::SampleUniform;

use crate::column::{
page::PageReader,
Expand Down Expand Up @@ -1464,7 +1464,7 @@ mod tests {
max_def_level: i16,
max_rep_level: i16,
) where
T::T: PartialOrd + SampleRange + Copy,
T::T: PartialOrd + SampleUniform + Copy,
{
let mut num_values: usize = 0;

Expand Down
2 changes: 1 addition & 1 deletion rust/parquet/src/compression.rs
Expand Up @@ -45,7 +45,7 @@ use std::io::{self, Read, Write};
use brotli;
use flate2::{read, write, Compression};
use lz4;
use snap::{decompress_len, max_compress_len, Decoder, Encoder};
use snap::raw::{decompress_len, max_compress_len, Decoder, Encoder};
use zstd;

use crate::basic::Compression as CodecType;
Expand Down
4 changes: 2 additions & 2 deletions rust/parquet/src/encodings/rle.rs
Expand Up @@ -836,11 +836,11 @@ mod tests {
Standard.sample_iter(&mut rng).take(seed_len).collect();
let mut seed = [0u8; 32];
seed.copy_from_slice(&seed_vec[0..seed_len]);
let mut gen = rand::StdRng::from_seed(seed);
let mut gen = rand::rngs::StdRng::from_seed(seed);

let mut parity = false;
for _ in 0..ngroups {
let mut group_size = gen.gen_range::<u32>(1, 20);
let mut group_size = gen.gen_range(1, 20);
if group_size > max_group_size {
group_size = 1;
}
Expand Down
4 changes: 2 additions & 2 deletions rust/parquet/src/util/test_common/page_util.rs
Expand Up @@ -28,7 +28,7 @@ use crate::util::memory::ByteBufferPtr;
use crate::util::memory::MemTracker;
use crate::util::memory::MemTrackerPtr;
use crate::util::test_common::random_numbers_range;
use rand::distributions::range::SampleRange;
use rand::distributions::uniform::SampleUniform;
use std::collections::VecDeque;
use std::mem;
use std::rc::Rc;
Expand Down Expand Up @@ -239,7 +239,7 @@ pub fn make_pages<T: DataType>(
pages: &mut VecDeque<Page>,
use_v2: bool,
) where
T::T: PartialOrd + SampleRange + Copy,
T::T: PartialOrd + SampleUniform + Copy,
{
let mut num_values = 0;
let max_def_level = desc.max_def_level();
Expand Down
8 changes: 4 additions & 4 deletions rust/parquet/src/util/test_common/rand_gen.rs
Expand Up @@ -16,7 +16,7 @@
// under the License.

use rand::{
distributions::{range::SampleRange, Distribution, Standard},
distributions::{uniform::SampleUniform, Distribution, Standard},
thread_rng, Rng,
};

Expand Down Expand Up @@ -86,7 +86,7 @@ impl RandGen<ByteArrayType> for ByteArrayType {
let mut rng = thread_rng();
let mut result = ByteArray::new();
let mut value = vec![];
let len = rng.gen_range::<usize>(0, 128);
let len = rng.gen_range(0, 128);
for _ in 0..len {
value.push(rng.gen_range(0, 255) & 0xFF);
}
Expand All @@ -99,7 +99,7 @@ impl RandGen<FixedLenByteArrayType> for FixedLenByteArrayType {
fn gen(len: i32) -> ByteArray {
let mut rng = thread_rng();
let value_len = if len < 0 {
rng.gen_range::<usize>(0, 128)
rng.gen_range(0, 128)
} else {
len as usize
};
Expand Down Expand Up @@ -136,7 +136,7 @@ where

pub fn random_numbers_range<T>(n: usize, low: T, high: T, result: &mut Vec<T>)
where
T: PartialOrd + SampleRange + Copy,
T: PartialOrd + SampleUniform + Copy,
{
let mut rng = thread_rng();
for _ in 0..n {
Expand Down

0 comments on commit 368037f

Please sign in to comment.