Functions — github.com/apache/spark-connect-rust

hub / github.com/apache/spark-connect-rust / functions

Functions681 in github.com/apache/spark-connect-rust

⨍ Functions 681◇ Types & classes 38

Functiontest_func_named_struct

()

crates/connect/src/functions/mod.rs:1859

Functiontest_func_or

()

crates/connect/src/functions/mod.rs:2354

Functiontest_func_over

()

crates/connect/src/functions/mod.rs:2546

Functiontest_func_rlike

()

crates/connect/src/functions/mod.rs:2281

Functiontest_func_startswith

()

crates/connect/src/functions/mod.rs:2185

Functiontest_func_substr

()

crates/connect/src/functions/mod.rs:2520

Functiontest_func_sum_distinct

()

crates/connect/src/functions/mod.rs:2588

Functiontest_func_uuid

()

crates/connect/src/functions/mod.rs:1923

Functiontest_function_exists

()

crates/connect/src/catalog.rs:615

Functiontest_get_database

()

crates/connect/src/catalog.rs:586

Functiontest_group_count

()

crates/connect/src/group.rs:161

Functiontest_group_pivot

()

crates/connect/src/group.rs:177

Functiontest_list_catalogs

()

crates/connect/src/catalog.rs:539

Functiontest_list_columns

()

crates/connect/src/catalog.rs:625

Functiontest_panic_incorrect_url_scheme

()

crates/connect/src/client/builder.rs:233

Functiontest_panic_missing_url_host

()

crates/connect/src/client/builder.rs:240

Functiontest_panic_missing_url_port

()

crates/connect/src/client/builder.rs:247

Functiontest_panic_ssl

()

crates/connect/src/client/builder.rs:268

Functiontest_read_stream

()

crates/connect/src/streaming/mod.rs:754

Functiontest_schema

()

crates/connect/src/types.rs:642

Functiontest_session_config

()

crates/connect/src/session.rs:425

Functiontest_session_tags

()

crates/connect/src/session.rs:372

Functiontest_session_tags_panic

()

crates/connect/src/session.rs:396

Functiontest_session_version

()

crates/connect/src/session.rs:409

Functiontest_set_current_catalog_panic

()

crates/connect/src/catalog.rs:528

Functiontest_set_current_database

()

crates/connect/src/catalog.rs:561

Functiontest_set_current_database_panic

()

crates/connect/src/catalog.rs:575

Functiontest_settings_builder

()

crates/connect/src/client/builder.rs:254

Functiontest_spark_create_dataframe

()

crates/connect/src/session.rs:346

Functiontest_spark_range

()

crates/connect/src/session.rs:334

Functiontest_spark_session_create

()

crates/connect/src/session.rs:362

Functiontest_stream_active

()

crates/connect/src/streaming/mod.rs:768

Functiontest_stream_explain

()

crates/connect/src/streaming/mod.rs:851

Functiontest_stream_manager_active

()

crates/connect/src/streaming/mod.rs:879

Functiontest_stream_manager_await_term

()

crates/connect/src/streaming/mod.rs:955

Functiontest_stream_manager_await_term_none

()

crates/connect/src/streaming/mod.rs:1004

Functiontest_stream_manager_get

()

crates/connect/src/streaming/mod.rs:926

Functiontest_stream_progress

()

crates/connect/src/streaming/mod.rs:822

Functiontest_stream_status

()

crates/connect/src/streaming/mod.rs:795

Functiontest_window_orderby

()

crates/connect/src/window.rs:313

Functiontest_window_over

()

crates/connect/src/window.rs:272

Functiontest_window_partitionby

()

crates/connect/src/window.rs:345

Functiontest_window_rangebetween

()

crates/connect/src/window.rs:377

Functiontest_window_rowsbetween

()

crates/connect/src/window.rs:411

Functionto_binary

(col: impl Into<Column>, len: Option<impl Into<Column>>)

crates/connect/src/functions/mod.rs:1505

Functionto_csv

Converts a column containing a StructType into a CSV string

crates/connect/src/functions/mod.rs:899

Functionto_date

Parses the timestamp with the format to a timestamp without time zone.

crates/connect/src/functions/mod.rs:627

Methodto_df

Returns a new [DataFrame] that with new specified column names

crates/connect/src/dataframe.rs:1156

Methodto_df

(self, cols: I)

crates/connect/src/plan.rs:338

Functionto_json

Converts a column containing a StructType into a JSON string

crates/connect/src/functions/mod.rs:806

Methodto_table

Start a streaming job to save the contents of the [StreamingQuery] to a table.

crates/connect/src/streaming/mod.rs:273

Functionto_timestamp

Converts a Column into pyspark.sql.types.TimestampType using the optionally specified format.

crates/connect/src/functions/mod.rs:604

Functionto_timestamp_ltz

Parses the timestamp with the format to a timestamp without time zone.

crates/connect/src/functions/mod.rs:612

Functionto_timestamp_ntz

Parses the timestamp with the format to a timestamp without time zone.

crates/connect/src/functions/mod.rs:620

Functionto_unix_timestamp

Returns the UNIX timestamp of the given time.

crates/connect/src/functions/mod.rs:595

Methodtoken

(mut self, val: &str)

crates/connect/src/client/config.rs:61

Functiontry_aes_decrypt

( input: impl Into<Column>, key: impl Into<Column>, mode: Option<impl Into<Column>>, padding:

crates/connect/src/functions/mod.rs:1555

Functiontry_to_binary

(col: impl Into<Column>, len: Option<impl Into<Column>>)

crates/connect/src/functions/mod.rs:1512

Functiontry_to_timestamp

(col: impl Into<Column>, format: Option<impl Into<Column>>)

crates/connect/src/functions/mod.rs:685

Methodtype_name

(&self)

crates/connect/src/types.rs:28

Methodunbounded_following

Returns [i64::MAX]

crates/connect/src/window.rs:153

Methodunbounded_preceding

Returns [i64::MIN]

crates/connect/src/window.rs:158

Methodunion

Return a new [DataFrame] containing the union of rows in this and another [DataFrame].

crates/connect/src/dataframe.rs:1239

Methodunion

(self, other: LogicalPlanBuilder)

crates/connect/src/plan.rs:397

Methodunion_by_name

Returns a new [DataFrame] containing union of rows in this and another [DataFrame].

crates/connect/src/dataframe.rs:1263

Methodunion_by_name

( self, other: LogicalPlanBuilder, allow_missing_columns: Option<bool>, )

crates/connect/src/plan.rs:401

Functionunix_timestamp

Convert time string with given pattern (‘yyyy-MM-dd HH:mm:ss’, by default) to Unix time stamp (in seconds), using the default timezone and the default

crates/connect/src/functions/mod.rs:579

Methodunpersist

Marks the [DataFrame] as non-persistent, and remove all blocks for it from memory and disk.

crates/connect/src/dataframe.rs:1275

Methodunpivot

( self, ids: Vec<spark::Expression>, values: Option<Vec<spark::Expression>>, v

crates/connect/src/plan.rs:137

Methoduse_ssl

(mut self, val: bool)

crates/connect/src/client/config.rs:81

Methoduser_agent

(mut self, val: &str)

crates/connect/src/client/config.rs:76

Methoduser_id

(mut self, val: &str)

crates/connect/src/client/config.rs:71

Functionwhen

Evaluates a list of conditions and returns one of multiple possible result expressions.

crates/connect/src/functions/mod.rs:149

Functionwidth_bucket

Returns the bucket number into which the value of this expression would fall after being evaluated.

crates/connect/src/functions/mod.rs:270

Functionwindow

Bucketize rows into one or moe time windows given a timestamp specifying column.

crates/connect/src/functions/mod.rs:639

Methodwindow_frame

(row_frame: bool, start: i64, end: i64)

crates/connect/src/window.rs:116

Methodwith_column_renamed

Returns a new [DataFrame] by renaming an existing column.

crates/connect/src/dataframe.rs:1345

Methodwith_columns

(self, col_map: I, metadata: Option<M>)

crates/connect/src/plan.rs:764

Methodwith_columns_renamed

(self, cols: I)

crates/connect/src/plan.rs:795

Methodwith_watermark

Defines an event time watermark for this [DataFrame].

crates/connect/src/dataframe.rs:1383

Methodwith_watermark

(self, event_time: T, delay_threshold: D)

crates/connect/src/plan.rs:814

← previous601–681 of 681, ranked by callers