in src/text/java/com/amazonaws/kda/benchmarking/util/GetSampleData.java [17:50]
public static void main(String[] args) {
AmazonDynamoDB client = AmazonDynamoDBClientBuilder.standard().withEndpointConfiguration(
new AwsClientBuilder.EndpointConfiguration("http://localhost:8000", "us-east-1")).build();
// String tableName = "kda_flink_perf_benchmarking_with_s3";
// String tableName = "kda_flink_perf_benchmarking_without_s3";
// String tableName = "kda_flink_perf_benchmarking_child_job_summary";
String tableName = "kda_flink_perf_benchmarking_parent_job_summary";
try {
ScanRequest scanRequest = new ScanRequest().withTableName(tableName);
ScanResult result = client.scan(scanRequest);
for (Map<String, AttributeValue> item : result.getItems()) {
Map<String, AttributeValue> attributeList = item;
for (Map.Entry<String, AttributeValue> item1 : attributeList.entrySet()) {
String attributeName = item1.getKey();
AttributeValue value = item1.getValue();
// if(Optional.ofNullable(value.getN()).isPresent())
System.out.print(attributeName + ": " + (value.getS() == null ? "N=[" + value.getN() + "] " : "S=[" + value.getS() + "] "));
}
// Move to next line
System.out.println();
}
} catch (Exception e) {
System.err.println("Unable to create table: ");
System.err.println(e.getMessage());
}
}