Skip to content

Commit

Permalink
Fix crate name usages
Browse files Browse the repository at this point in the history
  • Loading branch information
Jefffrey committed Apr 2, 2024
1 parent 1ff6b32 commit 21debc0
Show file tree
Hide file tree
Showing 6 changed files with 9 additions and 9 deletions.
2 changes: 1 addition & 1 deletion benches/arrow_reader.rs
Original file line number Diff line number Diff line change
Expand Up @@ -18,8 +18,8 @@
use std::fs::File;

use criterion::{criterion_group, criterion_main, Criterion};
use datafusion_orc::arrow_reader::ArrowReaderBuilder;
use futures_util::TryStreamExt;
use orc_rust::arrow_reader::ArrowReaderBuilder;

fn basic_path(path: &str) -> String {
let dir = env!("CARGO_MANIFEST_DIR");
Expand Down
2 changes: 1 addition & 1 deletion examples/datafusion_integration.rs
Original file line number Diff line number Diff line change
Expand Up @@ -21,8 +21,8 @@ use datafusion::physical_plan::{
};
use datafusion::prelude::*;
use datafusion_expr::{Expr, LogicalPlanBuilder};
use datafusion_orc::ArrowReaderBuilder;
use datafusion_physical_expr::PhysicalSortExpr;
use orc_rust::ArrowReaderBuilder;

use async_trait::async_trait;
use futures_util::StreamExt;
Expand Down
2 changes: 1 addition & 1 deletion src/bin/orc-metadata.rs
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
use std::{error::Error, fs::File, path::PathBuf, sync::Arc};

use clap::Parser;
use datafusion_orc::{reader::metadata::read_metadata, stripe::Stripe};
use orc_rust::{reader::metadata::read_metadata, stripe::Stripe};

#[derive(Parser)]
#[command(version, about, long_about = None)]
Expand Down
2 changes: 1 addition & 1 deletion src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
//!
//! ```no_run
//! # use std::fs::File;
//! # use datafusion_orc::arrow_reader::{ArrowReader, ArrowReaderBuilder};
//! # use orc_rust::arrow_reader::{ArrowReader, ArrowReaderBuilder};
//! let file = File::open("/path/to/file.orc").unwrap();
//! let reader = ArrowReaderBuilder::try_new(file).unwrap().build();
//! let record_batches = reader.collect::<Result<Vec<_>, _>>().unwrap();
Expand Down
8 changes: 4 additions & 4 deletions tests/basic/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -4,12 +4,12 @@ use std::sync::Arc;
use arrow::datatypes::{DataType, Field, Schema, TimeUnit};
use arrow::record_batch::{RecordBatch, RecordBatchReader};
use arrow::util::pretty;
use datafusion_orc::arrow_reader::{ArrowReader, ArrowReaderBuilder};
#[cfg(feature = "async")]
use datafusion_orc::async_arrow_reader::ArrowStreamReader;
use datafusion_orc::projection::ProjectionMask;
#[cfg(feature = "async")]
use futures_util::TryStreamExt;
use orc_rust::arrow_reader::{ArrowReader, ArrowReaderBuilder};
#[cfg(feature = "async")]
use orc_rust::async_arrow_reader::ArrowStreamReader;
use orc_rust::projection::ProjectionMask;

use crate::misc::{LONG_BOOL_EXPECTED, LONG_STRING_DICT_EXPECTED, LONG_STRING_EXPECTED};

Expand Down
2 changes: 1 addition & 1 deletion tests/integration/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ use arrow::{
};
use pretty_assertions::assert_eq;

use datafusion_orc::arrow_reader::ArrowReaderBuilder;
use orc_rust::arrow_reader::ArrowReaderBuilder;

fn read_orc_file(name: &str) -> RecordBatch {
let path = format!(
Expand Down

0 comments on commit 21debc0

Please sign in to comment.