in src/main/java/software/aws/glue/tableversions/utils/DDBUtil.java [59:76]
public boolean insertTableDetailsToDynamoDB(AmazonDynamoDB ddbClient, String ddbTableName, String hashKey,
String rangeKey, long executionBatchId, String databaseName, String tableName, String messageSentTime) {
boolean itemInserted = false;
DynamoDB dynamoDB = new DynamoDB(ddbClient);
Table table = dynamoDB.getTable(ddbTableName);
Item item = new Item().withPrimaryKey(hashKey, executionBatchId)
.withString(rangeKey, databaseName.concat("|").concat(tableName)).withString("table_name", tableName)
.withString("database_name", databaseName).withString("message_sent_time", messageSentTime);
// Write the item to the table
PutItemOutcome outcome = table.putItem(item);
int statusCode = outcome.getPutItemResult().getSdkHttpMetadata().getHttpStatusCode();
if (statusCode == 200) {
itemInserted = true;
System.out.println("Table version inserted to DynamoDB table: " + ddbTableName);
}
return itemInserted;
}