docs: static <IN, BucketID> Bucket<IN, BucketID> getNew(
  			final RecoverableWriter fsWriter,
  			final int subtaskIndex,
  			final BucketID bucketId,
  			final Path bucketPath,
  			final long initialPartCounter,
  			final PartFileWriter.PartFileFactory<IN, BucketID> partFileFactory,
  			final RollingPolicy<IN, BucketID> rollingPolicy) {
  		return new Bucket<>(fsWriter, subtaskIndex, bucketId, bucketPath, initialPartCounter, partFileFactory, rollingPolicy);
  	}