Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

refactor: remove unused code (#4742)

pull/24376/head
Marco Neumann 2022-05-31 13:36:02 +02:00 committed by GitHub
parent 5a95da7327
commit 988bd38e93
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 0 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
Cargo.lock generated
View File

@ -3505,7 +3505,6 @@ dependencies = [
"prost", "prost",
"schema", "schema",
"snafu", "snafu",
"tempfile",
"thiserror", "thiserror",
"thrift", "thrift",
"tokio", "tokio",

1
parquet_file/Cargo.toml
View File

@ -25,7 +25,6 @@ predicate = { path = "../predicate" }
prost = "0.10" prost = "0.10"
schema = { path = "../schema" } schema = { path = "../schema" }
snafu = "0.7" snafu = "0.7"
tempfile = "3.1.0"
thrift = "0.13" thrift = "0.13"
tokio = { version = "1.18", features = ["macros", "parking_lot", "rt", "rt-multi-thread", "sync"] } tokio = { version = "1.18", features = ["macros", "parking_lot", "rt", "rt-multi-thread", "sync"] }
uuid = { version = "0.8", features = ["v4"] } uuid = { version = "0.8", features = ["v4"] }

9
parquet_file/src/storage.rs
View File

@ -49,11 +49,6 @@ pub enum UploadError {
/// Errors during Parquet file download & scan. /// Errors during Parquet file download & scan.
#[derive(Debug, Error)] #[derive(Debug, Error)]
pub enum ReadError { pub enum ReadError {
/// Failed to create the temporary Parquet file on disk to which the
/// downloaded parquet bytes will be spilled.
#[error("failed to create temporary file: {0}")]
TempFile(std::io::Error),
/// Error writing the bytes fetched from object store to the temporary /// Error writing the bytes fetched from object store to the temporary
/// parquet file on disk. /// parquet file on disk.
#[error("i/o error writing downloaded parquet: {0}")] #[error("i/o error writing downloaded parquet: {0}")]
@ -66,10 +61,6 @@ pub enum ReadError {
/// An error reading the downloaded Parquet file. /// An error reading the downloaded Parquet file.
#[error("invalid parquet file: {0}")] #[error("invalid parquet file: {0}")]
Parquet(#[from] parquet::errors::ParquetError), Parquet(#[from] parquet::errors::ParquetError),
/// Cannot poll arrow blocking wrapper
#[error("cannot poll arrow blocking wrapper: {0}")]
Poll(#[from] tokio::sync::oneshot::error::RecvError),
} }
/// The [`ParquetStorage`] type encapsulates [`RecordBatch`] persistence to an /// The [`ParquetStorage`] type encapsulates [`RecordBatch`] persistence to an