Struct GenericSeriesState 

pub struct GenericSeriesState<T>
where
    T: SeriesValue,
{
    schema: Arc<Schema>,
    start: T,
    end: T,
    step: <T as SeriesValue>::StepType,
    batch_size: usize,
    current: T,
    include_end: bool,
    name: &'static str,
}

Fields

schema: Arc<Schema>

start: T

end: T

step: <T as SeriesValue>::StepType

batch_size: usize

current: T

include_end: bool

name: &'static str

Implementations

impl<T> GenericSeriesState<T>

where T: SeriesValue,

pub fn name(&self) -> &'static str

pub fn batch_size(&self) -> usize

pub fn include_end(&self) -> bool

pub fn start(&self) -> &T

pub fn end(&self) -> &T

pub fn step(&self) -> &<T as SeriesValue>::StepType

pub fn current(&self) -> &T

Trait Implementations

impl<T> Clone for GenericSeriesState<T>

where T: Clone + SeriesValue, <T as SeriesValue>::StepType: Clone,

fn clone(&self) -> GenericSeriesState<T>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> Debug for GenericSeriesState<T>

where T: Debug + SeriesValue, <T as SeriesValue>::StepType: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<T> Display for GenericSeriesState<T>

where T: SeriesValue,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<T> LazyBatchGenerator for GenericSeriesState<T>

where T: SeriesValue,

fn as_any(&self) -> &(dyn Any + 'static)

Returns the generator as Any so that it can be downcast to a specific implementation.

fn generate_next_batch( &mut self, ) -> Result<Option<RecordBatch>, DataFusionError>

Generate the next batch, return None when no more batches are available

fn boundedness(&self) -> Boundedness