Struct PyDataframeQueryView

pub struct PyDataframeQueryView {
    dataset: Py<PyDataset>,
    query_expression: QueryExpression,
    partition_ids: Vec<String>,
}

View into a remote dataset acting as DataFusion table provider.

Fields

dataset: Py<PyDataset>

query_expression: QueryExpression

partition_ids: Vec<String>

Limit the query to these partition ids.

If empty, use the whole dataset.

Implementations

impl PyDataframeQueryView

pub fn new( dataset: Py<PyDataset>, index: String, contents: Py<PyAny>, include_semantically_empty_columns: bool, include_indicator_columns: bool, include_tombstone_columns: bool, py: Python<'_>, ) -> PyResult<Self>

fn clone_with_new_query( &self, py: Python<'_>, mutation_fn: impl FnOnce(&mut QueryExpression), ) -> Self

impl PyDataframeQueryView

fn filter_partition_id<'py>( &self, py: Python<'py>, partition_id: String, args: &Bound<'py, PyTuple>, ) -> PyResult<Self>

Filter by one or more partition ids. All partition ids are included if not specified.

fn filter_range_sequence( &self, py: Python<'_>, start: i64, end: i64, ) -> PyResult<Self>

Filter the view to only include data between the given index sequence numbers.

This range is inclusive and will contain both the value at the start and the value at the end.

The view must be of a sequential index type to use this method.

Parameters

start : int The inclusive start of the range. end : int The inclusive end of the range.

Returns

RecordingView A new view containing only the data within the specified range.

The original view will not be modified.

fn filter_range_secs( &self, py: Python<'_>, start: f64, end: f64, ) -> PyResult<Self>

Filter the view to only include data between the given index values expressed as seconds.

This range is inclusive and will contain both the value at the start and the value at the end.

The view must be of a temporal index type to use this method.

Parameters

start : int The inclusive start of the range. end : int The inclusive end of the range.

Returns

RecordingView A new view containing only the data within the specified range.

The original view will not be modified.

fn filter_range_nanos( &self, py: Python<'_>, start: i64, end: i64, ) -> PyResult<Self>

Filter the view to only include data between the given index values expressed as nanoseconds.

This range is inclusive and will contain both the value at the start and the value at the end.

The view must be of a temporal index type to use this method.

Parameters

start : int The inclusive start of the range. end : int The inclusive end of the range.

Returns

RecordingView A new view containing only the data within the specified range.

The original view will not be modified.

fn filter_index_values( &self, py: Python<'_>, values: IndexValuesLike<'_>, ) -> PyResult<Self>

Filter the view to only include data at the provided index values.

The index values returned will be the intersection between the provided values and the original index values.

This requires index values to be a precise match. Index values in Rerun are represented as i64 sequence counts or nanoseconds. This API does not expose an interface in floating point seconds, as the numerical conversion would risk false mismatches.

Parameters

values : IndexValuesLike The index values to filter by.

Returns

RecordingView A new view containing only the data at the specified index values.

The original view will not be modified.

fn filter_is_not_null( &self, py: Python<'_>, column: AnyComponentColumn, ) -> PyResult<Self>

Filter the view to only include rows where the given component column is not null.

This corresponds to rows for index values where this component was provided to Rerun explicitly via .log() or .send_columns().

Parameters

column : AnyComponentColumn The component column to filter by.

Returns

RecordingView A new view containing only the data where the specified component column is not null.

The original view will not be modified.

fn using_index_values( &self, py: Python<'_>, values: IndexValuesLike<'_>, ) -> PyResult<Self>

Replace the index in the view with the provided values.

The output view will always have the same number of rows as the provided values, even if those rows are empty. Use with [.fill_latest_at()][rerun.dataframe.RecordingView.fill_latest_at] to populate these rows with the most recent data.

This requires index values to be a precise match. Index values in Rerun are represented as i64 sequence counts or nanoseconds. This API does not expose an interface in floating point seconds, as the numerical conversion would risk false mismatches.

Parameters

values : IndexValuesLike The index values to use.

Returns

RecordingView A new view containing the provided index values.

The original view will not be modified.

fn fill_latest_at(&self, py: Python<'_>) -> Self

Populate any null values in a row with the latest valid data according to the index.

Returns

RecordingView A new view with the null values filled in.

The original view will not be modified.

fn __datafusion_table_provider__<'py>( self_: PyRef<'py, Self>, py: Python<'py>, ) -> PyResult<Bound<'py, PyCapsule>>

Returns a DataFusion table provider capsule.

fn df(self_: PyRef<'_, Self>) -> PyResult<Bound<'_, PyAny>>

Register this view to the global DataFusion context and return a DataFrame.

Trait Implementations

impl IntoPy<Py<PyAny>> for PyDataframeQueryView

fn into_py(self, py: Python<'_>) -> PyObject

👎Deprecated since 0.23.0: IntoPy is going to be replaced by IntoPyObject. See the migration guide (https://pyo3.rs/v0.23.0/migration) for more information.

Performs the conversion.

impl<'py> IntoPyObject<'py> for PyDataframeQueryView

type Target = PyDataframeQueryView

The Python output type

type Output = Bound<'py, <PyDataframeQueryView as IntoPyObject<'py>>::Target>

The smart pointer type to use.

type Error = PyErr

The type returned in the event of a conversion error.

fn into_pyobject( self, py: Python<'py>, ) -> Result<<Self as IntoPyObject<'_>>::Output, <Self as IntoPyObject<'_>>::Error>

Performs the conversion.

impl PyClass for PyDataframeQueryView

type Frozen = False

Whether the pyclass is frozen.

impl PyClassImpl for PyDataframeQueryView

const IS_BASETYPE: bool = false

#[pyclass(subclass)]

const IS_SUBCLASS: bool = false

#[pyclass(extends=…)]

const IS_MAPPING: bool = false

#[pyclass(mapping)]

const IS_SEQUENCE: bool = false

#[pyclass(sequence)]

type BaseType = PyAny

Base class

type ThreadChecker = SendablePyClass<PyDataframeQueryView>

This handles following two situations:

type PyClassMutability = <<PyAny as PyClassBaseType>::PyClassMutability as PyClassMutability>::MutableChild

Immutable or mutable

type Dict = PyClassDummySlot

Specify this class has #[pyclass(dict)] or not.

type WeakRef = PyClassDummySlot

Specify this class has #[pyclass(weakref)] or not.

type BaseNativeType = PyAny

The closest native ancestor. This is PyAny by default, and when you declare #[pyclass(extends=PyDict)], it’s PyDict.

fn items_iter() -> PyClassItemsIter

fn doc(py: Python<'_>) -> PyResult<&'static CStr>

Rendered class doc

fn lazy_type_object() -> &'static LazyTypeObject<Self>

fn dict_offset() -> Option<isize>

fn weaklist_offset() -> Option<isize>

impl<'a, 'py> PyFunctionArgument<'a, 'py> for &'a PyDataframeQueryView

type Holder = Option<PyRef<'py, PyDataframeQueryView>>

fn extract( obj: &'a Bound<'py, PyAny>, holder: &'a mut Self::Holder, ) -> PyResult<Self>

impl<'a, 'py> PyFunctionArgument<'a, 'py> for &'a mut PyDataframeQueryView

type Holder = Option<PyRefMut<'py, PyDataframeQueryView>>

fn extract( obj: &'a Bound<'py, PyAny>, holder: &'a mut Self::Holder, ) -> PyResult<Self>

impl PyMethods<PyDataframeQueryView> for PyClassImplCollector<PyDataframeQueryView>

fn py_methods(self) -> &'static PyClassItems

impl PyTypeInfo for PyDataframeQueryView

const NAME: &'static str = "DataframeQueryView"

Class name.

const MODULE: Option<&'static str> = ::core::option::Option::None

Module name, if any.

fn type_object_raw(py: Python<'_>) -> *mut PyTypeObject

Returns the PyTypeObject instance for this type.

fn type_object(py: Python<'_>) -> Bound<'_, PyType>

Returns the safe abstraction over the type object.

fn type_object_bound(py: Python<'_>) -> Bound<'_, PyType>

👎Deprecated since 0.23.0: renamed to PyTypeInfo::type_object

Deprecated name for [PyTypeInfo::type_object].

fn is_type_of(object: &Bound<'_, PyAny>) -> bool

Checks if object is an instance of this type or a subclass of this type.

fn is_type_of_bound(object: &Bound<'_, PyAny>) -> bool

👎Deprecated since 0.23.0: renamed to PyTypeInfo::is_type_of

Deprecated name for [PyTypeInfo::is_type_of].

fn is_exact_type_of(object: &Bound<'_, PyAny>) -> bool

Checks if object is an instance of this type.

fn is_exact_type_of_bound(object: &Bound<'_, PyAny>) -> bool

👎Deprecated since 0.23.0: renamed to PyTypeInfo::is_exact_type_of

Deprecated name for [PyTypeInfo::is_exact_type_of].

impl DerefToPyAny for PyDataframeQueryView