in src/main/java/software/aws/glue/tableversions/utils/DDBUtil.java [21:44]
public boolean insertCleanupStatusToDynamoDB(AmazonDynamoDB ddbClient, String ddbTableName, String hashKey,
String rangeKey, long executionId, String executionBatchId, String databaseName, String tableName,
int numTableVersionsB4Cleanup, int numVersionsRetained, int numDeletedVersions) {
boolean itemInserted = false;
DynamoDB dynamoDB = new DynamoDB(ddbClient);
Table table = dynamoDB.getTable(ddbTableName);
Item item = new Item()
.withPrimaryKey(hashKey, executionId)
.withNumber(rangeKey, Long.parseLong(executionBatchId))
.withString("table_name", tableName)
.withString("database_name", databaseName)
.withNumber("number_of_versions_before_cleanup", numTableVersionsB4Cleanup)
.withNumber("number_of_versions_retained", numVersionsRetained)
.withNumber("number_of_versions_deleted", numDeletedVersions);
// 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;
}