Skip to content

Commit

Permalink
address review comments
Browse files Browse the repository at this point in the history
  • Loading branch information
kazuyukitanimura committed May 15, 2024
1 parent 9a4b605 commit 396d077
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -23,8 +23,6 @@ import org.apache.spark.sql.execution.datasources.FileFormat
import org.apache.spark.sql.execution.datasources.parquet.ParquetFileFormat

object ShimFileFormat {
val ROW_INDEX = ParquetFileFormat.ROW_INDEX

// A name for a temporary column that holds row indexes computed by the file format reader
// until they can be placed in the _metadata struct.
val ROW_INDEX_TEMPORARY_COLUMN_NAME = ParquetFileFormat.ROW_INDEX_TEMPORARY_COLUMN_NAME
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,8 +30,6 @@ trait ShimCometParquetUtils {
QueryExecutionErrors.foundDuplicateFieldInFieldIdLookupModeError(requiredId, matchedFields)
}

val FIELD_ID_METADATA_KEY = ParquetUtils.FIELD_ID_METADATA_KEY

def hasFieldIds(schema: StructType): Boolean = ParquetUtils.hasFieldIds(schema)

def hasFieldId(field: StructField): Boolean = ParquetUtils.hasFieldId(field)
Expand Down

0 comments on commit 396d077

Please sign in to comment.