refactor: address PR feedback

pull/24376/head
Edd Robinson 2020-11-06 17:28:27 +00:00
parent 9847b68a9f
commit ab458b5f17
4 changed files with 10 additions and 5 deletions

1
Cargo.lock generated
View File

@ -731,6 +731,7 @@ dependencies = [
"arrow_deps",
"criterion",
"croaring",
"data_types",
"packers",
"rand",
]

View File

@ -9,6 +9,7 @@ edition = "2018"
[dependencies]
arrow_deps = { path = "../arrow_deps" }
data_types = { path = "../data_types" }
packers = { path = "../packers" }
croaring = "0.4.5"

View File

@ -3063,9 +3063,9 @@ mod test {
);
match row_ids {
RowIDsOption::None(_) => panic!("expected some rows"),
RowIDsOption::Some(_dst) => {
assert_eq!(_dst.to_vec(), vec![0]);
dst_buffer = _dst;
RowIDsOption::Some(dst) => {
assert_eq!(dst.to_vec(), vec![0]);
dst_buffer = dst;
}
RowIDsOption::All(_) => panic!("expected some rows"),
}

View File

@ -5,7 +5,8 @@ use arrow_deps::arrow::datatypes::SchemaRef;
use crate::column::{cmp::Operator, Column, RowIDs, RowIDsOption, Scalar, Value, Values};
/// The name used for a timestamp column.
pub const TIME_COLUMN_NAME: &str = "time";
pub const TIME_COLUMN_NAME: &str = data_types::TIME_COLUMN_NAME;
#[derive(Debug)]
pub struct Schema {
schema_ref: SchemaRef,
@ -255,7 +256,9 @@ impl<'a> Segment<'a> {
let col = self.all_columns.get(*col_name).unwrap();
// Explanation of how this buffer pattern works here. The idea is
// that the
// that the buffer should be returned to the caller so it can be
// re-used on other columns. To do that we need to hand the buffer
// back even if we haven't populated it with any results.
match col.row_ids_filter(op, value, dst) {
// No rows will be returned for the segment because this column
// doe not match any rows.