Skip to content

Commit

Permalink
revert unnecessary code 2/n
Browse files Browse the repository at this point in the history
  • Loading branch information
huan233usc committed Feb 19, 2025
1 parent 622d28d commit 13bb0a7
Showing 1 changed file with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -831,7 +831,7 @@ class DeltaTableWritesSuite extends DeltaTableWriteSuiteBase with ParquetSuiteBa
}

def commitAndVerify(newTbl: Boolean, txn: Transaction,
actions: CloseableIterable[Row], expTblVer: Long): Unit = {
actions: CloseableIterable[Row], expTblVer: Long): Unit = {
val commitResult = commitTransaction(txn, engine, actions)

expData = expData ++ data.flatMap(_._2).flatMap(_.toTestRows)
Expand Down Expand Up @@ -1021,7 +1021,7 @@ class DeltaTableWritesSuite extends DeltaTableWriteSuiteBase with ParquetSuiteBa
}

def createTestTxn(
engine: Engine, tablePath: String, schema: Option[StructType] = None): Transaction = {
engine: Engine, tablePath: String, schema: Option[StructType] = None): Transaction = {
val table = Table.forPath(engine, tablePath)
var txnBuilder = table.createTransactionBuilder(engine, testEngineInfo, CREATE_TABLE)
schema.foreach(s => txnBuilder = txnBuilder.withSchema(engine, s))
Expand Down Expand Up @@ -1266,9 +1266,9 @@ class DeltaTableWritesSuite extends DeltaTableWriteSuiteBase with ParquetSuiteBa
}

private def assertColumnMapping(
field: StructField,
expId: Long,
expPhyName: String = "UUID"): Unit = {
field: StructField,
expId: Long,
expPhyName: String = "UUID"): Unit = {
val meta = field.getMetadata
assert(meta.get(ColumnMapping.COLUMN_MAPPING_ID_KEY) == expId)
// For new tables the physical column name is a UUID. For existing tables, we
Expand All @@ -1279,4 +1279,4 @@ class DeltaTableWritesSuite extends DeltaTableWriteSuiteBase with ParquetSuiteBa
assert(meta.get(ColumnMapping.COLUMN_MAPPING_PHYSICAL_NAME_KEY) == expPhyName)
}
}
}
}

0 comments on commit 13bb0a7

Please sign in to comment.