MCPcopy Create free account

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

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

↓ 1 callersMethodget
(&self, id: &str)
crates/connect/src/streaming/mod.rs:649
↓ 1 callersFunctionget_current_ref
()
dev/merge_connect_rust_pr.py:556
↓ 1 callersMethodget_database
Get the database with the specified name
crates/connect/src/catalog.rs:140
↓ 1 callersFunctionget_jira_issue
(prompt, default_jira_id="")
dev/merge_connect_rust_pr.py:278
↓ 1 callersMethodget_storage_level
(&self)
crates/connect/src/client/mod.rs:634
↓ 1 callersFunctionget_version_json
(version_str)
dev/merge_connect_rust_pr.py:375
↓ 1 callersFunctiongrant_contributor_role
(user: str)
dev/merge_connect_rust_pr.py:455
↓ 1 callersMethodhandle_analyze
( &mut self, resp: spark::AnalyzePlanResponse, )
crates/connect/src/client/mod.rs:445
↓ 1 callersMethodhandle_response
(&mut self, resp: spark::ExecutePlanResponse)
crates/connect/src/client/mod.rs:404
↓ 1 callersMethodheaders
(mut self, val: HashMap<String, String>)
crates/connect/src/client/config.rs:86
↓ 1 callersMethodid
(&self)
crates/connect/src/streaming/mod.rs:332
↓ 1 callersMethodilike
A SQL ILIKE filter expression that evaluates the column based on a case insensitive match
crates/connect/src/column.rs:302
↓ 1 callersFunctioninitialize_jira
()
dev/merge_connect_rust_pr.py:565
↓ 1 callersMethodinput_files
Returns a best-effort snapshot of the files that compose this [DataFrame]
crates/connect/src/dataframe.rs:602
↓ 1 callersMethodintersect
Return a new [DataFrame] containing rows only in both this [DataFrame] and another [DataFrame].
crates/connect/src/dataframe.rs:615
↓ 1 callersMethodjson
(&self)
crates/connect/src/types.rs:143
↓ 1 callersMethodlayer
(&self, inner: S)
crates/connect/src/client/middleware.rs:48
↓ 1 callersMethodlike
A SQL LIKE filter expression that evaluates the column based on a case sensitive match
crates/connect/src/column.rs:297
↓ 1 callersMethodlist_catalogs
Returns a list of catalogs in this session
crates/connect/src/catalog.rs:82
↓ 1 callersFunctionmain
()
dev/merge_connect_rust_pr.py:599
↓ 1 callersMethodmax
Computes the max value for each numeric columns for each group.
crates/connect/src/group.rs:96
↓ 1 callersFunctionmerge_pr
(pr_num, target_ref, title, body, pr_repo_desc)
dev/merge_connect_rust_pr.py:143
↓ 1 callersMethodor
Logical OR comparion.
crates/connect/src/column.rs:324
↓ 1 callersMethodpartition_by
Partitions the output by the given columns on the file system
crates/connect/src/streaming/mod.rs:187
↓ 1 callersMethodpersist
Sets the storage level to persist the contents of the [DataFrame] across operations after the first time it is computed.
crates/connect/src/dataframe.rs:759
↓ 1 callersMethodplan_id
(self)
crates/connect/src/plan.rs:66
↓ 1 callersMethodport
(mut self, val: Port)
crates/connect/src/client/config.rs:56
↓ 1 callersMethodprocess_all_available
(&self)
crates/connect/src/streaming/mod.rs:456
↓ 1 callersMethodproject
(self, cols: I)
crates/connect/src/plan.rs:567
↓ 1 callersMethodrandom_split
Randomly splits this [DataFrame] with the provided weights.
crates/connect/src/dataframe.rs:793
↓ 1 callersMethodrange_between
(self, start: i64, end: i64)
crates/connect/src/window.rs:79
↓ 1 callersMethodreattach_execute
(&mut self)
crates/connect/src/client/mod.rs:201
↓ 1 callersMethodrelease_until
(&mut self)
crates/connect/src/client/mod.rs:250
↓ 1 callersMethodrepartition
Returns a new [DataFrame] partitioned by the given partition number and shuffle option # Arguments `num_partitions`: the target number of partitions
crates/connect/src/dataframe.rs:840
↓ 1 callersFunctionreplace
( src: impl Into<Column>, search: impl Into<Column>, replace: Option<impl Into<Column>>, )
crates/connect/src/functions/mod.rs:1433
↓ 1 callersMethodreplace
Returns a new [DataFrame] replacing a value with another value.
crates/connect/src/dataframe.rs:863
↓ 1 callersMethodreplace
(self)
crates/connect/src/readwriter.rs:826
↓ 1 callersMethodrequest_options
(&self)
crates/connect/src/client/mod.rs:138
↓ 1 callersMethodreset_termination
(&self)
crates/connect/src/streaming/mod.rs:714
↓ 1 callersFunctionresolve_jira_issues
(title, merge_branches, comment)
dev/merge_connect_rust_pr.py:474
↓ 1 callersMethodrlike
A SQL RLIKE filter expression that evaluates the column based on a regex match
crates/connect/src/column.rs:307
↓ 1 callersMethodsample
Returns a sampled subset of this [DataFrame]
crates/connect/src/dataframe.rs:909
↓ 1 callersMethodsample_by
Returns a stratified sample without replacement based on the fraction given on each stratum.
crates/connect/src/dataframe.rs:927
↓ 1 callersMethodschema
(&self)
crates/connect/src/client/mod.rs:570
↓ 1 callersMethodselect_expr
Project a set of SQL expressions and returns a new [DataFrame] This is a variant of `select` that accepts SQL Expressions # Example: ```rust async {
crates/connect/src/dataframe.rs:991
↓ 1 callersFunctionserialize
(batch: &RecordBatch)
crates/connect/src/plan.rs:864
↓ 1 callersMethodset_configs
( &mut self, map: &HashMap<String, String>, )
crates/connect/src/conf.rs:50
↓ 1 callersMethodset_current_database
Sets the current default database in this session
crates/connect/src/catalog.rs:110
↓ 1 callersMethodspark_version
(&mut self)
crates/connect/src/client/mod.rs:609
↓ 1 callersFunctionstandardize_jira_ref
Standardize the [SPARK-XXXXX] [MODULE] prefix Converts "[SPARK-XXX][mllib] Issue", "[MLLib] SPARK-XXX. Issue" or "SPARK XXX [MLLIB]: Issue" t
dev/merge_connect_rust_pr.py:483
↓ 1 callersMethodstatus
( &self, )
crates/connect/src/streaming/mod.rs:560
↓ 1 callersMethodsubstr
(self, start_pos: impl Into<Column>, length: impl Into<Column>)
crates/connect/src/column.rs:215
↓ 1 callersMethodsubstract
(self, other: LogicalPlanBuilder)
crates/connect/src/plan.rs:415
↓ 1 callersFunctionsum_distinct
"Returns the sum of distinct values in the expression."
crates/connect/src/functions/mod.rs:1115
↓ 1 callersMethodsummary
Computes specified statistics for numeric and string columns. Available statistics are: - count - mean - stddev - min - max - arbitrary approximate pe
crates/connect/src/dataframe.rs:1118
↓ 1 callersMethodto_filter_expr
(&self)
crates/connect/src/expressions.rs:96
↓ 1 callersMethodto_polars
(self)
crates/connect/src/dataframe.rs:1203
↓ 1 callersMethodto_schema
(&self)
crates/connect/src/readwriter.rs:43
↓ 1 callersMethodtransform
Returns a new [DataFrame] based on a provided closure. # Example: ``` // the closure will capture this variable from the current scope let val = 100;
crates/connect/src/dataframe.rs:1231
↓ 1 callersMethodtree_string
(&self)
crates/connect/src/client/mod.rs:584
↓ 1 callersMethodtype_name
(&self)
crates/connect/src/types.rs:135
↓ 1 callersMethoduncache_table
Removes the specified table from the in-memory cache.
crates/connect/src/catalog.rs:427
↓ 1 callersMethodunion_all
Return a new [DataFrame] containing the union of rows in this and another [DataFrame].
crates/connect/src/dataframe.rs:1251
↓ 1 callersMethodunion_all
(self, other: LogicalPlanBuilder)
crates/connect/src/plan.rs:387
↓ 1 callersMethodunset
Resets the configuration property for the given key.
crates/connect/src/conf.rs:78
↓ 1 callersMethodusing
(mut self, provider: &str)
crates/connect/src/readwriter.rs:792
↓ 1 callersMethodversion
The version of Spark on which this application is running.
crates/connect/src/session.rs:290
↓ 1 callersMethodwith_columns_renamed
Returns a new [DataFrame] by renaming multiple columns from a an iterator of containing a key/value pair with the key as the `existing` column name an
crates/connect/src/dataframe.rs:1356
↓ 1 callersMethodwith_field
(self, field_name: &str, col: impl Into<Column>)
crates/connect/src/column.rs:201
↓ 1 callersMethodwith_metadata
Returns a new [DataFrame] by updating an existing column with metadata.
crates/connect/src/dataframe.rs:1371
↓ 1 callersMethodwrite_to
Create a write configuration builder for v2 sources with [DataFrameWriterV2].
crates/connect/src/dataframe.rs:1404
Methodadd_tag
(&mut self, tag: &str)
crates/connect/src/client/mod.rs:323
Functionaes_decrypt
Returns a decrypted value of *input* using AES in *mode* with *padding
crates/connect/src/functions/mod.rs:1538
Functionaes_encrypt
Returns a encrypted value of *input* using AES in *mode* with the specified *padding
crates/connect/src/functions/mod.rs:1573
Methodagg
Aggregate on the entire [DataFrame] without groups (shorthand for `df.group_by().agg()`)
crates/connect/src/dataframe.rs:125
Methodaggregate
( input: LogicalPlanBuilder, group_type: GroupType, grouping_cols: Vec<spark::Expressi
crates/connect/src/plan.rs:104
Functionany_value
Returns some value of col for a group of rows.
crates/connect/src/functions/mod.rs:918
Methodappend
(self)
crates/connect/src/readwriter.rs:834
Functionapprox_count_distinct
Returns a new Column for approximate distinct count of column col.
crates/connect/src/functions/mod.rs:926
Methodapprox_quantile
Calculates the approximate quantiles of numerical columns of a [DataFrame].
crates/connect/src/dataframe.rs:143
Methodapprox_quantile
( self, cols: I, probabilities: P, relative_error: f64, )
crates/connect/src/plan.rs:454
Functionarray_insert
adds an item into a given array at a specified array index.
crates/connect/src/functions/mod.rs:742
Functionarray_join
Concatenates the elements of column using the delimiter.
crates/connect/src/functions/mod.rs:705
Functionarray_sort
(col: impl Into<Column>, compactor: Option<impl Into<Column>>)
crates/connect/src/functions/mod.rs:737
Methodarrow_to_bool
(record: RecordBatch)
crates/connect/src/catalog.rs:42
Methodas_str_name
(&self)
crates/connect/src/types.rs:36
Functionasc_nulls_first
Returns a sort expression based on the ascending order of the given column name, and null values return before non-null values.
crates/connect/src/functions/mod.rs:1210
Functionasc_nulls_last
Returns a sort expression based on the ascending order of the given column name, and null values appear after non-null values.
crates/connect/src/functions/mod.rs:1215
Functionassert_true
Returns *null* if the input column is *true*; throws an exception with the provided error message otherwise
crates/connect/src/functions/mod.rs:1621
Methodawait_termination
(&self, timeout_ms: Option<i64>)
crates/connect/src/streaming/mod.rs:365
Methodbitand
(self, other: Self)
crates/connect/src/column.rs:494
Methodbitor
(self, other: Self)
crates/connect/src/column.rs:486
Functionbitwise_not
Computes bitwise not.
crates/connect/src/functions/mod.rs:154
Methodbitxor
(self, other: Self)
crates/connect/src/column.rs:502
Functionbroadcast
Marks a DataFrame as small enough for use in broadcast joins.
crates/connect/src/functions/mod.rs:112
Functionbround
Round the given value to scale decimal places using HALF_EVEN rounding mode if scale >= 0 or at integral part when scale < 0.
crates/connect/src/functions/mod.rs:244
Functionbtrim
Remove the leading and trailing *trim* characters from *str
crates/connect/src/functions/mod.rs:1241
Methodbucket_by
Buckets the output by the given columns. If specified, the output is laid out on the file system similar to Hive’s bucketing scheme.
crates/connect/src/readwriter.rs:617
Methodcall
( &mut self, mut request: Request<UnsyncBoxBody<prost::bytes::Bytes, tonic::Status>>, )
crates/connect/src/client/middleware.rs:88
Methodclear_cache
Removes all cached tables from the in-memory cache.
crates/connect/src/catalog.rs:440
← previousnext →201–300 of 681, ranked by callers