S3AFileSystem

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total6,038 of 6,0380%377 of 3770%4434431,3821,382245245
initialize(URI, Configuration)7020%360%191913913911
toString()2010%160%99383811
s3GetFileStatus(Path, String, Set, boolean)2000%340%1818454511
innerCreateFile(Path, Progressable, AuditSpan, CreateFileBuilder.CreateFileOptions)1690%140%88474711
createClientManager(URI, boolean)1630%40%33505011
initiateRename(Path, Path)1590%200%1111333311
copyFile(String, String, long, S3ObjectAttributes, S3AReadOpContext)1390%60%44272711
initThreadPools(Configuration)1250%60%44222211
createRequestFactory()1180%80%55303011
removeKeysS3(List, boolean)1120%120%77292911
hasPathCapability(Path, String)910%260%2323252511
executeOpen(Path, OpenFileSupport.OpenFileInformation)870%20%22202011
lambda$stopAllServices$24()870%20%22171711
deleteWithoutCloseCheck(Path, boolean)840%20%22212111
innerListFiles(Path, boolean, Listing.FileStatusAcceptor, S3AFileStatus)660%100%66191911
createStoreContext()620%n/a11202011
lambda$access$20(Path, FsAction)610%40%339911
S3AFileSystem()580%n/a11141411
innerRename(Path, Path)580%n/a11111111
copyFromLocalFile(boolean, boolean, Path, Path)550%20%228811
rename(Path, Path)530%n/a11101011
createNonRecursive(Path, FsPermission, EnumSet, int, short, long, Progressable)510%20%22131311
lambda$continueListObjects$13(S3ListResult, S3ListRequest)510%40%339911
innerListStatus(Path)470%40%33121211
createFile(Path)460%n/a11121211
getFileStatus(Path)450%60%447711
abortMultipartUpload(MultipartUpload)450%20%229911
makeQualified(Path)420%80%559911
putObjectDirect(PutObjectRequest, PutObjectOptions, S3ADataBlocks.BlockUploadData, DurationTrackerFactory)420%n/a11131311
lambda$copyFile$27(CopyObjectRequest, ChangeTracker, String, String)410%20%22141411
verifyBucketExists()390%20%224411
processDeleteOnExit()380%20%22121211
lambda$listLocatedStatus$38(Path, PathFilter, AuditSpan)370%60%44121211
listAWSPolicyRules(Set)350%80%55101011
createMultipartUploader(Path)350%20%228811
addDeprecatedKeys()340%20%225511
listObjects(S3ListRequest, DurationTrackerFactory)340%n/a117711
createReadContext(FileStatus, AuditSpan)330%n/a116611
innerGetFileStatus(Path, boolean, Set)330%n/a115511
close()330%40%33111111
createBulkDelete(Path)330%20%226611
lambda$copyFile$28(String, String, long, CopyObjectRequest, ChangeTracker)330%n/a116611
createS3AStore(ClientManager, int)320%n/a11121211
doBucketProbing()320%50%44121211
uploadPart(UploadPartRequest, RequestBody, DurationTrackerFactory)320%n/a11101011
lambda$verifyBucketExists$1()320%60%447711
continueListObjects(S3ListRequest, S3ListResult, DurationTrackerFactory)310%n/a116611
executePut(PutObjectRequest, Progressable, PutObjectOptions, File)310%n/a116611
listMultipartUploads(String)310%60%444411
initMultipartUploads(Configuration)300%20%22101011
create(Path, FsPermission, boolean, int, short, long, Progressable)290%40%337711
createEmptyObject(String, PutObjectOptions)290%n/a115511
getFileChecksum(Path, long)290%40%335511
extractOrFetchSimpleFileStatus(Path, OpenFileSupport.OpenFileInformation)290%40%336611
listLocatedStatus(Path, PathFilter)280%n/a116611
listUploadsUnderPrefix(StoreContext, String)280%60%444411
lambda$getBucketMetadata$10()280%n/a114411
abortOutstandingMultipartUploads(long)270%20%225511
pathToKey(Path)270%60%445511
createListObjectsRequest(String, String, int)270%20%227711
openFileWithOptions(Path, OpenFileParameters)270%n/a117711
createTmpFileForWrite(String, long, Configuration)260%n/a115511
mkdirs(Path, FsPermission)260%n/a116611
lambda$abortOutstandingMultipartUploads$3(Instant)260%40%339911
initLocalDirAllocatorIfNotInitialized(Configuration)250%40%337711
stopAllServices()240%n/a116611
lambda$getFileChecksum$35(Path)240%20%224411
populateVectoredIOContext(Configuration)230%n/a116611
getDelegationToken(String)230%20%226611
operationRetried(Exception)220%20%227711
createFileSystemHandler()210%40%335511
deleteObjects(DeleteObjectsRequest)210%20%225511
createFakeDirectoryIfNecessary(Path)210%40%335511
removeKeys(List, boolean)200%n/a114411
getCanonicalServiceName()200%40%336611
access(Path, FsAction)190%n/a114411
deleteOnExit(Path)190%n/a115511
initCannedAcls(Configuration)180%20%225511
createObjectAttributes(Path, String, String, long)180%n/a114411
trackDurationAndSpan(Statistic, String, String, CallableRaisingIOE)180%n/a114411
getContentSummary(Path)180%n/a114411
getXAttr(Path, String)180%n/a115511
getXAttrs(Path, List)180%n/a115511
lambda$getDelegationToken$25(String)180%20%222211
initializeStatisticsBinding()170%n/a114411
createWriteOperationHelper(AuditSpan)170%n/a113311
getAdditionalTokenIssuers()170%20%225511
exists(Path)170%n/a115511
isDirectory(Path)170%n/a114411
isFile(Path)170%n/a114411
getXAttrs(Path)170%n/a115511
listXAttrs(Path)170%n/a115511
listUploads(String)170%n/a113311
createMarkerToolOperations(String)170%n/a112211
lambda$listMultipartUploads$40(String)170%n/a113311
lambda$listObjects$12(S3ListRequest)170%20%223311
abortMultipartUploadsUnderPrefix(StoreContext, AuditSpan, String)160%n/a115511
getObjectMetadata(Path, ChangeTracker, Invoker, String)160%n/a112211
maybeCreateFakeParentDirectory(Path)160%60%444411
s3Exists(Path, Set)160%n/a115511
cancelDeleteOnExit(Path)160%n/a113311
finishedWrite(String, long, PutObjectOptions)160%20%224411
toLocatedFileStatus(S3AFileStatus)160%20%224411
abortMultipartUpload(String, String)160%n/a113311
hasCapability(String)160%n/a114411
validateListArguments(S3ListRequest)150%40%334411
getPutRequestLength(PutObjectRequest)150%20%223311
listStatusIterator(Path)150%n/a112211
initiateMultipartUpload(CreateMultipartUploadRequest)150%n/a113311
listFiles(Path, boolean)150%n/a113311
lambda$copyFromLocalFile$22(Path, Path, boolean, boolean)150%n/a114411
deleteObjectAtPath(Path, String, boolean)140%20%225511
listFilesAndEmptyDirectories(Path, boolean)140%n/a112211
setUri(URI, boolean)130%20%223311
trackDurationAndSpan(Statistic, Path, CallableRaisingIOE)130%20%222211
deleteObject(String)130%n/a115511
listStatus(Path)130%n/a112211
lambda$createEmptyObject$30(String, PutObjectOptions, S3ADataBlocks.BlockUploadData)130%n/a113311
setAmazonS3Client(S3Client)120%n/a114411
keyToPath(String)120%n/a111111
entryPoint(Statistic, Path)120%20%222211
entryPoint(Statistic, String, String)120%n/a113311
getBucketMetadata()120%n/a112211
noteDeleted(int, boolean)120%20%224411
createCopyFromLocalCallbacks(AuditSpanS3A)120%n/a112211
checkNotClosed()120%20%223311
setEncryptionSecrets(EncryptionSecrets)110%20%224411
createBulkDeleteCallbacks(Path, int, AuditSpanS3A)110%n/a111111
lambda$abortMultipartUpload$41(String, String)110%n/a113311
lambda$globStatus$31(Path, PathFilter)110%n/a116611
lambda$putObjectDirect$14(PutObjectRequest, UploadContentProviders.BaseContentProvider)110%n/a113311
lambda$getBucketMetadata$11()110%n/a111111
lambda$abortMultipartUploadsUnderPrefix$8(MultipartUpload)110%n/a111111
lambda$verifyBucketExists$2()110%n/a111111
open(Path, int)100%n/a112211
createObjectAttributes(Path, S3AFileStatus)100%n/a114411
getObjectMetadata(String, ChangeTracker, Invoker, String)100%n/a111111
globStatus(Path, PathFilter)100%n/a111111
lambda$listFiles$36(Path, boolean)100%n/a111111
static {...}100%n/a114411
initializeAuditService()90%n/a114411
checkPath(Path)90%n/a112211
getIOStatistics()90%20%223311
getDurationTrackerFactory()90%20%223311
lambda$listStatus$19(Path)90%n/a111111
lambda$listStatusIterator$17(Path, Path)90%n/a111111
createClientManager(S3ClientFactory, S3ClientFactory, S3ClientFactory.S3ClientCreationParameters, DurationTrackerFactory)80%n/a111111
createSpan(String, String, String)80%n/a111111
getObjectMetadata(String)80%n/a111111
newPutObjectRequestBuilder(String, long, boolean)80%n/a111111
getHeaderProcessing()80%n/a112211
shareCredentials(String)80%n/a112211
lambda$isFile$34(Path)80%n/a112211
lambda$isDirectory$33(Path)80%n/a112211
lambda$copyFromLocalFile$23(boolean, boolean, Path, Path)80%n/a112211
lambda$create$5(Path, Progressable, CreateFileBuilder.CreateFileOptions)80%n/a112211
createStorageStatistics(IOStatistics)70%n/a112211
createInputStreamCallbacks(AuditSpan)70%n/a111111
putObject(PutObjectRequest, File, ProgressableProgressListener)70%n/a111111
delete(Path, boolean)70%n/a112211
createListObjectsRequest(String, String)70%n/a111111
lambda$openFileWithOptions$43(CompletableFuture, Path, OpenFileSupport.OpenFileInformation)70%n/a111111
lambda$listFilesAndEmptyDirectories$37(Path, boolean)70%n/a111111
lambda$copyFile$26(String, ChangeTracker, Invoker)70%n/a111111
lambda$getObjectMetadata$9(String, ChangeTracker, Invoker, String)70%n/a111111
createDelegationOperations()60%n/a111111
getBucketLocation()60%n/a111111
createS3AInternals()60%n/a111111
keyToQualifiedPath(String)60%n/a111111
incrementStatistic(Statistic, long)60%n/a112211
decrementGauge(Statistic, long)60%n/a112211
incrementGauge(Statistic, long)60%n/a112211
incrementPutCompletedStatistics(boolean, long)60%n/a112211
incrementPutProgressStatistics(String, long)60%n/a112211
setWorkingDirectory(Path)60%n/a112211
getDefaultBlockSize()60%n/a111111
lambda$listMultipartUploads$39(ListMultipartUploadsRequest)60%n/a111111
lambda$exists$32(Path)60%n/a111111
lambda$getFileStatus$21(Path)60%n/a111111
lambda$uploadPart$15(UploadPartRequest, RequestBody)60%n/a111111
lambda$rename$6(Path, Path)60%n/a111111
getActiveAuditSpan()0%n/a111111
canonicalizeUri(URI)0%n/a111111
getWriteOperationHelper()0%n/a111111
append(Path, int, Progressable)0%n/a111111
getObjectMetadata(Path)0%n/a111111
incrementStatistic(Statistic)0%n/a112211
nonNullDurationTrackerFactory(DurationTrackerFactory)0%n/a111111
incrementReadOperations()0%n/a112211
incrementWriteOperations()0%n/a112211
incrementPutStartStatistics(long)0%n/a112211
createMkdirOperationCallbacks()0%n/a111111
createGetContentSummaryCallbacks()0%n/a111111
createFakeDirectory(String, PutObjectOptions)0%n/a112211
isMagicCommitPath(Path)0%n/a111111
isUnderMagicCommitPath(Path)0%n/a111111
globStatus(Path)0%n/a111111
createHeaderProcessingCallbacks()0%n/a111111
listLocatedStatus(Path)0%n/a111111
lambda$openFileWithOptions$42(Path, OpenFileSupport.OpenFileInformation)0%n/a111111
lambda$initiateMultipartUpload$29(CreateMultipartUploadRequest)0%n/a111111
lambda$listStatus$18(Path)0%n/a111111
lambda$executeOpen$4(Path, OpenFileSupport.OpenFileInformation)0%n/a111111
lambda$createStorageStatistics$0(IOStatistics)0%n/a111111
getAuditor()0%n/a111111
getS3EncryptionAlgorithm()0%n/a111111
setBucket(String)0%n/a112211
setInputPolicy(S3AInputPolicy)0%n/a112211
qualify(Path)0%n/a111111
getFsDelegationToken()0%n/a111111
operationRetried(String, Exception, int, boolean)0%n/a112211
isMagicCommitEnabled()0%n/a111111
newCommitterStatistics()0%n/a111111
initializeClass()0%n/a112211
lambda$listStatusIterator$16(Path)0%n/a111111
lambda$abortMultipartUploadsUnderPrefix$7(MultipartUpload)0%n/a111111
getInstrumentation()0%n/a111111
getFsStatistics()0%n/a111111
getListing()0%n/a111111
getAuditManager()0%n/a111111
getRequestFactory()0%n/a111111
getPerformanceFlags()0%n/a111111
getEncryptionSecrets()0%n/a111111
getScheme()0%n/a111111
getUri()0%n/a111111
getCanonicalUri()0%n/a111111
getS3Client()0%n/a111111
getS3AInternals()0%n/a111111
getInputPolicy()0%n/a111111
getChangeDetectionPolicy()0%n/a111111
getBucket()0%n/a111111
getCannedACL()0%n/a111111
maybeAddTrailingSlash(String)0%n/a111111
getStorageStatistics()0%n/a111111
getWorkingDirectory()0%n/a111111
getUsername()0%n/a111111
getOwner()0%n/a111111
getDelegationTokens()0%n/a111111
getPartitionSize()0%n/a111111
getMultiPartThreshold()0%n/a111111
getMaxKeys()0%n/a111111
isCSEEnabled()0%n/a111111
isMultipartUploadEnabled()0%n/a111111
getAuditSpanSource()0%n/a111111
getDefaultPort()0%n/a111111