Skip to content

Commit

Permalink
fix format violations
Browse files Browse the repository at this point in the history
  • Loading branch information
柯海林 committed Dec 17, 2024
1 parent de473fb commit 426462c
Show file tree
Hide file tree
Showing 3 changed files with 18 additions and 15 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,13 @@
*/
package org.apache.iceberg.spark.extensions;

import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatThrownBy;
import static org.assertj.core.api.Assumptions.assumeThat;
import static org.mockito.Mockito.doAnswer;
import static org.mockito.Mockito.spy;
import static org.mockito.Mockito.when;

import java.util.List;
import java.util.Locale;
import java.util.Map;
Expand Down Expand Up @@ -49,13 +56,6 @@
import org.junit.jupiter.api.TestTemplate;
import org.junit.jupiter.api.extension.ExtendWith;

import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatThrownBy;
import static org.assertj.core.api.Assumptions.assumeThat;
import static org.mockito.Mockito.doAnswer;
import static org.mockito.Mockito.spy;
import static org.mockito.Mockito.when;

@ExtendWith(ParameterizedTestExtension.class)
public class TestMergeOnReadWithIdentifierFieldsDelete extends TestDelete {

Expand All @@ -72,7 +72,9 @@ public void clearTestSparkCatalogCache() {

@TestTemplate
public void testDeleteWithExecutorCacheLocality() throws NoSuchTableException {
sql("CREATE TABLE %s (id INT NOT NULL, dep STRING) USING iceberg PARTITIONED BY (dep)", tableName);
sql(
"CREATE TABLE %s (id INT NOT NULL, dep STRING) USING iceberg PARTITIONED BY (dep)",
tableName);

sql("ALTER TABLE %s SET IDENTIFIER FIELDS id", tableName);

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,9 @@
*/
package org.apache.iceberg.spark.extensions;

import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assumptions.assumeThat;

import java.util.List;
import java.util.Map;
import java.util.Set;
Expand All @@ -37,9 +40,6 @@
import org.apache.spark.sql.Encoders;
import org.junit.jupiter.api.TestTemplate;

import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assumptions.assumeThat;

public class TestMergeOnReadWithIdentifierFieldsMerge extends TestMerge {

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,9 @@
*/
package org.apache.iceberg.spark.extensions;

import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assumptions.assumeThat;

import java.util.List;
import java.util.Map;
import java.util.Set;
Expand All @@ -37,9 +40,6 @@
import org.junit.jupiter.api.TestTemplate;
import org.junit.jupiter.api.extension.ExtendWith;

import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assumptions.assumeThat;

@ExtendWith(ParameterizedTestExtension.class)
public class TestMergeOnReadWithIdentifierFieldsUpdate extends TestUpdate {

Expand Down Expand Up @@ -212,7 +212,8 @@ public void testUpdateWithDVAndHistoricalPositionDeletes() {
}

private void initTable(String partitionedBy, DeleteGranularity deleteGranularity) {
createTableWithDeleteGranularity("id INT NOT NULL, dep STRING", partitionedBy, deleteGranularity);
createTableWithDeleteGranularity(
"id INT NOT NULL, dep STRING", partitionedBy, deleteGranularity);

sql("ALTER TABLE %s SET IDENTIFIER FIELDS id", tableName);

Expand Down

0 comments on commit 426462c

Please sign in to comment.