use std::any::Any;
use std::fmt;
use crate::array::{Array, ArrayData};
use crate::datatypes::*;
pub struct NullArray {
data: ArrayData,
}
impl NullArray {
pub fn new(length: usize) -> Self {
let array_data = ArrayData::builder(DataType::Null).len(length);
let array_data = unsafe { array_data.build_unchecked() };
NullArray::from(array_data)
}
}
impl Array for NullArray {
fn as_any(&self) -> &dyn Any {
self
}
fn data(&self) -> &ArrayData {
&self.data
}
fn into_data(self) -> ArrayData {
self.into()
}
fn is_null(&self, _index: usize) -> bool {
true
}
fn is_valid(&self, _index: usize) -> bool {
false
}
fn null_count(&self) -> usize {
self.data_ref().len()
}
}
impl From<ArrayData> for NullArray {
fn from(data: ArrayData) -> Self {
assert_eq!(
data.data_type(),
&DataType::Null,
"NullArray data type should be Null"
);
assert_eq!(
data.buffers().len(),
0,
"NullArray data should contain 0 buffers"
);
assert!(
data.null_buffer().is_none(),
"NullArray data should not contain a null buffer, as no buffers are required"
);
Self { data }
}
}
impl From<NullArray> for ArrayData {
fn from(array: NullArray) -> Self {
array.data
}
}
impl fmt::Debug for NullArray {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
write!(f, "NullArray({})", self.len())
}
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn test_null_array() {
let null_arr = NullArray::new(32);
assert_eq!(null_arr.len(), 32);
assert_eq!(null_arr.null_count(), 32);
assert!(!null_arr.is_valid(0));
}
#[test]
fn test_null_array_slice() {
let array1 = NullArray::new(32);
let array2 = array1.slice(8, 16);
assert_eq!(array2.len(), 16);
assert_eq!(array2.null_count(), 16);
assert_eq!(array2.offset(), 8);
}
#[test]
fn test_debug_null_array() {
let array = NullArray::new(1024 * 1024);
assert_eq!(format!("{:?}", array), "NullArray(1048576)");
}
}