| parseMessage(Message) |  | 0% | | 0% | 23 | 23 | 61 | 61 | 1 | 1 |
| receiveBatch(SqsClient, StreamingJobProperties, int) | | 0% | | 0% | 13 | 13 | 51 | 51 | 1 | 1 |
| fetchRemoteMeta(StreamingJobProperties, Map) | | 0% | | 0% | 15 | 15 | 50 | 50 | 1 | 1 |
| deletePendingMessages(SqsClient, List) | | 0% | | 0% | 5 | 5 | 32 | 32 | 1 | 1 |
| renewBatchVisibility(SqsClient, S3EventSourceOffsetProvider.TaskBatch, List, int) | | 0% | | 0% | 6 | 6 | 21 | 21 | 1 | 1 |
| ensureInitialized(Long, Map) | | 0% | | 0% | 4 | 4 | 21 | 21 | 1 | 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 |
| refreshApproximateNumberOfMessages(SqsClient) | | 0% | | 0% | 3 | 3 | 15 | 15 | 1 | 1 |
| getShowMaxOffset() | | 0% | | 0% | 6 | 6 | 9 | 9 | 1 | 1 |
| onTaskCommitted(long, long) | | 0% | | 0% | 4 | 4 | 8 | 8 | 1 | 1 |
| deleteSkippedMessages(SqsClient, List, List) | | 0% | | 0% | 2 | 2 | 15 | 15 | 1 | 1 |
| replayIfNeed(StreamingInsertJob) | | 0% | | 0% | 5 | 5 | 9 | 9 | 1 | 1 |
| releaseMessages(SqsClient, List) | | 0% | | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
| makeReadyBatch(List, List, List, long) | | 0% | | 0% | 4 | 4 | 6 | 6 | 1 | 1 |
| logBatchFailures(String, List) | | 0% | | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
| close() | | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
| buildDeleteEntries(List) | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| isCommitted(String, String) | | 0% | | 0% | 5 | 5 | 4 | 4 | 1 | 1 |
| getNextOffset(StreamingJobProperties, Map) | | 0% | | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
| closeClientResources(FileSystem, SqsClient) | | 0% | | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
| isInvalidReceipt(BatchResultErrorEntry) | | 0% | | 0% | 5 | 5 | 4 | 4 | 1 | 1 |
| getCommitOffsetJson(Offset, long, List) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| collectReceiptsToRelease(List, List) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| lastFileName(S3EventOffset) | | 0% | | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
| restoreFromPersistInfo(String) | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| getShowCurrentOffset() | | 0% | | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
| createSqsClient(S3Client) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| getRetryableReceiptHandles(List, List) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| S3EventSourceOffsetProvider(String) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| hasMoreDataToConsume() | | 0% | | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
| getLagMessages() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| getPersistInfo() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| rewriteTvfParams(InsertIntoTableCommand, Offset, long) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$getRetryableReceiptHandles$6(BatchResultErrorEntry) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$collectReceiptsToRelease$3(S3EventSourceOffsetProvider.ParsedMessage) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$getRetryableReceiptHandles$7(List, BatchResultErrorEntry) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$deletePendingMessages$5(List, DeleteMessageBatchResultEntry) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| deserializeOffset(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| updateOffset(Offset) | | 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$deleteSkippedMessages$1(S3EventSourceOffsetProvider.ParsedMessage) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$receiveBatch$0(S3EventSourceOffsetProvider.ParsedMessage) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| static {...} | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getLastSourceEventTimestampSeconds() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$collectReceiptsToRelease$4(S3EventSourceOffsetProvider.ParsedMessage) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$deleteSkippedMessages$2(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 |