public class SparkReaderFactory extends Object implements org.apache.spark.sql.connector.read.PartitionReaderFactory
PartitionReaderFactory
for table store.Constructor and Description |
---|
SparkReaderFactory(Table table,
int[] projectedFields,
List<Predicate> predicates,
org.apache.flink.configuration.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
org.apache.spark.sql.connector.read.PartitionReader<org.apache.spark.sql.catalyst.InternalRow> |
createReader(org.apache.spark.sql.connector.read.InputPartition partition) |
public org.apache.spark.sql.connector.read.PartitionReader<org.apache.spark.sql.catalyst.InternalRow> createReader(org.apache.spark.sql.connector.read.InputPartition partition)
createReader
in interface org.apache.spark.sql.connector.read.PartitionReaderFactory
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.