79
79
import org .apache .iceberg .relocated .com .google .common .collect .Streams ;
80
80
import org .apache .iceberg .types .Types ;
81
81
import org .apache .iceberg .util .CharSequenceSet ;
82
- import org .junit .jupiter .api .Assumptions ;
83
82
import org .junit .jupiter .api .Test ;
84
83
import org .junit .jupiter .params .ParameterizedTest ;
85
84
import org .junit .jupiter .params .provider .ValueSource ;
@@ -228,7 +227,7 @@ public void testCreateExistingNamespace() {
228
227
229
228
@ Test
230
229
public void testCreateNamespaceWithProperties () {
231
- Assumptions . assumeTrue (supportsNamespaceProperties ());
230
+ assumeThat (supportsNamespaceProperties ()). isTrue ( );
232
231
233
232
C catalog = catalog ();
234
233
@@ -264,7 +263,7 @@ public void testLoadNamespaceMetadata() {
264
263
265
264
@ Test
266
265
public void testSetNamespaceProperties () {
267
- Assumptions . assumeTrue (supportsNamespaceProperties ());
266
+ assumeThat (supportsNamespaceProperties ()). isTrue ( );
268
267
269
268
C catalog = catalog ();
270
269
@@ -281,7 +280,7 @@ public void testSetNamespaceProperties() {
281
280
282
281
@ Test
283
282
public void testUpdateNamespaceProperties () {
284
- Assumptions . assumeTrue (supportsNamespaceProperties ());
283
+ assumeThat (supportsNamespaceProperties ()). isTrue ( );
285
284
286
285
C catalog = catalog ();
287
286
@@ -307,7 +306,7 @@ public void testUpdateNamespaceProperties() {
307
306
308
307
@ Test
309
308
public void testUpdateAndSetNamespaceProperties () {
310
- Assumptions . assumeTrue (supportsNamespaceProperties ());
309
+ assumeThat (supportsNamespaceProperties ()). isTrue ( );
311
310
312
311
C catalog = catalog ();
313
312
@@ -334,7 +333,7 @@ public void testUpdateAndSetNamespaceProperties() {
334
333
335
334
@ Test
336
335
public void testSetNamespacePropertiesNamespaceDoesNotExist () {
337
- Assumptions . assumeTrue (supportsNamespaceProperties ());
336
+ assumeThat (supportsNamespaceProperties ()). isTrue ( );
338
337
339
338
C catalog = catalog ();
340
339
@@ -345,7 +344,7 @@ public void testSetNamespacePropertiesNamespaceDoesNotExist() {
345
344
346
345
@ Test
347
346
public void testRemoveNamespaceProperties () {
348
- Assumptions . assumeTrue (supportsNamespaceProperties ());
347
+ assumeThat (supportsNamespaceProperties ()). isTrue ( );
349
348
350
349
C catalog = catalog ();
351
350
@@ -366,7 +365,7 @@ public void testRemoveNamespaceProperties() {
366
365
367
366
@ Test
368
367
public void testRemoveNamespacePropertiesNamespaceDoesNotExist () {
369
- Assumptions . assumeTrue (supportsNamespaceProperties ());
368
+ assumeThat (supportsNamespaceProperties ()). isTrue ( );
370
369
371
370
C catalog = catalog ();
372
371
@@ -454,8 +453,9 @@ public void testListNamespaces() {
454
453
455
454
@ Test
456
455
public void testListNestedNamespaces () {
457
- Assumptions .assumeTrue (
458
- supportsNestedNamespaces (), "Only valid when the catalog supports nested namespaces" );
456
+ assumeThat (supportsNestedNamespaces ())
457
+ .as ("Only valid when the catalog supports nested namespaces" )
458
+ .isTrue ();
459
459
460
460
C catalog = catalog ();
461
461
@@ -500,7 +500,7 @@ public void testListNestedNamespaces() {
500
500
501
501
@ Test
502
502
public void testNamespaceWithSlash () {
503
- Assumptions . assumeTrue (supportsNamesWithSlashes ());
503
+ assumeThat (supportsNamesWithSlashes ()). isTrue ( );
504
504
505
505
C catalog = catalog ();
506
506
@@ -521,7 +521,7 @@ public void testNamespaceWithSlash() {
521
521
522
522
@ Test
523
523
public void testNamespaceWithDot () {
524
- Assumptions . assumeTrue (supportsNamesWithDot ());
524
+ assumeThat (supportsNamesWithDot ()). isTrue ( );
525
525
526
526
C catalog = catalog ();
527
527
@@ -568,7 +568,7 @@ public void testBasicCreateTable() {
568
568
569
569
@ Test
570
570
public void testTableNameWithSlash () {
571
- Assumptions . assumeTrue (supportsNamesWithSlashes ());
571
+ assumeThat (supportsNamesWithSlashes ()). isTrue ( );
572
572
573
573
C catalog = catalog ();
574
574
@@ -594,7 +594,7 @@ public void testTableNameWithSlash() {
594
594
595
595
@ Test
596
596
public void testTableNameWithDot () {
597
- Assumptions . assumeTrue (supportsNamesWithDot ());
597
+ assumeThat (supportsNamesWithDot ()). isTrue ( );
598
598
599
599
C catalog = catalog ();
600
600
@@ -1333,9 +1333,9 @@ public void testUUIDValidation() {
1333
1333
1334
1334
@ Test
1335
1335
public void testUpdateTableSchemaServerSideRetry () {
1336
- Assumptions . assumeTrue (
1337
- supportsServerSideRetry (),
1338
- "Schema update recovery is only supported with server-side retry" );
1336
+ assumeThat ( supportsServerSideRetry ())
1337
+ . as ( "Schema update recovery is only supported with server-side retry" )
1338
+ . isTrue ( );
1339
1339
C catalog = catalog ();
1340
1340
1341
1341
if (requiresNamespaceCreate ()) {
@@ -1471,8 +1471,9 @@ public void testUpdateTableSpec() {
1471
1471
1472
1472
@ Test
1473
1473
public void testUpdateTableSpecServerSideRetry () {
1474
- Assumptions .assumeTrue (
1475
- supportsServerSideRetry (), "Spec update recovery is only supported with server-side retry" );
1474
+ assumeThat (supportsServerSideRetry ())
1475
+ .as ("Spec update recovery is only supported with server-side retry" )
1476
+ .isTrue ();
1476
1477
C catalog = catalog ();
1477
1478
1478
1479
if (requiresNamespaceCreate ()) {
@@ -1739,9 +1740,9 @@ public void testUpdateTableSortOrder() {
1739
1740
1740
1741
@ Test
1741
1742
public void testUpdateTableSortOrderServerSideRetry () {
1742
- Assumptions . assumeTrue (
1743
- supportsServerSideRetry (),
1744
- "Sort order update recovery is only supported with server-side retry" );
1743
+ assumeThat ( supportsServerSideRetry ())
1744
+ . as ( "Sort order update recovery is only supported with server-side retry" )
1745
+ . isTrue ( );
1745
1746
C catalog = catalog ();
1746
1747
1747
1748
if (requiresNamespaceCreate ()) {
@@ -2398,9 +2399,9 @@ public void testCompleteCreateOrReplaceTransactionReplace() {
2398
2399
2399
2400
@ Test
2400
2401
public void testCreateOrReplaceTransactionConcurrentCreate () {
2401
- Assumptions . assumeTrue (
2402
- supportsServerSideRetry (),
2403
- "Conversion to replace transaction is not supported by REST catalog" );
2402
+ assumeThat ( supportsServerSideRetry ())
2403
+ . as ( "Conversion to replace transaction is not supported by REST catalog" )
2404
+ . isTrue ( );
2404
2405
2405
2406
C catalog = catalog ();
2406
2407
@@ -2735,7 +2736,7 @@ public void testConcurrentReplaceTransactionSchema2() {
2735
2736
2736
2737
@ Test
2737
2738
public void testConcurrentReplaceTransactionSchemaConflict () {
2738
- Assumptions . assumeTrue (supportsServerSideRetry (), "Schema conflicts are detected server-side" );
2739
+ assumeThat (supportsServerSideRetry ()). as ( "Schema conflicts are detected server-side" ). isTrue ( );
2739
2740
2740
2741
C catalog = catalog ();
2741
2742
@@ -2855,7 +2856,7 @@ public void testConcurrentReplaceTransactionPartitionSpec2() {
2855
2856
2856
2857
@ Test
2857
2858
public void testConcurrentReplaceTransactionPartitionSpecConflict () {
2858
- Assumptions . assumeTrue (supportsServerSideRetry (), "Spec conflicts are detected server-side" );
2859
+ assumeThat (supportsServerSideRetry ()). as ( "Spec conflicts are detected server-side" ). isTrue ( );
2859
2860
C catalog = catalog ();
2860
2861
2861
2862
if (requiresNamespaceCreate ()) {
@@ -3067,7 +3068,7 @@ public void testMetadataFileLocationsRemovalAfterCommit() {
3067
3068
3068
3069
@ Test
3069
3070
public void tableCreationWithoutNamespace () {
3070
- Assumptions . assumeTrue (requiresNamespaceCreate ());
3071
+ assumeThat (requiresNamespaceCreate ()). isTrue ( );
3071
3072
3072
3073
assertThatThrownBy (
3073
3074
() ->
0 commit comments