Trait DataFrameExt 

pub trait DataFrameExt {
    // Required methods
    fn collect_async(
        &self,
    ) -> impl Future<Output = Result<Vec<Row>>> + Send + 'static;
    fn collect_record_batches_async(
        &self,
    ) -> impl Future<Output = Result<Vec<RecordBatch>>> + Send + 'static;
    fn count_async(&self) -> impl Future<Output = Result<i64>> + Send + 'static;
    fn show_async(
        &self,
        n: usize,
    ) -> impl Future<Output = Result<()>> + Send + 'static;
    fn first_async(
        &self,
    ) -> impl Future<Output = Result<Option<Row>>> + Send + 'static;
    fn head_async(
        &self,
    ) -> impl Future<Output = Result<Option<Row>>> + Send + 'static;
    fn take_async(
        &self,
        n: usize,
    ) -> impl Future<Output = Result<Vec<Row>>> + Send + 'static;
    fn is_empty_async(
        &self,
    ) -> impl Future<Output = Result<bool>> + Send + 'static;
    fn exists_async(
        &self,
    ) -> impl Future<Output = Result<bool>> + Send + 'static;
    fn scalar_async(
        &self,
    ) -> impl Future<Output = Result<Option<Value>>> + Send + 'static;
    fn schema_async(
        &self,
    ) -> impl Future<Output = Result<DataType>> + Send + 'static;
    fn columns_async(
        &self,
    ) -> impl Future<Output = Result<Vec<String>>> + Send + 'static;
    fn dtypes_async(
        &self,
    ) -> impl Future<Output = Result<Vec<(String, String)>>> + Send + 'static;
    fn print_schema_async(
        &self,
    ) -> impl Future<Output = Result<()>> + Send + 'static;
    fn explain_async(&self) -> impl Future<Output = Result<()>> + Send + 'static;
    fn explain_mode_async(
        &self,
        mode: &str,
    ) -> impl Future<Output = Result<()>> + Send + 'static;
    fn input_files_async(
        &self,
    ) -> impl Future<Output = Result<Vec<String>>> + Send + 'static;
    fn is_cached_async(
        &self,
    ) -> impl Future<Output = Result<bool>> + Send + 'static;
    fn cache_async(
        &self,
    ) -> impl Future<Output = Result<DataFrame>> + Send + 'static;
    fn persist_async(
        &self,
        storage_level: StorageLevel,
    ) -> impl Future<Output = Result<DataFrame>> + Send + 'static;
    fn unpersist_async(
        &self,
        blocking: bool,
    ) -> impl Future<Output = Result<DataFrame>> + Send + 'static;
    fn storage_level_async(
        &self,
    ) -> impl Future<Output = Result<StorageLevel>> + Send + 'static;
    fn checkpoint_async(
        &self,
    ) -> impl Future<Output = Result<DataFrame>> + Send + 'static;
    fn local_checkpoint_async(
        &self,
    ) -> impl Future<Output = Result<DataFrame>> + Send + 'static;
    fn semantic_hash_async(
        &self,
    ) -> impl Future<Output = Result<i32>> + Send + 'static;
    fn same_semantics_async(
        &self,
        other: &DataFrame,
    ) -> impl Future<Output = Result<bool>> + Send + 'static;
    fn create_temp_view_async(
        &self,
        name: &str,
    ) -> impl Future<Output = Result<()>> + Send + 'static;
    fn create_or_replace_temp_view_async(
        &self,
        name: &str,
    ) -> impl Future<Output = Result<()>> + Send + 'static;
    fn create_global_temp_view_async(
        &self,
        name: &str,
    ) -> impl Future<Output = Result<()>> + Send + 'static;
    fn create_or_replace_global_temp_view_async(
        &self,
        name: &str,
    ) -> impl Future<Output = Result<()>> + Send + 'static;
    fn register_temp_table_async(
        &self,
        name: &str,
    ) -> impl Future<Output = Result<()>> + Send + 'static;
    fn to_arrow_async(
        &self,
    ) -> impl Future<Output = Result<Vec<u8>>> + Send + 'static;
    fn to_json_async(
        &self,
    ) -> impl Future<Output = Result<Vec<String>>> + Send + 'static;
    fn foreach_async(
        &self,
        func: CommonInlineUserDefinedFunctionExpression,
    ) -> impl Future<Output = Result<()>> + Send + 'static;
    fn foreach_partition_async(
        &self,
        func: CommonInlineUserDefinedFunctionExpression,
    ) -> impl Future<Output = Result<()>> + Send + 'static;
}

Async actions on a DataFrame.

Required Methods

fn collect_async( &self, ) -> impl Future<Output = Result<Vec<Row>>> + Send + 'static

Async DataFrame::collect.

fn collect_record_batches_async( &self, ) -> impl Future<Output = Result<Vec<RecordBatch>>> + Send + 'static

Async DataFrame::collect_record_batches.

fn count_async(&self) -> impl Future<Output = Result<i64>> + Send + 'static

Async DataFrame::count.

fn show_async( &self, n: usize, ) -> impl Future<Output = Result<()>> + Send + 'static

Async DataFrame::show.

fn first_async( &self, ) -> impl Future<Output = Result<Option<Row>>> + Send + 'static

Async DataFrame::first.

fn head_async( &self, ) -> impl Future<Output = Result<Option<Row>>> + Send + 'static

Async DataFrame::head.

fn take_async( &self, n: usize, ) -> impl Future<Output = Result<Vec<Row>>> + Send + 'static

Async DataFrame::take.

fn is_empty_async(&self) -> impl Future<Output = Result<bool>> + Send + 'static

Async DataFrame::is_empty.

fn exists_async(&self) -> impl Future<Output = Result<bool>> + Send + 'static

Async DataFrame::exists.

fn scalar_async( &self, ) -> impl Future<Output = Result<Option<Value>>> + Send + 'static

Async DataFrame::scalar.

fn schema_async( &self, ) -> impl Future<Output = Result<DataType>> + Send + 'static

Async DataFrame::schema.

fn columns_async( &self, ) -> impl Future<Output = Result<Vec<String>>> + Send + 'static

Async DataFrame::columns.

fn dtypes_async( &self, ) -> impl Future<Output = Result<Vec<(String, String)>>> + Send + 'static

Async DataFrame::dtypes.

fn print_schema_async( &self, ) -> impl Future<Output = Result<()>> + Send + 'static

Async DataFrame::print_schema.

fn explain_async(&self) -> impl Future<Output = Result<()>> + Send + 'static

Async DataFrame::explain.

fn explain_mode_async( &self, mode: &str, ) -> impl Future<Output = Result<()>> + Send + 'static

Async DataFrame::explain_mode.

fn input_files_async( &self, ) -> impl Future<Output = Result<Vec<String>>> + Send + 'static

Async DataFrame::input_files.

fn is_cached_async(&self) -> impl Future<Output = Result<bool>> + Send + 'static

Async DataFrame::is_cached.

fn cache_async( &self, ) -> impl Future<Output = Result<DataFrame>> + Send + 'static

Async DataFrame::cache.

fn persist_async( &self, storage_level: StorageLevel, ) -> impl Future<Output = Result<DataFrame>> + Send + 'static

Async DataFrame::persist.

fn unpersist_async( &self, blocking: bool, ) -> impl Future<Output = Result<DataFrame>> + Send + 'static

Async DataFrame::unpersist.

fn storage_level_async( &self, ) -> impl Future<Output = Result<StorageLevel>> + Send + 'static

Async DataFrame::storage_level.

fn checkpoint_async( &self, ) -> impl Future<Output = Result<DataFrame>> + Send + 'static

Async DataFrame::checkpoint.

fn local_checkpoint_async( &self, ) -> impl Future<Output = Result<DataFrame>> + Send + 'static

Async DataFrame::local_checkpoint.

fn semantic_hash_async( &self, ) -> impl Future<Output = Result<i32>> + Send + 'static

Async DataFrame::semantic_hash.

fn same_semantics_async( &self, other: &DataFrame, ) -> impl Future<Output = Result<bool>> + Send + 'static

Async DataFrame::same_semantics.

fn create_temp_view_async( &self, name: &str, ) -> impl Future<Output = Result<()>> + Send + 'static

Async DataFrame::create_temp_view.

fn create_or_replace_temp_view_async( &self, name: &str, ) -> impl Future<Output = Result<()>> + Send + 'static

Async DataFrame::create_or_replace_temp_view.

fn create_global_temp_view_async( &self, name: &str, ) -> impl Future<Output = Result<()>> + Send + 'static

Async DataFrame::create_global_temp_view.

fn create_or_replace_global_temp_view_async( &self, name: &str, ) -> impl Future<Output = Result<()>> + Send + 'static

Async DataFrame::create_or_replace_global_temp_view.

fn register_temp_table_async( &self, name: &str, ) -> impl Future<Output = Result<()>> + Send + 'static

Async DataFrame::register_temp_table.

fn to_arrow_async( &self, ) -> impl Future<Output = Result<Vec<u8>>> + Send + 'static

Async DataFrame::to_arrow.

fn to_json_async( &self, ) -> impl Future<Output = Result<Vec<String>>> + Send + 'static

Async DataFrame::to_json.

fn foreach_async( &self, func: CommonInlineUserDefinedFunctionExpression, ) -> impl Future<Output = Result<()>> + Send + 'static

Async DataFrame::foreach.

fn foreach_partition_async( &self, func: CommonInlineUserDefinedFunctionExpression, ) -> impl Future<Output = Result<()>> + Send + 'static

Async DataFrame::foreach_partition.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl DataFrameExt for DataFrame