List of all items

Structs

• catalog::Catalog
• client::ChannelBuilder
• client::Config
• client::HeadersLayer
• client::HeadersMiddleware
• client::SparkConnectClient
• column::Column
• conf::RunTimeConfig
• dataframe::DataFrame
• dataframe::DataFrameNaFunctions
• dataframe::DataFrameStatFunctions
• expressions::VecExpression
• group::GroupedData
• plan::LogicalPlanBuilder
• readwriter::CommonFileOptions
• readwriter::CsvOptions
• readwriter::DataFrameReader
• readwriter::DataFrameWriter
• readwriter::DataFrameWriterV2
• readwriter::JsonOptions
• readwriter::OrcOptions
• readwriter::ParquetOptions
• readwriter::TextOptions
• session::SparkSession
• session::SparkSessionBuilder
• spark::AddArtifactsRequest
• spark::AddArtifactsResponse
• spark::Aggregate
• spark::AnalyzePlanRequest
• spark::AnalyzePlanResponse
• spark::ApplyInPandasWithState
• spark::ArtifactStatusesRequest
• spark::ArtifactStatusesResponse
• spark::CacheTable
• spark::CachedLocalRelation
• spark::CachedRemoteRelation
• spark::CallFunction
• spark::Catalog
• spark::ClearCache
• spark::CoGroupMap
• spark::CollectMetrics
• spark::Command
• spark::CommonInlineUserDefinedFunction
• spark::CommonInlineUserDefinedTableFunction
• spark::ConfigRequest
• spark::ConfigResponse
• spark::CreateDataFrameViewCommand
• spark::CreateExternalTable
• spark::CreateTable
• spark::CurrentCatalog
• spark::CurrentDatabase
• spark::DataType
• spark::DatabaseExists
• spark::Deduplicate
• spark::Drop
• spark::DropGlobalTempView
• spark::DropTempView
• spark::ExecutePlanRequest
• spark::ExecutePlanResponse
• spark::Expression
• spark::Filter
• spark::FunctionExists
• spark::GetDatabase
• spark::GetFunction
• spark::GetResourcesCommand
• spark::GetResourcesCommandResult
• spark::GetTable
• spark::GroupMap
• spark::Hint
• spark::HtmlString
• spark::InterruptRequest
• spark::InterruptResponse
• spark::IsCached
• spark::JavaUdf
• spark::Join
• spark::KeyValue
• spark::Limit
• spark::ListCatalogs
• spark::ListColumns
• spark::ListDatabases
• spark::ListFunctions
• spark::ListTables
• spark::LocalRelation
• spark::MapPartitions
• spark::NaDrop
• spark::NaFill
• spark::NaReplace
• spark::Offset
• spark::Parse
• spark::Plan
• spark::Project
• spark::PythonUdf
• spark::PythonUdtf
• spark::Range
• spark::Read
• spark::ReattachExecuteRequest
• spark::ReattachOptions
• spark::RecoverPartitions
• spark::RefreshByPath
• spark::RefreshTable
• spark::Relation
• spark::RelationCommon
• spark::ReleaseExecuteRequest
• spark::ReleaseExecuteResponse
• spark::Repartition
• spark::RepartitionByExpression
• spark::ResourceInformation
• spark::Sample
• spark::ScalarScalaUdf
• spark::SetCurrentCatalog
• spark::SetCurrentDatabase
• spark::SetOperation
• spark::ShowString
• spark::Sort
• spark::Sql
• spark::SqlCommand
• spark::StatApproxQuantile
• spark::StatCorr
• spark::StatCov
• spark::StatCrosstab
• spark::StatDescribe
• spark::StatFreqItems
• spark::StatSampleBy
• spark::StatSummary
• spark::StorageLevel
• spark::StreamingForeachFunction
• spark::StreamingQueryCommand
• spark::StreamingQueryCommandResult
• spark::StreamingQueryInstanceId
• spark::StreamingQueryManagerCommand
• spark::StreamingQueryManagerCommandResult
• spark::SubqueryAlias
• spark::TableExists
• spark::Tail
• spark::ToDf
• spark::ToSchema
• spark::UncacheTable
• spark::Unknown
• spark::Unpivot
• spark::UserContext
• spark::WithColumns
• spark::WithColumnsRenamed
• spark::WithWatermark
• spark::WriteOperation
• spark::WriteOperationV2
• spark::WriteStreamOperationStart
• spark::WriteStreamOperationStartResult
• spark::add_artifacts_request::ArtifactChunk
• spark::add_artifacts_request::Batch
• spark::add_artifacts_request::BeginChunkedArtifact
• spark::add_artifacts_request::SingleChunkArtifact
• spark::add_artifacts_response::ArtifactSummary
• spark::aggregate::Pivot
• spark::analyze_plan_request::DdlParse
• spark::analyze_plan_request::Explain
• spark::analyze_plan_request::GetStorageLevel
• spark::analyze_plan_request::InputFiles
• spark::analyze_plan_request::IsLocal
• spark::analyze_plan_request::IsStreaming
• spark::analyze_plan_request::Persist
• spark::analyze_plan_request::SameSemantics
• spark::analyze_plan_request::Schema
• spark::analyze_plan_request::SemanticHash
• spark::analyze_plan_request::SparkVersion
• spark::analyze_plan_request::TreeString
• spark::analyze_plan_request::Unpersist
• spark::analyze_plan_response::DdlParse
• spark::analyze_plan_response::Explain
• spark::analyze_plan_response::GetStorageLevel
• spark::analyze_plan_response::InputFiles
• spark::analyze_plan_response::IsLocal
• spark::analyze_plan_response::IsStreaming
• spark::analyze_plan_response::Persist
• spark::analyze_plan_response::SameSemantics
• spark::analyze_plan_response::Schema
• spark::analyze_plan_response::SemanticHash
• spark::analyze_plan_response::SparkVersion
• spark::analyze_plan_response::TreeString
• spark::analyze_plan_response::Unpersist
• spark::artifact_statuses_response::ArtifactStatus
• spark::config_request::Get
• spark::config_request::GetAll
• spark::config_request::GetOption
• spark::config_request::GetWithDefault
• spark::config_request::IsModifiable
• spark::config_request::Operation
• spark::config_request::Set
• spark::config_request::Unset
• spark::data_type::Array
• spark::data_type::Binary
• spark::data_type::Boolean
• spark::data_type::Byte
• spark::data_type::CalendarInterval
• spark::data_type::Char
• spark::data_type::Date
• spark::data_type::DayTimeInterval
• spark::data_type::Decimal
• spark::data_type::Double
• spark::data_type::Float
• spark::data_type::Integer
• spark::data_type::Long
• spark::data_type::Map
• spark::data_type::Null
• spark::data_type::Short
• spark::data_type::String
• spark::data_type::Struct
• spark::data_type::StructField
• spark::data_type::Timestamp
• spark::data_type::TimestampNtz
• spark::data_type::Udt
• spark::data_type::Unparsed
• spark::data_type::VarChar
• spark::data_type::YearMonthInterval
• spark::execute_plan_request::RequestOption
• spark::execute_plan_response::ArrowBatch
• spark::execute_plan_response::Metrics
• spark::execute_plan_response::ObservedMetrics
• spark::execute_plan_response::ResultComplete
• spark::execute_plan_response::SqlCommandResult
• spark::execute_plan_response::metrics::MetricObject
• spark::execute_plan_response::metrics::MetricValue
• spark::expression::Alias
• spark::expression::Cast
• spark::expression::ExpressionString
• spark::expression::LambdaFunction
• spark::expression::Literal
• spark::expression::SortOrder
• spark::expression::UnresolvedAttribute
• spark::expression::UnresolvedExtractValue
• spark::expression::UnresolvedFunction
• spark::expression::UnresolvedNamedLambdaVariable
• spark::expression::UnresolvedRegex
• spark::expression::UnresolvedStar
• spark::expression::UpdateFields
• spark::expression::Window
• spark::expression::literal::Array
• spark::expression::literal::CalendarInterval
• spark::expression::literal::Decimal
• spark::expression::literal::Map
• spark::expression::literal::Struct
• spark::expression::window::WindowFrame
• spark::expression::window::window_frame::FrameBoundary
• spark::join::JoinDataType
• spark::na_replace::Replacement
• spark::read::DataSource
• spark::read::NamedTable
• spark::release_execute_request::ReleaseAll
• spark::release_execute_request::ReleaseUntil
• spark::spark_connect_service_client::SparkConnectServiceClient
• spark::stat_sample_by::Fraction
• spark::streaming_query_command::AwaitTerminationCommand
• spark::streaming_query_command::ExplainCommand
• spark::streaming_query_command_result::AwaitTerminationResult
• spark::streaming_query_command_result::ExceptionResult
• spark::streaming_query_command_result::ExplainResult
• spark::streaming_query_command_result::RecentProgressResult
• spark::streaming_query_command_result::StatusResult
• spark::streaming_query_manager_command::AwaitAnyTerminationCommand
• spark::streaming_query_manager_command::StreamingQueryListenerCommand
• spark::streaming_query_manager_command_result::ActiveResult
• spark::streaming_query_manager_command_result::AwaitAnyTerminationResult
• spark::streaming_query_manager_command_result::ListStreamingQueryListenerResult
• spark::streaming_query_manager_command_result::StreamingQueryInstance
• spark::streaming_query_manager_command_result::StreamingQueryListenerInstance
• spark::unpivot::Values
• spark::write_operation::BucketBy
• spark::write_operation::SaveTable
• streaming::DataStreamReader
• streaming::DataStreamWriter
• streaming::StreamingQuery
• streaming::StreamingQueryManager
• types::StructField
• types::StructType
• window::Window
• window::WindowSpec

Enums

• errors::SparkError
• spark::add_artifacts_request::Payload
• spark::aggregate::GroupType
• spark::analyze_plan_request::Analyze
• spark::analyze_plan_request::explain::ExplainMode
• spark::analyze_plan_response::Result
• spark::catalog::CatType
• spark::command::CommandType
• spark::common_inline_user_defined_function::Function
• spark::common_inline_user_defined_table_function::Function
• spark::config_request::operation::OpType
• spark::data_type::Kind
• spark::execute_plan_request::request_option::RequestOption
• spark::execute_plan_response::ResponseType
• spark::expression::ExprType
• spark::expression::cast::CastToType
• spark::expression::literal::LiteralType
• spark::expression::sort_order::NullOrdering
• spark::expression::sort_order::SortDirection
• spark::expression::window::window_frame::FrameType
• spark::expression::window::window_frame::frame_boundary::Boundary
• spark::interrupt_request::Interrupt
• spark::interrupt_request::InterruptType
• spark::join::JoinType
• spark::parse::ParseFormat
• spark::plan::OpType
• spark::read::ReadType
• spark::relation::RelType
• spark::release_execute_request::Release
• spark::set_operation::SetOpType
• spark::streaming_foreach_function::Function
• spark::streaming_query_command::Command
• spark::streaming_query_command_result::ResultType
• spark::streaming_query_manager_command::Command
• spark::streaming_query_manager_command_result::ResultType
• spark::write_operation::SaveMode
• spark::write_operation::SaveType
• spark::write_operation::save_table::TableSaveMethod
• spark::write_operation_v2::Mode
• spark::write_stream_operation_start::SinkDestination
• spark::write_stream_operation_start::Trigger
• storage::StorageLevel
• streaming::OutputMode
• types::DataType

Traits

• expressions::ToFilterExpr
• expressions::ToLiteral
• readwriter::ConfigOpts
• readwriter::ToSchema
• types::SparkDataType

Functions

• functions::abs
• functions::acos
• functions::acosh
• functions::add_months
• functions::aes_decrypt
• functions::aes_encrypt
• functions::any_value
• functions::approx_count_distinct
• functions::array
• functions::array_agg
• functions::array_append
• functions::array_compact
• functions::array_contains
• functions::array_distinct
• functions::array_except
• functions::array_insert
• functions::array_intersect
• functions::array_join
• functions::array_max
• functions::array_min
• functions::array_position
• functions::array_prepend
• functions::array_remove
• functions::array_repeat
• functions::array_size
• functions::array_sort
• functions::array_union
• functions::arrays_overlap
• functions::arrays_zip
• functions::asc
• functions::asc_nulls_first
• functions::asc_nulls_last
• functions::ascii
• functions::asin
• functions::asinh
• functions::assert_true
• functions::atan
• functions::atan2
• functions::atanh
• functions::avg
• functions::base64
• functions::bin
• functions::bit_and
• functions::bit_count
• functions::bit_get
• functions::bit_length
• functions::bit_or
• functions::bit_xor
• functions::bitmap_bit_position
• functions::bitmap_bucket_number
• functions::bitmap_construct_agg
• functions::bitmap_count
• functions::bitmap_or_agg
• functions::bitwise_not
• functions::bool_and
• functions::bool_or
• functions::broadcast
• functions::bround
• functions::btrim
• functions::bucket
• functions::cardinality
• functions::cbrt
• functions::ceil
• functions::ceiling
• functions::char
• functions::char_length
• functions::character_length
• functions::coalesce
• functions::col
• functions::collect_list
• functions::collect_set
• functions::column
• functions::concat
• functions::concat_ws
• functions::contains
• functions::conv
• functions::convert_timezone
• functions::corr
• functions::cos
• functions::cosh
• functions::cot
• functions::count
• functions::count_distinct
• functions::count_if
• functions::count_min_sketch
• functions::covar_pop
• functions::covar_samp
• functions::crc32
• functions::create_map
• functions::csc
• functions::cume_dist
• functions::curdate
• functions::current_catalog
• functions::current_database
• functions::current_date
• functions::current_schema
• functions::current_timestamp
• functions::current_timezone
• functions::current_user
• functions::date_add
• functions::date_diff
• functions::date_format
• functions::date_from_unix_date
• functions::date_part
• functions::date_sub
• functions::date_trunc
• functions::dateadd
• functions::datediff
• functions::day
• functions::dayofmonth
• functions::dayofweek
• functions::dayofyear
• functions::days
• functions::decode
• functions::degrees
• functions::dense_rank
• functions::desc
• functions::desc_nulls_first
• functions::desc_nulls_last
• functions::e
• functions::element_at
• functions::elt
• functions::encode
• functions::endswith
• functions::equal_null
• functions::every
• functions::exp
• functions::explode
• functions::explode_outer
• functions::expm1
• functions::expr
• functions::extract
• functions::factorial
• functions::find_in_set
• functions::first
• functions::first_value
• functions::flatten
• functions::floor
• functions::format_number
• functions::format_string
• functions::from_csv
• functions::from_json
• functions::from_unixtime
• functions::from_utc_timestamp
• functions::get
• functions::get_json_object
• functions::getbit
• functions::greatest
• functions::grouping
• functions::grouping_id
• functions::hash
• functions::hex
• functions::histogram_numeric
• functions::hll_sketch_agg
• functions::hll_sketch_estimate
• functions::hll_union
• functions::hll_union_agg
• functions::hour
• functions::hours
• functions::hypot
• functions::ifnull
• functions::ilike
• functions::initcap
• functions::inline
• functions::inline_outer
• functions::input_file_block_length
• functions::input_file_block_start
• functions::input_file_name
• functions::instr
• functions::isnan
• functions::isnotnull
• functions::isnull
• functions::java_method
• functions::json_array_length
• functions::json_object_keys
• functions::json_tuple
• functions::kurtosis
• functions::lag
• functions::last
• functions::last_day
• functions::last_value
• functions::lcase
• functions::lead
• functions::least
• functions::left
• functions::length
• functions::levenshtein
• functions::like
• functions::lit
• functions::ln
• functions::localtimestamp
• functions::locate
• functions::log
• functions::log10
• functions::log1p
• functions::log2
• functions::lower
• functions::lpad
• functions::ltrim
• functions::make_date
• functions::make_dt_interval
• functions::make_interval
• functions::make_timestamp
• functions::make_timestamp_ltz
• functions::make_timestamp_ntz
• functions::make_ym_interval
• functions::map_concat
• functions::map_contains_key
• functions::map_entries
• functions::map_from_arrays
• functions::map_from_entries
• functions::map_keys
• functions::map_values
• functions::max
• functions::max_by
• functions::md5
• functions::mean
• functions::median
• functions::min
• functions::min_by
• functions::minute
• functions::mode
• functions::monotonically_increasing_id
• functions::month
• functions::months
• functions::months_between
• functions::named_struct
• functions::nanvl
• functions::negate
• functions::negative
• functions::next_day
• functions::now
• functions::nth_value
• functions::ntile
• functions::nullif
• functions::nvl
• functions::nvl2
• functions::octet_length
• functions::overlay
• functions::parse_url
• functions::percent_rank
• functions::percentile
• functions::percentile_approx
• functions::pi
• functions::pmod
• functions::posexplode
• functions::posexplode_outer
• functions::position
• functions::positive
• functions::pow
• functions::power
• functions::printf
• functions::product
• functions::quarter
• functions::radians
• functions::raise_error
• functions::rand
• functions::randn
• functions::rank
• functions::reflect
• functions::regexp
• functions::regexp_count
• functions::regexp_extract
• functions::regexp_extract_all
• functions::regexp_instr
• functions::regexp_like
• functions::regexp_replace
• functions::regexp_substr
• functions::regr_avgx
• functions::regr_avgy
• functions::regr_count
• functions::regr_intercept
• functions::regr_r2
• functions::regr_slope
• functions::regr_sxx
• functions::regr_sxy
• functions::regr_syy
• functions::repeat
• functions::replace
• functions::reverse
• functions::right
• functions::rint
• functions::rlike
• functions::round
• functions::row_number
• functions::rpad
• functions::rtrim
• functions::schema_of_csv
• functions::schema_of_json
• functions::sec
• functions::second
• functions::sentences
• functions::sequence
• functions::session_window
• functions::sha
• functions::sha1
• functions::sha2
• functions::shiftleft
• functions::shiftright
• functions::shiftrightunsigned
• functions::shuffle
• functions::sign
• functions::signum
• functions::sin
• functions::sinh
• functions::size
• functions::skewness
• functions::slice
• functions::some
• functions::sort_array
• functions::soundex
• functions::spark_partition_id
• functions::split
• functions::split_part
• functions::sqrt
• functions::stack
• functions::startswith
• functions::std
• functions::stddev
• functions::stddev_pop
• functions::stddev_samp
• functions::str_to_map
• functions::struct_col
• functions::substr
• functions::substring
• functions::substring_index
• functions::sum
• functions::sum_distinct
• functions::tan
• functions::tanh
• functions::timestamp_micros
• functions::timestamp_millis
• functions::timestamp_seconds
• functions::to_binary
• functions::to_char
• functions::to_csv
• functions::to_date
• functions::to_json
• functions::to_number
• functions::to_timestamp
• functions::to_timestamp_ltz
• functions::to_timestamp_ntz
• functions::to_unix_timestamp
• functions::to_utc_timestamp
• functions::to_varchar
• functions::translate
• functions::trim
• functions::trunc
• functions::try_add
• functions::try_aes_decrypt
• functions::try_avg
• functions::try_divide
• functions::try_element_at
• functions::try_multiply
• functions::try_subtract
• functions::try_sum
• functions::try_to_binary
• functions::try_to_number
• functions::try_to_timestamp
• functions::ucase
• functions::unbase64
• functions::unhex
• functions::unix_date
• functions::unix_micros
• functions::unix_millis
• functions::unix_seconds
• functions::unix_timestamp
• functions::upper
• functions::url_decode
• functions::url_encode
• functions::user
• functions::var_pop
• functions::var_samp
• functions::variance
• functions::version
• functions::weekday
• functions::weekofyear
• functions::width_bucket
• functions::window
• functions::window_time
• functions::xpath
• functions::xpath_boolean
• functions::xpath_double
• functions::xpath_float
• functions::xpath_int
• functions::xpath_long
• functions::xpath_number
• functions::xpath_short
• functions::xpath_string
• functions::xxhash64
• functions::year
• functions::years

Type Aliases

• client::SparkClient