Class Hierarchy
- java.lang.Object
- org.apache.spark.sql.catalyst.util.ArrayData (implements scala.Serializable, org.apache.spark.sql.catalyst.expressions.SpecializedGetters)
- org.apache.spark.sql.catalyst.InternalRow (implements scala.Serializable, org.apache.spark.sql.catalyst.expressions.SpecializedGetters)
- org.apache.flink.table.store.spark.SparkCaseSensitiveConverter
- org.apache.flink.table.store.spark.SparkCatalog (implements org.apache.spark.sql.connector.catalog.SupportsNamespaces, org.apache.spark.sql.connector.catalog.TableCatalog)
- org.apache.flink.table.store.spark.SparkDataSourceReader (implements org.apache.spark.sql.sources.v2.reader.SupportsPushDownFilters, org.apache.spark.sql.sources.v2.reader.SupportsPushDownRequiredColumns, org.apache.spark.sql.sources.v2.reader.SupportsReportStatistics)
- org.apache.flink.table.store.spark.SparkFilterConverter
- org.apache.flink.table.store.spark.SparkInputPartition (implements org.apache.spark.sql.connector.read.InputPartition)
- org.apache.flink.table.store.spark.SparkReaderFactory (implements org.apache.spark.sql.connector.read.PartitionReaderFactory)
- org.apache.flink.table.store.spark.SparkRowData (implements org.apache.flink.table.data.RowData)
- org.apache.flink.table.store.spark.SparkScan (implements org.apache.spark.sql.connector.read.Scan, org.apache.spark.sql.connector.read.SupportsReportStatistics)
- org.apache.flink.table.store.spark.SparkScanBuilder (implements org.apache.spark.sql.connector.read.ScanBuilder, org.apache.spark.sql.connector.read.SupportsPushDownFilters, org.apache.spark.sql.connector.read.SupportsPushDownRequiredColumns)
- org.apache.flink.table.store.spark.SparkSource (implements org.apache.spark.sql.sources.DataSourceRegister, org.apache.spark.sql.connector.catalog.SessionConfigSupport)
- org.apache.flink.table.store.spark.SparkTable (implements org.apache.spark.sql.connector.catalog.SupportsDelete, org.apache.spark.sql.connector.catalog.SupportsRead, org.apache.spark.sql.connector.catalog.SupportsWrite, org.apache.spark.sql.connector.catalog.Table)
- org.apache.flink.table.store.spark.SparkTypeUtils
- org.apache.flink.table.store.spark.SparkWrite (implements org.apache.spark.sql.connector.write.V1Write)
- org.apache.flink.table.store.spark.SparkWriteBuilder (implements org.apache.spark.sql.connector.write.WriteBuilder)
- org.apache.flink.table.store.spark.SpecializedGettersReader
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.