Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/apache/spark-connect-rust
/ functions
Functions
681 in github.com/apache/spark-connect-rust
⨍
Functions
681
◇
Types & classes
38
↓ 1 callers
Method
get
(&self, id: &str)
crates/connect/src/streaming/mod.rs:649
↓ 1 callers
Function
get_current_ref
()
dev/merge_connect_rust_pr.py:556
↓ 1 callers
Method
get_database
Get the database with the specified name
crates/connect/src/catalog.rs:140
↓ 1 callers
Function
get_jira_issue
(prompt, default_jira_id="")
dev/merge_connect_rust_pr.py:278
↓ 1 callers
Method
get_storage_level
(&self)
crates/connect/src/client/mod.rs:634
↓ 1 callers
Function
get_version_json
(version_str)
dev/merge_connect_rust_pr.py:375
↓ 1 callers
Function
grant_contributor_role
(user: str)
dev/merge_connect_rust_pr.py:455
↓ 1 callers
Method
handle_analyze
( &mut self, resp: spark::AnalyzePlanResponse, )
crates/connect/src/client/mod.rs:445
↓ 1 callers
Method
handle_response
(&mut self, resp: spark::ExecutePlanResponse)
crates/connect/src/client/mod.rs:404
↓ 1 callers
Method
headers
(mut self, val: HashMap<String, String>)
crates/connect/src/client/config.rs:86
↓ 1 callers
Method
id
(&self)
crates/connect/src/streaming/mod.rs:332
↓ 1 callers
Method
ilike
A SQL ILIKE filter expression that evaluates the column based on a case insensitive match
crates/connect/src/column.rs:302
↓ 1 callers
Function
initialize_jira
()
dev/merge_connect_rust_pr.py:565
↓ 1 callers
Method
input_files
Returns a best-effort snapshot of the files that compose this [DataFrame]
crates/connect/src/dataframe.rs:602
↓ 1 callers
Method
intersect
Return a new [DataFrame] containing rows only in both this [DataFrame] and another [DataFrame].
crates/connect/src/dataframe.rs:615
↓ 1 callers
Method
json
(&self)
crates/connect/src/types.rs:143
↓ 1 callers
Method
layer
(&self, inner: S)
crates/connect/src/client/middleware.rs:48
↓ 1 callers
Method
like
A SQL LIKE filter expression that evaluates the column based on a case sensitive match
crates/connect/src/column.rs:297
↓ 1 callers
Method
list_catalogs
Returns a list of catalogs in this session
crates/connect/src/catalog.rs:82
↓ 1 callers
Function
main
()
dev/merge_connect_rust_pr.py:599
↓ 1 callers
Method
max
Computes the max value for each numeric columns for each group.
crates/connect/src/group.rs:96
↓ 1 callers
Function
merge_pr
(pr_num, target_ref, title, body, pr_repo_desc)
dev/merge_connect_rust_pr.py:143
↓ 1 callers
Method
or
Logical OR comparion.
crates/connect/src/column.rs:324
↓ 1 callers
Method
partition_by
Partitions the output by the given columns on the file system
crates/connect/src/streaming/mod.rs:187
↓ 1 callers
Method
persist
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 callers
Method
plan_id
(self)
crates/connect/src/plan.rs:66
↓ 1 callers
Method
port
(mut self, val: Port)
crates/connect/src/client/config.rs:56
↓ 1 callers
Method
process_all_available
(&self)
crates/connect/src/streaming/mod.rs:456
↓ 1 callers
Method
project
(self, cols: I)
crates/connect/src/plan.rs:567
↓ 1 callers
Method
random_split
Randomly splits this [DataFrame] with the provided weights.
crates/connect/src/dataframe.rs:793
↓ 1 callers
Method
range_between
(self, start: i64, end: i64)
crates/connect/src/window.rs:79
↓ 1 callers
Method
reattach_execute
(&mut self)
crates/connect/src/client/mod.rs:201
↓ 1 callers
Method
release_until
(&mut self)
crates/connect/src/client/mod.rs:250
↓ 1 callers
Method
repartition
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 callers
Function
replace
( src: impl Into<Column>, search: impl Into<Column>, replace: Option<impl Into<Column>>, )
crates/connect/src/functions/mod.rs:1433
↓ 1 callers
Method
replace
Returns a new [DataFrame] replacing a value with another value.
crates/connect/src/dataframe.rs:863
↓ 1 callers
Method
replace
(self)
crates/connect/src/readwriter.rs:826
↓ 1 callers
Method
request_options
(&self)
crates/connect/src/client/mod.rs:138
↓ 1 callers
Method
reset_termination
(&self)
crates/connect/src/streaming/mod.rs:714
↓ 1 callers
Function
resolve_jira_issues
(title, merge_branches, comment)
dev/merge_connect_rust_pr.py:474
↓ 1 callers
Method
rlike
A SQL RLIKE filter expression that evaluates the column based on a regex match
crates/connect/src/column.rs:307
↓ 1 callers
Method
sample
Returns a sampled subset of this [DataFrame]
crates/connect/src/dataframe.rs:909
↓ 1 callers
Method
sample_by
Returns a stratified sample without replacement based on the fraction given on each stratum.
crates/connect/src/dataframe.rs:927
↓ 1 callers
Method
schema
(&self)
crates/connect/src/client/mod.rs:570
↓ 1 callers
Method
select_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 callers
Function
serialize
(batch: &RecordBatch)
crates/connect/src/plan.rs:864
↓ 1 callers
Method
set_configs
( &mut self, map: &HashMap<String, String>, )
crates/connect/src/conf.rs:50
↓ 1 callers
Method
set_current_database
Sets the current default database in this session
crates/connect/src/catalog.rs:110
↓ 1 callers
Method
spark_version
(&mut self)
crates/connect/src/client/mod.rs:609
↓ 1 callers
Function
standardize_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 callers
Method
status
( &self, )
crates/connect/src/streaming/mod.rs:560
↓ 1 callers
Method
substr
(self, start_pos: impl Into<Column>, length: impl Into<Column>)
crates/connect/src/column.rs:215
↓ 1 callers
Method
substract
(self, other: LogicalPlanBuilder)
crates/connect/src/plan.rs:415
↓ 1 callers
Function
sum_distinct
"Returns the sum of distinct values in the expression."
crates/connect/src/functions/mod.rs:1115
↓ 1 callers
Method
summary
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 callers
Method
to_filter_expr
(&self)
crates/connect/src/expressions.rs:96
↓ 1 callers
Method
to_polars
(self)
crates/connect/src/dataframe.rs:1203
↓ 1 callers
Method
to_schema
(&self)
crates/connect/src/readwriter.rs:43
↓ 1 callers
Method
transform
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 callers
Method
tree_string
(&self)
crates/connect/src/client/mod.rs:584
↓ 1 callers
Method
type_name
(&self)
crates/connect/src/types.rs:135
↓ 1 callers
Method
uncache_table
Removes the specified table from the in-memory cache.
crates/connect/src/catalog.rs:427
↓ 1 callers
Method
union_all
Return a new [DataFrame] containing the union of rows in this and another [DataFrame].
crates/connect/src/dataframe.rs:1251
↓ 1 callers
Method
union_all
(self, other: LogicalPlanBuilder)
crates/connect/src/plan.rs:387
↓ 1 callers
Method
unset
Resets the configuration property for the given key.
crates/connect/src/conf.rs:78
↓ 1 callers
Method
using
(mut self, provider: &str)
crates/connect/src/readwriter.rs:792
↓ 1 callers
Method
version
The version of Spark on which this application is running.
crates/connect/src/session.rs:290
↓ 1 callers
Method
with_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 callers
Method
with_field
(self, field_name: &str, col: impl Into<Column>)
crates/connect/src/column.rs:201
↓ 1 callers
Method
with_metadata
Returns a new [DataFrame] by updating an existing column with metadata.
crates/connect/src/dataframe.rs:1371
↓ 1 callers
Method
write_to
Create a write configuration builder for v2 sources with [DataFrameWriterV2].
crates/connect/src/dataframe.rs:1404
Method
add_tag
(&mut self, tag: &str)
crates/connect/src/client/mod.rs:323
Function
aes_decrypt
Returns a decrypted value of *input* using AES in *mode* with *padding
crates/connect/src/functions/mod.rs:1538
Function
aes_encrypt
Returns a encrypted value of *input* using AES in *mode* with the specified *padding
crates/connect/src/functions/mod.rs:1573
Method
agg
Aggregate on the entire [DataFrame] without groups (shorthand for `df.group_by().agg()`)
crates/connect/src/dataframe.rs:125
Method
aggregate
( input: LogicalPlanBuilder, group_type: GroupType, grouping_cols: Vec<spark::Expressi
crates/connect/src/plan.rs:104
Function
any_value
Returns some value of col for a group of rows.
crates/connect/src/functions/mod.rs:918
Method
append
(self)
crates/connect/src/readwriter.rs:834
Function
approx_count_distinct
Returns a new Column for approximate distinct count of column col.
crates/connect/src/functions/mod.rs:926
Method
approx_quantile
Calculates the approximate quantiles of numerical columns of a [DataFrame].
crates/connect/src/dataframe.rs:143
Method
approx_quantile
( self, cols: I, probabilities: P, relative_error: f64, )
crates/connect/src/plan.rs:454
Function
array_insert
adds an item into a given array at a specified array index.
crates/connect/src/functions/mod.rs:742
Function
array_join
Concatenates the elements of column using the delimiter.
crates/connect/src/functions/mod.rs:705
Function
array_sort
(col: impl Into<Column>, compactor: Option<impl Into<Column>>)
crates/connect/src/functions/mod.rs:737
Method
arrow_to_bool
(record: RecordBatch)
crates/connect/src/catalog.rs:42
Method
as_str_name
(&self)
crates/connect/src/types.rs:36
Function
asc_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
Function
asc_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
Function
assert_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
Method
await_termination
(&self, timeout_ms: Option<i64>)
crates/connect/src/streaming/mod.rs:365
Method
bitand
(self, other: Self)
crates/connect/src/column.rs:494
Method
bitor
(self, other: Self)
crates/connect/src/column.rs:486
Function
bitwise_not
Computes bitwise not.
crates/connect/src/functions/mod.rs:154
Method
bitxor
(self, other: Self)
crates/connect/src/column.rs:502
Function
broadcast
Marks a DataFrame as small enough for use in broadcast joins.
crates/connect/src/functions/mod.rs:112
Function
bround
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
Function
btrim
Remove the leading and trailing *trim* characters from *str
crates/connect/src/functions/mod.rs:1241
Method
bucket_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
Method
call
( &mut self, mut request: Request<UnsyncBoxBody<prost::bytes::Bytes, tonic::Status>>, )
crates/connect/src/client/middleware.rs:88
Method
clear_cache
Removes all cached tables from the in-memory cache.
crates/connect/src/catalog.rs:440
← previous
next →
201–300 of 681, ranked by callers