Index
All Classes and Interfaces|All Packages|Constant Field Values
A
- alterNamespace(String[], NamespaceChange...) - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
- alterTable(Identifier, TableChange...) - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
- alterTable(Identifier, TableChange...) - Method in class org.apache.polaris.spark.PolarisSparkCatalog
- alterView(Identifier, ViewChange...) - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
B
- baseLocation() - Method in record class org.apache.polaris.spark.rest.GenericTable
-
Returns the value of the
baseLocationrecord component. - BasePolarisSparkCatalog - Class in org.apache.polaris.spark
-
SparkCatalog implementation that is able to interact with both Iceberg SparkCatalog and Polaris.
- BasePolarisSparkCatalog() - Constructor for class org.apache.polaris.spark.BasePolarisSparkCatalog
- build() - Method in class org.apache.polaris.spark.rest.CreateGenericTableRequest.Builder
- build() - Method in class org.apache.polaris.spark.rest.ListGenericTablesResponse.Builder
- build() - Method in class org.apache.polaris.spark.rest.LoadGenericTableResponse.Builder
- builder() - Static method in class org.apache.polaris.spark.rest.CreateGenericTableRequest
- builder() - Static method in record class org.apache.polaris.spark.rest.GenericTable
- builder() - Static method in class org.apache.polaris.spark.rest.ListGenericTablesResponse
- builder() - Static method in class org.apache.polaris.spark.rest.LoadGenericTableResponse
- builder(String, String) - Static method in class org.apache.polaris.spark.rest.CreateGenericTableRequest
- builder(GenericTable) - Static method in class org.apache.polaris.spark.rest.LoadGenericTableResponse
C
- catalogName - Variable in class org.apache.polaris.spark.BasePolarisSparkCatalog
- close() - Method in class org.apache.polaris.spark.PolarisRESTCatalog
- createCatalogUtils() - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
- createCatalogUtils() - Method in class org.apache.polaris.spark.SparkCatalog
- createGenericTable(TableIdentifier, String, String, String, Map<String, String>) - Method in interface org.apache.polaris.spark.PolarisCatalog
- createGenericTable(TableIdentifier, String, String, String, Map<String, String>) - Method in class org.apache.polaris.spark.PolarisRESTCatalog
- CreateGenericTableRequest - Class in org.apache.polaris.spark.rest
- CreateGenericTableRequest(String, String) - Constructor for class org.apache.polaris.spark.rest.CreateGenericTableRequest
- CreateGenericTableRequest(String, String, String, String, Map<String, String>) - Constructor for class org.apache.polaris.spark.rest.CreateGenericTableRequest
- CreateGenericTableRequest.Builder - Class in org.apache.polaris.spark.rest
- CreateGenericTableRESTRequest - Class in org.apache.polaris.spark.rest
-
RESTRequest definition for CreateGenericTable which extends the iceberg RESTRequest.
- CreateGenericTableRESTRequest(String, String, String, String, Map<String, String>) - Constructor for class org.apache.polaris.spark.rest.CreateGenericTableRESTRequest
- CreateGenericTableRESTRequest(CreateGenericTableRequest) - Constructor for class org.apache.polaris.spark.rest.CreateGenericTableRESTRequest
- createNamespace(String[], Map<String, String>) - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
- createTable(Identifier, StructType, Transform[], Map<String, String>) - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
- createTable(Identifier, StructType, Transform[], Map<String, String>) - Method in class org.apache.polaris.spark.PolarisSparkCatalog
- createView(ViewInfo) - Method in class org.apache.polaris.spark.SparkCatalog
D
- defaultNamespace() - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
- DELTA_CATALOG_IMPL_KEY - Static variable in class org.apache.polaris.spark.utils.DeltaHelper
- deltaHelper - Variable in class org.apache.polaris.spark.BasePolarisSparkCatalog
- DeltaHelper - Class in org.apache.polaris.spark.utils
-
Helper class for integrating Delta table functionality with Polaris Spark Catalog.
- DeltaHelper(CaseInsensitiveStringMap) - Constructor for class org.apache.polaris.spark.utils.DeltaHelper
- doc() - Method in record class org.apache.polaris.spark.rest.GenericTable
-
Returns the value of the
docrecord component. - dropGenericTable(TableIdentifier) - Method in interface org.apache.polaris.spark.PolarisCatalog
- dropGenericTable(TableIdentifier) - Method in class org.apache.polaris.spark.PolarisRESTCatalog
- dropNamespace(String[], boolean) - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
- dropTable(Identifier) - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
- dropTable(Identifier) - Method in class org.apache.polaris.spark.PolarisSparkCatalog
- dropView(Identifier) - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
E
- equals(Object) - Method in class org.apache.polaris.spark.rest.CreateGenericTableRequest
- equals(Object) - Method in record class org.apache.polaris.spark.rest.GenericTable
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in class org.apache.polaris.spark.rest.ListGenericTablesResponse
- equals(Object) - Method in class org.apache.polaris.spark.rest.LoadGenericTableResponse
F
- fetchConfig(RESTClient, Map<String, String>, Map<String, String>) - Static method in class org.apache.polaris.spark.PolarisRESTCatalog
- format() - Method in record class org.apache.polaris.spark.rest.GenericTable
-
Returns the value of the
formatrecord component.
G
- GenericTable - Record Class in org.apache.polaris.spark.rest
- GenericTable(String, String, String, String, Map<String, String>) - Constructor for record class org.apache.polaris.spark.rest.GenericTable
-
Creates an instance of a
GenericTablerecord class. - getAuthSession(SparkCatalog) - Static method in class org.apache.polaris.spark.utils.PolarisCatalogUtils
-
Get the catalogAuth field inside the RESTSessionCatalog used by Iceberg Spark Catalog use reflection.
- getBaseLocation() - Method in class org.apache.polaris.spark.rest.CreateGenericTableRequest
- getDoc() - Method in class org.apache.polaris.spark.rest.CreateGenericTableRequest
- getFormat() - Method in class org.apache.polaris.spark.rest.CreateGenericTableRequest
- getIdentifiers() - Method in class org.apache.polaris.spark.rest.ListGenericTablesResponse
- getName() - Method in class org.apache.polaris.spark.rest.CreateGenericTableRequest
- getNextPageToken() - Method in class org.apache.polaris.spark.rest.ListGenericTablesResponse
-
An opaque token that allows clients to make use of pagination for list APIs (e.g.
- getProperties() - Method in class org.apache.polaris.spark.rest.CreateGenericTableRequest
- getTable() - Method in class org.apache.polaris.spark.rest.LoadGenericTableResponse
H
- hashCode() - Method in class org.apache.polaris.spark.rest.CreateGenericTableRequest
- hashCode() - Method in record class org.apache.polaris.spark.rest.GenericTable
-
Returns a hash code value for this object.
- hashCode() - Method in class org.apache.polaris.spark.rest.ListGenericTablesResponse
- hashCode() - Method in class org.apache.polaris.spark.rest.LoadGenericTableResponse
- HUDI_CATALOG_IMPL_KEY - Static variable in class org.apache.polaris.spark.utils.HudiHelper
- hudiHelper - Variable in class org.apache.polaris.spark.BasePolarisSparkCatalog
- HudiHelper - Class in org.apache.polaris.spark.utils
- HudiHelper(CaseInsensitiveStringMap) - Constructor for class org.apache.polaris.spark.utils.HudiHelper
I
- icebergsSparkCatalog - Variable in class org.apache.polaris.spark.BasePolarisSparkCatalog
- initialize(String, CaseInsensitiveStringMap) - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
- initialize(String, CaseInsensitiveStringMap) - Method in class org.apache.polaris.spark.PolarisSparkCatalog
- initialize(Map<String, String>, OAuth2Util.AuthSession) - Method in class org.apache.polaris.spark.PolarisRESTCatalog
- invalidateTable(Identifier) - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
- isTableWithSparkManagedLocation(Map<String, String>) - Static method in class org.apache.polaris.spark.utils.PolarisCatalogUtils
-
For tables whose location is managed by Spark Session Catalog, there will be no location or path in the properties.
L
- listGenericTables(Namespace) - Method in interface org.apache.polaris.spark.PolarisCatalog
- listGenericTables(Namespace) - Method in class org.apache.polaris.spark.PolarisRESTCatalog
- ListGenericTablesResponse - Class in org.apache.polaris.spark.rest
- ListGenericTablesResponse(String, Set<TableIdentifier>) - Constructor for class org.apache.polaris.spark.rest.ListGenericTablesResponse
- ListGenericTablesResponse.Builder - Class in org.apache.polaris.spark.rest
- ListGenericTablesRESTResponse - Class in org.apache.polaris.spark.rest
-
RESTResponse definition for ListGenericTable which extends the iceberg RESTResponse.
- ListGenericTablesRESTResponse(String, Set<TableIdentifier>) - Constructor for class org.apache.polaris.spark.rest.ListGenericTablesRESTResponse
- listNamespaces() - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
- listNamespaces(String[]) - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
- listTables(String[]) - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
- listTables(String[]) - Method in class org.apache.polaris.spark.PolarisSparkCatalog
- listViews(String...) - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
- loadDeltaCatalog(PolarisSparkCatalog) - Method in class org.apache.polaris.spark.utils.DeltaHelper
- loadGenericTable(TableIdentifier) - Method in interface org.apache.polaris.spark.PolarisCatalog
- loadGenericTable(TableIdentifier) - Method in class org.apache.polaris.spark.PolarisRESTCatalog
- LoadGenericTableResponse - Class in org.apache.polaris.spark.rest
- LoadGenericTableResponse(GenericTable) - Constructor for class org.apache.polaris.spark.rest.LoadGenericTableResponse
- LoadGenericTableResponse.Builder - Class in org.apache.polaris.spark.rest
- LoadGenericTableRESTResponse - Class in org.apache.polaris.spark.rest
-
RESTResponse definition for LoadGenericTable which extends the iceberg RESTResponse.
- LoadGenericTableRESTResponse(GenericTable) - Constructor for class org.apache.polaris.spark.rest.LoadGenericTableRESTResponse
- loadHudiCatalog(PolarisSparkCatalog) - Method in class org.apache.polaris.spark.utils.HudiHelper
- loadNamespaceMetadata(String[]) - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
- loadPaimonCatalog(PolarisSparkCatalog) - Method in class org.apache.polaris.spark.utils.PaimonHelper
-
Load and configure the Paimon catalog with Polaris Spark Catalog as the delegate.
- loadTable(Identifier) - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
- loadTable(Identifier) - Method in class org.apache.polaris.spark.PolarisSparkCatalog
- loadV1SparkTable(GenericTable, Identifier, String) - Method in class org.apache.polaris.spark.utils.PolarisCatalogSpark4Utils
- loadV1SparkTable(GenericTable, Identifier, String) - Method in class org.apache.polaris.spark.utils.PolarisCatalogUtils
-
Return a Spark V1Table for formats that do not use DataSourceV2.
- loadV2SparkTable(GenericTable) - Static method in class org.apache.polaris.spark.utils.PolarisCatalogUtils
-
Load spark table using DataSourceV2.
- loadView(Identifier) - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
N
- name() - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
- name() - Method in class org.apache.polaris.spark.PolarisSparkCatalog
- name() - Method in record class org.apache.polaris.spark.rest.GenericTable
-
Returns the value of the
namerecord component. - normalizeTablePropertiesForLoadSparkTable(GenericTable) - Static method in class org.apache.polaris.spark.utils.PolarisCatalogUtils
-
Normalize table properties for loading Spark tables by ensuring the TABLE_PATH_KEY is properly set.
O
- org.apache.polaris.spark - package org.apache.polaris.spark
- org.apache.polaris.spark.rest - package org.apache.polaris.spark.rest
- org.apache.polaris.spark.utils - package org.apache.polaris.spark.utils
P
- PAIMON_CATALOG_IMPL_KEY - Static variable in class org.apache.polaris.spark.utils.PaimonHelper
- paimonHelper - Variable in class org.apache.polaris.spark.BasePolarisSparkCatalog
- PaimonHelper - Class in org.apache.polaris.spark.utils
-
Helper class for integrating Apache Paimon table functionality with Polaris Spark Catalog.
- PaimonHelper(CaseInsensitiveStringMap) - Constructor for class org.apache.polaris.spark.utils.PaimonHelper
- PolarisCatalog - Interface in org.apache.polaris.spark
- PolarisCatalogSpark4Utils - Class in org.apache.polaris.spark.utils
-
Spark 4.0 implementation of
PolarisCatalogUtils. - PolarisCatalogSpark4Utils() - Constructor for class org.apache.polaris.spark.utils.PolarisCatalogSpark4Utils
- PolarisCatalogUtils - Class in org.apache.polaris.spark.utils
-
Base class with helpers used by the Polaris Spark client.
- PolarisCatalogUtils() - Constructor for class org.apache.polaris.spark.utils.PolarisCatalogUtils
- PolarisRESTCatalog - Class in org.apache.polaris.spark
-
[[PolarisRESTCatalog]] talks to Polaris REST APIs, and implements the PolarisCatalog interfaces, which are generic table related APIs at this moment.
- PolarisRESTCatalog() - Constructor for class org.apache.polaris.spark.PolarisRESTCatalog
- PolarisRESTCatalog(Function<Map<String, String>, RESTClient>) - Constructor for class org.apache.polaris.spark.PolarisRESTCatalog
- polarisSparkCatalog - Variable in class org.apache.polaris.spark.BasePolarisSparkCatalog
- PolarisSparkCatalog - Class in org.apache.polaris.spark
-
A spark TableCatalog Implementation interacts with Polaris specific APIs only.
- PolarisSparkCatalog(PolarisCatalog, PolarisCatalogUtils) - Constructor for class org.apache.polaris.spark.PolarisSparkCatalog
- properties() - Method in record class org.apache.polaris.spark.rest.GenericTable
-
Returns the value of the
propertiesrecord component. - purgeTable(Identifier) - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
- purgeTable(Identifier) - Method in class org.apache.polaris.spark.PolarisSparkCatalog
R
- renameTable(Identifier, Identifier) - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
- renameTable(Identifier, Identifier) - Method in class org.apache.polaris.spark.PolarisSparkCatalog
- renameView(Identifier, Identifier) - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
- replaceView(Identifier, String, String, String[], StructType, String[], String[], String[], Map<String, String>) - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
- replaceView(ViewInfo, boolean) - Method in class org.apache.polaris.spark.SparkCatalog
- REST_PAGE_SIZE - Static variable in class org.apache.polaris.spark.PolarisRESTCatalog
S
- setBaseLocation(String) - Method in class org.apache.polaris.spark.rest.CreateGenericTableRequest.Builder
- setDoc(String) - Method in class org.apache.polaris.spark.rest.CreateGenericTableRequest.Builder
- setFormat(String) - Method in class org.apache.polaris.spark.rest.CreateGenericTableRequest.Builder
- setIdentifiers(Set<TableIdentifier>) - Method in class org.apache.polaris.spark.rest.ListGenericTablesResponse.Builder
- setName(String) - Method in class org.apache.polaris.spark.rest.CreateGenericTableRequest.Builder
- setNextPageToken(String) - Method in class org.apache.polaris.spark.rest.ListGenericTablesResponse.Builder
- setProperties(Map<String, String>) - Method in class org.apache.polaris.spark.rest.CreateGenericTableRequest.Builder
- setTable(GenericTable) - Method in class org.apache.polaris.spark.rest.LoadGenericTableResponse.Builder
- SparkCatalog - Class in org.apache.polaris.spark
-
Spark 4.0 SparkCatalog implementation.
- SparkCatalog() - Constructor for class org.apache.polaris.spark.SparkCatalog
- stageCreate(Identifier, StructType, Transform[], Map<String, String>) - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
- stageCreateOrReplace(Identifier, StructType, Transform[], Map<String, String>) - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
- stageReplace(Identifier, StructType, Transform[], Map<String, String>) - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
T
- TABLE_PATH_KEY - Static variable in class org.apache.polaris.spark.utils.PolarisCatalogUtils
- TABLE_PROVIDER_KEY - Static variable in class org.apache.polaris.spark.utils.PolarisCatalogUtils
- toString() - Method in class org.apache.polaris.spark.rest.CreateGenericTableRequest
- toString() - Method in record class org.apache.polaris.spark.rest.GenericTable
-
Returns a string representation of this record class.
- toString() - Method in class org.apache.polaris.spark.rest.ListGenericTablesResponse
- toString() - Method in class org.apache.polaris.spark.rest.LoadGenericTableResponse
U
- useDelta(String) - Static method in class org.apache.polaris.spark.utils.PolarisCatalogUtils
-
Check whether the table provider is delta.
- useHudi(String) - Static method in class org.apache.polaris.spark.utils.PolarisCatalogUtils
- useIceberg(String) - Static method in class org.apache.polaris.spark.utils.PolarisCatalogUtils
-
Check whether the table provider is iceberg.
- usePaimon(String) - Static method in class org.apache.polaris.spark.utils.PolarisCatalogUtils
-
Check whether the table provider is paimon.
V
- validate() - Method in class org.apache.polaris.spark.rest.CreateGenericTableRESTRequest
- validate() - Method in class org.apache.polaris.spark.rest.ListGenericTablesRESTResponse
- validate() - Method in class org.apache.polaris.spark.rest.LoadGenericTableRESTResponse
- validateAndResolveCatalogOptions(CaseInsensitiveStringMap) - Method in class org.apache.polaris.spark.BasePolarisSparkCatalog
-
Check whether invalid catalog configuration is provided, and return an option map with catalog type configured correctly.
All Classes and Interfaces|All Packages|Constant Field Values