in src/main/scala/org/apache/pekko/persistence/dynamodb/snapshot/DynamoDBSnapshotRequests.scala [119:135]
private def loadBySeqNr(
persistenceId: String,
minSequenceNr: Long,
maxSequenceNr: Long,
limit: Option[Int]): Future[QueryResult] = {
val request = new QueryRequest()
.withTableName(Table)
.withKeyConditionExpression(s" $Key = :partitionKeyVal AND $SequenceNr BETWEEN :seqMinVal AND :seqMaxVal")
.addExpressionAttributeValuesEntry(":partitionKeyVal", S(messagePartitionKey(persistenceId)))
.addExpressionAttributeValuesEntry(":seqMinVal", N(minSequenceNr))
.addExpressionAttributeValuesEntry(":seqMaxVal", N(maxSequenceNr))
.withScanIndexForward(false)
.withConsistentRead(true)
limit.foreach(request.setLimit(_))
dynamo.query(request)
}