CollectionSize.ANY,
    ALLOWS_NULL_VALUES,
    SUPPORTS_REMOVE,
    CollectionFeature.SUPPORTS_ITERATOR_REMOVE,
    MultisetTestSuiteBuilder.NoRecurse.NO_ENTRY_SET, // Cannot create entries with count > 1
  };

  static final Supplier<TreeSet<String>> STRING_TREESET_FACTORY =
      new Supplier<TreeSet<String>>() {
        @Override
        public TreeSet<String> get() {

scala> counts.saveAsTextFile("s3a://testbucket/wordcount")
```

Use one of the following approaches to view job output:

View output in the Scala shell:

```
scala> counts.count()
364
```

To view the output from MinIO exit the Scala shell. View WordCount job status:

```
hadoop fs -ls s3a://testbucket/wordcount
```

The output should be similar to the following:

        loadTestData();

        int originalSize = stopwordsFile.stopwordsItemList.size();
        StopwordsItem item = stopwordsFile.get(1).get();
        stopwordsFile.delete(item);

        // Verify the item count decreased
        // Note: get(1) may still return an item if IDs are reassigned
        assertTrue(stopwordsFile.stopwordsItemList.size() < originalSize);
    }

    // Test reload with InputStream
    @Test

	"time"

	"github.com/minio/minio/internal/dsync"
)

// Reject new lock requests immediately when this many are queued
// for the local lock mutex.
// We do not block unlocking or maintenance, but they add to the count.
// The limit is set to allow for bursty behavior,
// but prevent requests to overload the server completely.
// Rejected clients are expected to retry.
const lockMutexWaitLimit = 1000

    //
    private static final Logger logger = LogManager.getLogger(AdminMaintenanceAction.class);

    private static final String[] CAT_NAMES =
            { "aliases", "allocation", "count", "fielddata", "health", "indices", "master", "nodeattrs", "nodes", "pending_tasks",
                    "plugins", "recovery", "repositories", "thread_pool", "shards", "segments", "snapshots", "templates" };

   *
   * @param array the source array
   * @param minLength the minimum length the returned array must guarantee
   * @param padding an extra amount to "grow" the array by if growth is necessary
   * @throws IllegalArgumentException if {@code minLength} or {@code padding} is negative
   * @return an array containing the values of {@code array}, with guaranteed minimum length {@code

        assertEquals(35000, socketTimeout, "Should delegate socket timeout");
        assertEquals(35000, connTimeout, "Should delegate connection timeout");
        assertEquals(10, maxMpx, "Should delegate max MPX count");

        verify(mockDelegate).getDfsTtl();
        verify(mockDelegate).getResponseTimeout();
        verify(mockDelegate).getSoTimeout();
        verify(mockDelegate).getConnTimeout();

        }

        @Test
        @DisplayName("Should calculate size for Unicode characters")
        void testSizeWithUnicodeCharacters() {
            // Unicode characters still count as single chars in Java
            String path = "\\\\server\\共享\\路径";
            buffer = new DfsReferralRequestBuffer(path, 3);

            int expectedSize = 4 + 2 * path.length();

                .desc("Encrypt server password")
                .build());
        options.addOption(Option.builder(THREADS)
                .longOpt("threads")
                .hasArg()
                .desc("Thread count, for instance 4 (int) or 2C/2.5C (int/float) where C is core multiplied")
                .build());
        options.addOption(Option.builder(BUILDER)
                .longOpt("builder")
                .hasArg()

// if sha256Hex is not the empty string.
//
// If size resp. actualSize is unknown at the time of calling
// NewReader then it should be set to -1.
// When size is >=0 it *must* match the amount of data provided by r.
//
// NewReader may try merge the given size, MD5 and SHA256 values
// into src - if src is a Reader - to avoid computing the same
// checksums multiple times.