public class SparkScanBuilder extends Object implements org.apache.spark.sql.connector.read.ScanBuilder, org.apache.spark.sql.connector.read.SupportsPushDownFilters, org.apache.spark.sql.connector.read.SupportsPushDownRequiredColumns
ScanBuilder
for table store.Constructor and Description |
---|
SparkScanBuilder(Table table,
org.apache.flink.configuration.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
org.apache.spark.sql.connector.read.Scan |
build() |
void |
pruneColumns(org.apache.spark.sql.types.StructType requiredSchema) |
org.apache.spark.sql.sources.Filter[] |
pushedFilters() |
org.apache.spark.sql.sources.Filter[] |
pushFilters(org.apache.spark.sql.sources.Filter[] filters) |
public SparkScanBuilder(Table table, org.apache.flink.configuration.Configuration conf)
public org.apache.spark.sql.sources.Filter[] pushFilters(org.apache.spark.sql.sources.Filter[] filters)
pushFilters
in interface org.apache.spark.sql.connector.read.SupportsPushDownFilters
public org.apache.spark.sql.sources.Filter[] pushedFilters()
pushedFilters
in interface org.apache.spark.sql.connector.read.SupportsPushDownFilters
public void pruneColumns(org.apache.spark.sql.types.StructType requiredSchema)
pruneColumns
in interface org.apache.spark.sql.connector.read.SupportsPushDownRequiredColumns
public org.apache.spark.sql.connector.read.Scan build()
build
in interface org.apache.spark.sql.connector.read.ScanBuilder
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.