Class SparkScanBuilder

  • All Implemented Interfaces:
    org.apache.spark.sql.connector.read.ScanBuilder, org.apache.spark.sql.connector.read.SupportsPushDownFilters, org.apache.spark.sql.connector.read.SupportsPushDownRequiredColumns

    public class SparkScanBuilder
    extends java.lang.Object
    implements org.apache.spark.sql.connector.read.ScanBuilder, org.apache.spark.sql.connector.read.SupportsPushDownFilters, org.apache.spark.sql.connector.read.SupportsPushDownRequiredColumns
    • Method Detail

      • withMetadataColumns

        public SparkScanBuilder withMetadataColumns​(java.lang.String... metadataColumns)
      • caseSensitive

        public SparkScanBuilder caseSensitive​(boolean isCaseSensitive)
      • pushFilters

        public org.apache.spark.sql.sources.Filter[] pushFilters​(org.apache.spark.sql.sources.Filter[] filters)
        Specified by:
        pushFilters in interface org.apache.spark.sql.connector.read.SupportsPushDownFilters
      • pushedFilters

        public org.apache.spark.sql.sources.Filter[] pushedFilters()
        Specified by:
        pushedFilters in interface org.apache.spark.sql.connector.read.SupportsPushDownFilters
      • pruneColumns

        public void pruneColumns​(org.apache.spark.sql.types.StructType requestedSchema)
        Specified by:
        pruneColumns in interface org.apache.spark.sql.connector.read.SupportsPushDownRequiredColumns
      • build

        public org.apache.spark.sql.connector.read.Scan build()
        Specified by:
        build in interface org.apache.spark.sql.connector.read.ScanBuilder
      • buildMergeOnReadScan

        public org.apache.spark.sql.connector.read.Scan buildMergeOnReadScan()
      • buildCopyOnWriteScan

        public org.apache.spark.sql.connector.read.Scan buildCopyOnWriteScan()