List of all items
Structs
- DataFrame
- DataFrameReader
- DataFrameWriter
- SparkSession
- SparkSessionBuilder
- catalog::Catalog
- client::AnalyzeHandler
- client::ChannelBuilder
- client::MetadataInterceptor
- client::ResponseHandler
- client::SparkConnectClient
- column::Column
- dataframe::DataFrame
- dataframe::DataFrameReader
- dataframe::DataFrameWriter
- dataframe::DataStreamReader
- dataframe::DataStreamWriter
- dataframe::StreamingQuery
- group::GroupedData
- plan::LogicalPlanBuilder
- readwriter::DataFrameReader
- readwriter::DataFrameWriter
- 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::ExamplePluginCommand
- spark::ExamplePluginExpression
- spark::ExamplePluginRelation
- 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
- window::Window
- window::WindowSpec
Enums
- dataframe::ExplainMode
- dataframe::GroupType
- dataframe::JoinType
- dataframe::OutputMode
- dataframe::SaveMode
- 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
- streaming::Trigger
Traits
- expressions::ToExpr
- expressions::ToFilterExpr
- expressions::ToLiteral
- expressions::ToLiteralExpr
- expressions::ToVecExpr
- types::ToDataType
Functions
- functions::abs
- functions::acos
- functions::acosh
- functions::add_months
- functions::approx_count_distinct
- functions::array
- functions::array_append
- functions::array_compact
- functions::array_distinct
- functions::array_except
- functions::array_insert
- functions::array_intersect
- functions::array_join
- functions::array_max
- functions::array_min
- functions::array_overlap
- functions::array_position
- functions::array_remove
- functions::array_repeat
- functions::array_size
- functions::array_union
- functions::arrays_zip
- functions::asc
- functions::asc_nulls_first
- functions::asc_nulls_last
- functions::ascii
- functions::asin
- functions::asinh
- functions::atan
- functions::atan2
- functions::atanh
- functions::avg
- functions::base64
- functions::bin
- functions::bit_count
- functions::bit_length
- functions::bitmap_bit_position
- functions::bitmap_bucket_number
- functions::bitmap_construct_agg
- functions::bitmap_count
- functions::bitmap_or_agg
- functions::bitwise_not
- 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::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_sub
- functions::dateadd
- functions::datediff
- functions::day
- functions::dayofmonth
- functions::dayofweek
- functions::dayofyear
- functions::days
- functions::degrees
- functions::dense_rank
- functions::desc
- functions::desc_nulls_first
- functions::desc_nulls_last
- functions::e
- functions::equal_null
- functions::exp
- functions::explode
- functions::explode_outer
- functions::expm1
- functions::expr
- functions::factorial
- functions::flatten
- functions::floor
- functions::greatest
- functions::group_id
- functions::grouping
- functions::hash
- functions::hex
- functions::hour
- functions::hours
- functions::ifnull
- functions::initcap
- functions::inline
- functions::inline_outer
- functions::input_file_block_length
- functions::input_file_block_start
- functions::input_file_name
- functions::invoke_func
- functions::isnan
- functions::isnotnull
- functions::isnull
- functions::java_method
- functions::json_array_length
- functions::json_object_keys
- functions::kurtosis
- functions::least
- functions::length
- functions::lit
- functions::ln
- functions::localtimestamp
- functions::log
- functions::log10
- functions::log1p
- functions::log2
- functions::lower
- functions::ltrim
- functions::map_concat
- functions::map_entries
- functions::map_from_entries
- functions::map_keys
- functions::map_values
- functions::max
- functions::md5
- functions::mean
- functions::median
- functions::min
- functions::minute
- functions::monotonically_increasing_id
- functions::month
- functions::months
- functions::named_struct
- functions::nanvl
- functions::negate
- functions::negative
- functions::now
- functions::ntile
- functions::nullif
- functions::nvl
- functions::octet_length
- functions::percent_rank
- functions::pi
- functions::posexplode
- functions::posexplode_outer
- functions::pow
- functions::power
- functions::product
- functions::quarter
- functions::radians
- functions::rand
- functions::randn
- functions::rank
- functions::reflect
- functions::reverse
- functions::rint
- functions::round
- functions::row_number
- functions::rtrim
- functions::sec
- functions::second
- functions::sha
- functions::sha1
- functions::shuffle
- functions::signum
- functions::sin
- functions::sinh
- functions::size
- functions::skewness
- functions::soundex
- functions::spark_partition_id
- functions::sqrt
- functions::stack
- functions::stddev
- functions::stddev_pop
- functions::stddev_samp
- functions::struct_col
- functions::sum
- functions::tan
- functions::tanh
- functions::timestamp_micros
- functions::timestamp_millis
- functions::timestamp_seconds
- functions::trim
- functions::ucase
- functions::unbase64
- functions::unhex
- functions::unix_date
- functions::unix_macros
- functions::unix_millis
- functions::unix_seconds
- functions::upper
- functions::user
- functions::var_pop
- functions::var_samp
- functions::variance
- functions::version
- functions::weekday
- functions::weekofyear
- functions::xxhash64
- functions::year
- functions::years