Package com.salesforce.multicloudj.docstore.aws

Class QueryRunner

java.lang.Object

com.salesforce.multicloudj.docstore.aws.QueryRunner

public class QueryRunner
extends Object

Constructor Summary

Constructors

Constructor	Description
QueryRunner(software.amazon.awssdk.services.dynamodb.DynamoDbClient ddb, software.amazon.awssdk.services.dynamodb.model.ScanRequest scanRequest, software.amazon.awssdk.services.dynamodb.model.QueryRequest queryRequest, Consumer<Predicate<Object>> beforeRun, List<String> paginationKeys)

Method Summary

Modifier and Type	Method	Description
Consumer<Predicate<Object>>	getBeforeRun()
software.amazon.awssdk.services.dynamodb.DynamoDbClient	getDdb()
List<String>	getPaginationKeys()
software.amazon.awssdk.services.dynamodb.model.QueryRequest	getQueryRequest()
software.amazon.awssdk.services.dynamodb.model.ScanRequest	getScanRequest()
String	queryPlan()
Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue>	run(Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue> startAfter, List<Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue>> items, Function<Object,Boolean> asFunc)
void	setPaginationKeys(List<String> paginationKeys)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

QueryRunner

public QueryRunner(software.amazon.awssdk.services.dynamodb.DynamoDbClient ddb,
 software.amazon.awssdk.services.dynamodb.model.ScanRequest scanRequest,
 software.amazon.awssdk.services.dynamodb.model.QueryRequest queryRequest,
 Consumer<Predicate<Object>> beforeRun,
 List<String> paginationKeys)

Method Details

queryPlan

public String queryPlan()

run

public Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue> run(Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue> startAfter,
 List<Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue>> items,
 Function<Object,Boolean> asFunc)

getDdb

public software.amazon.awssdk.services.dynamodb.DynamoDbClient getDdb()

getScanRequest

public software.amazon.awssdk.services.dynamodb.model.ScanRequest getScanRequest()

getQueryRequest

public software.amazon.awssdk.services.dynamodb.model.QueryRequest getQueryRequest()

getBeforeRun

public Consumer<Predicate<Object>> getBeforeRun()

getPaginationKeys

public List<String> getPaginationKeys()

setPaginationKeys

public void setPaginationKeys(List<String> paginationKeys)