buildReaderWithPartitionValues(
sparkSession: SparkSession,
dataSchema: StructType,
partitionSchema: StructType,
requiredSchema: StructType,
filters: Seq[Filter],
options: Map[String, String],
hadoopConf: Configuration): (PartitionedFile) => Iterator[InternalRow]
OrcFileFormat
OrcFileFormat
is a FileFormat that…FIXME
buildReaderWithPartitionValues
Method
Note
|
buildReaderWithPartitionValues is part of FileFormat Contract to build a data reader with partition column values appended.
|
buildReaderWithPartitionValues
…FIXME
inferSchema
Method
inferSchema(
sparkSession: SparkSession,
options: Map[String, String],
files: Seq[FileStatus]): Option[StructType]
Note
|
inferSchema is part of FileFormat Contract to…FIXME.
|
inferSchema
…FIXME
Building Partitioned Data Reader — buildReader
Method
buildReader(
sparkSession: SparkSession,
dataSchema: StructType,
partitionSchema: StructType,
requiredSchema: StructType,
filters: Seq[Filter],
options: Map[String, String],
hadoopConf: Configuration): (PartitionedFile) => Iterator[InternalRow]
Note
|
buildReader is part of FileFormat Contract to…FIXME
|
buildReader
…FIXME