public boolean insertCleanupStatusToDynamoDB()

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;
	}