| parseMessage(Message) |  | 0% | | 0% | 23 | 23 | 59 | 59 | 1 | 1 |
| receiveBatch(SqsClient, StreamingJobProperties, int) |  | 9% | | 0% | 12 | 13 | 48 | 54 | 0 | 1 |
| deletePendingMessages(SqsClient, List) | | 0% | | 0% | 5 | 5 | 32 | 32 | 1 | 1 |
| renewBatchVisibility(SqsClient, S3EventSourceOffsetProvider.TaskBatch, List, int) | | 0% | | 0% | 8 | 8 | 27 | 27 | 1 | 1 |
| replayIfNeed(StreamingInsertJob) | | 27% | | 38% | 7 | 10 | 11 | 19 | 0 | 1 |
| fetchRemoteMeta(StreamingJobProperties, Map) | | 62% | | 42% | 12 | 15 | 16 | 50 | 0 | 1 |
| changeMessageVisibility(SqsClient, List, int) | | 0% | | 0% | 3 | 3 | 17 | 17 | 1 | 1 |
| parseMessages(SqsClient, List, List) | | 0% | | 0% | 3 | 3 | 13 | 13 | 1 | 1 |
| onTaskCommitted(long, long) | | 0% | | 0% | 4 | 4 | 9 | 9 | 1 | 1 |
| getShowMaxOffset() | | 0% | | 0% | 6 | 6 | 9 | 9 | 1 | 1 |
| isCommitted(String, String, String) | | 0% | | 0% | 7 | 7 | 7 | 7 | 1 | 1 |
| deleteSkippedMessages(SqsClient, List, List) | | 0% | | 0% | 2 | 2 | 15 | 15 | 1 | 1 |
| releaseMessages(SqsClient, List) | | 0% | | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
| makeReadyBatch(List, List, List, Map, long) | | 0% | | 0% | 4 | 4 | 6 | 6 | 1 | 1 |
| logBatchFailures(String, List) | | 0% | | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
| getCommitOffsetJson(Offset, long, List) | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
| buildDeleteEntries(List) | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| getNextOffset(StreamingJobProperties, Map) | | 0% | | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
| isInvalidReceipt(BatchResultErrorEntry) | | 0% | | 0% | 5 | 5 | 4 | 4 | 1 | 1 |
| ensureInitialized(Long, Map) | | 71% | | 50% | 3 | 4 | 6 | 21 | 0 | 1 |
| collectReceiptsToRelease(List, List) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| lastFileName(S3EventOffset) | | 0% | | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
| lambda$deletePendingMessages$8(Set, Map.Entry) | | 0% | | 0% | 3 | 3 | 3 | 3 | 1 | 1 |
| getShowCurrentOffset() | | 0% | | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
| closeClientResources(FileSystem, SqsClient) | | 44% | | 100% | 0 | 3 | 4 | 11 | 0 | 1 |
| restoreFromPersistInfo(String) | | 17% | | 100% | 0 | 2 | 5 | 7 | 0 | 1 |
| rememberCommittedBatch(S3EventSourceOffsetProvider.TaskBatch) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| getRetryableReceiptHandles(List, List) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| refreshApproximateNumberOfMessages(SqsClient) | | 80% | | 25% | 2 | 3 | 3 | 15 | 0 | 1 |
| hasMoreDataToConsume() | | 0% | | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
| getPersistInfo() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$rememberCommittedBatch$12(String, Map) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| rewriteTvfParams(InsertIntoTableCommand, Offset, long) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$invalidateReceipts$13(Set, String, String) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$getRetryableReceiptHandles$9(BatchResultErrorEntry) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$collectReceiptsToRelease$5(S3EventSourceOffsetProvider.ParsedMessage) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$getRetryableReceiptHandles$10(List, BatchResultErrorEntry) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$deletePendingMessages$7(List, DeleteMessageBatchResultEntry) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| deserializeOffset(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| invalidateReceipts(Map, Set) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| fetchRemoteMeta(Map) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| validateAlterOffset(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$invalidateReceipts$14(Set, Map) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$rememberCommittedBatch$11(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$isCommitted$4(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$deleteSkippedMessages$2(S3EventSourceOffsetProvider.ParsedMessage) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$receiveBatch$1(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$receiveBatch$0(S3EventSourceOffsetProvider.ParsedMessage) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$collectReceiptsToRelease$6(S3EventSourceOffsetProvider.ParsedMessage) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$deleteSkippedMessages$3(S3EventSourceOffsetProvider.ParsedMessage) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getSourceType() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| deserializeOffsetProperty(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| close() | | 100% | | n/a | 0 | 1 | 0 | 10 | 0 | 1 |
| static {...} | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
| createSqsClient(S3Client) | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
| S3EventSourceOffsetProvider(String) | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
| getLagMessages() | | 100% | | 100% | 0 | 2 | 0 | 1 | 0 | 1 |
| updateOffset(Offset) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| getLastSourceEventTimestampSeconds() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |