| ensureInitialized(Long, Map) |   | 71% | | 66% | 2 | 4 | 6 | 21 | 0 | 1 |
| rewriteTvfParams(InsertIntoTableCommand, Offset, long) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| fetchRemoteMeta(StreamingJobProperties, Map) | | 96% | | 92% | 2 | 15 | 2 | 51 | 0 | 1 |
| renewBatchVisibility(SqsClient, S3EventSourceOffsetProvider.TaskBatch, List, int) | | 93% | | 100% | 0 | 8 | 2 | 27 | 0 | 1 |
| closeClientResources(FileSystem, SqsClient) | | 72% | | 100% | 0 | 3 | 2 | 11 | 0 | 1 |
| parseMessages(SqsClient, ObjStorage, List, List) | | 91% | | 75% | 1 | 3 | 1 | 13 | 0 | 1 |
| isCommitted(String, String, String) | | 88% | | 91% | 1 | 7 | 1 | 7 | 0 | 1 |
| releaseMessages(SqsClient, List) | | 85% | | 100% | 0 | 3 | 2 | 9 | 0 | 1 |
| restoreFromPersistInfo(String) | | 70% | | 100% | 0 | 2 | 2 | 7 | 0 | 1 |
| fetchRemoteMeta(Map) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| validateAlterOffset(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$collectReceiptsToRelease$6(S3EventSourceOffsetProvider.ParsedMessage) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| onTaskCommitted(long, long) | | 96% | | 50% | 3 | 4 | 0 | 9 | 0 | 1 |
| lambda$collectReceiptsToRelease$5(S3EventSourceOffsetProvider.ParsedMessage) | | 75% | | 50% | 1 | 2 | 0 | 1 | 0 | 1 |
| getSourceType() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| deserializeOffsetProperty(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| makeReadyBatch(List, List, List, Map, long) | | 97% | | 66% | 2 | 4 | 0 | 6 | 0 | 1 |
| getCommitOffsetJson(Offset, long, List) | | 96% | | 75% | 1 | 3 | 0 | 5 | 0 | 1 |
| getNextOffset(StreamingJobProperties, Map) | | 96% | | 75% | 1 | 3 | 0 | 6 | 0 | 1 |
| parseMessage(Message, ObjStorage) | | 100% | | 86% | 6 | 23 | 0 | 68 | 0 | 1 |
| receiveBatch(SqsClient, ObjStorage, StreamingJobProperties, int) | | 100% | | 91% | 2 | 13 | 0 | 54 | 0 | 1 |
| deletePendingMessages(SqsClient, List) | | 100% | | 87% | 1 | 5 | 0 | 32 | 0 | 1 |
| replayIfNeed(StreamingInsertJob) | | 100% | | 94% | 1 | 10 | 0 | 19 | 0 | 1 |
| changeMessageVisibility(SqsClient, List, int) | | 100% | | 100% | 0 | 3 | 0 | 17 | 0 | 1 |
| refreshApproximateNumberOfMessages(SqsClient) | | 100% | | 50% | 2 | 3 | 0 | 15 | 0 | 1 |
| getShowMaxOffset() | | 100% | | 100% | 0 | 6 | 0 | 9 | 0 | 1 |
| deleteSkippedMessages(SqsClient, List, List) | | 100% | | 100% | 0 | 2 | 0 | 15 | 0 | 1 |
| logBatchFailures(String, List) | | 100% | | 100% | 0 | 3 | 0 | 8 | 0 | 1 |
| close() | | 100% | | n/a | 0 | 1 | 0 | 10 | 0 | 1 |
| buildDeleteEntries(List) | | 100% | | 100% | 0 | 2 | 0 | 7 | 0 | 1 |
| isInvalidReceipt(BatchResultErrorEntry) | | 100% | | 75% | 2 | 5 | 0 | 4 | 0 | 1 |
| collectReceiptsToRelease(List, List) | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
| lastFileName(S3EventOffset) | | 100% | | 75% | 1 | 3 | 0 | 4 | 0 | 1 |
| lambda$deletePendingMessages$8(Set, Map.Entry) | | 100% | | 100% | 0 | 3 | 0 | 3 | 0 | 1 |
| static {...} | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
| getShowCurrentOffset() | | 100% | | 100% | 0 | 2 | 0 | 2 | 0 | 1 |
| createSqsClient(S3Client) | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
| rememberCommittedBatch(S3EventSourceOffsetProvider.TaskBatch) | | 100% | | 100% | 0 | 2 | 0 | 4 | 0 | 1 |
| getRetryableReceiptHandles(List, List) | | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
| S3EventSourceOffsetProvider(String) | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
| hasMoreDataToConsume() | | 100% | | 75% | 1 | 3 | 0 | 1 | 0 | 1 |
| getLagMessages() | | 100% | | 100% | 0 | 2 | 0 | 1 | 0 | 1 |
| getPersistInfo() | | 100% | | 100% | 0 | 2 | 0 | 1 | 0 | 1 |
| lambda$rememberCommittedBatch$12(String, Map) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$invalidateReceipts$13(Set, String, String) | | 100% | | 100% | 0 | 2 | 0 | 1 | 0 | 1 |
| lambda$getRetryableReceiptHandles$9(BatchResultErrorEntry) | | 100% | | 100% | 0 | 2 | 0 | 1 | 0 | 1 |
| lambda$getRetryableReceiptHandles$10(List, BatchResultErrorEntry) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$deletePendingMessages$7(List, DeleteMessageBatchResultEntry) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| deserializeOffset(String) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| invalidateReceipts(Map, Set) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| updateOffset(Offset) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| lambda$invalidateReceipts$14(Set, Map) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$rememberCommittedBatch$11(String) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$isCommitted$4(String) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$deleteSkippedMessages$2(S3EventSourceOffsetProvider.ParsedMessage) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$receiveBatch$1(String) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$receiveBatch$0(S3EventSourceOffsetProvider.ParsedMessage) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| getLastSourceEventTimestampSeconds() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$deleteSkippedMessages$3(S3EventSourceOffsetProvider.ParsedMessage) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |