public static boolean insertChildJobDetailedStatus()

in src/main/java/com/amazonaws/kda/flink/benchmarking/util/DDBUtil.java [124:143]

• 19 lines of code
• 3 McCabe index (conditional complexity)

	public static boolean insertChildJobDetailedStatus(DynamoDB dynamoDBClient, String dynamoDBTblName, String jobName,
			String jobTriggeringId, String targetStream, String interactionId, int batchSize, long executionTime) {

		boolean itemInserted = false;
		Table table = dynamoDBClient.getTable(dynamoDBTblName);
		Item item = new Item().withPrimaryKey("job_name", jobName).withString("job_run_id", jobTriggeringId + "-" + System.currentTimeMillis())
				.withString("interaction_id", interactionId).withString("interaction_id", interactionId)
				.withNumber("batch_size", batchSize).withString("stream_name", targetStream);
		try {
			PutItemOutcome outcome = table.putItem(item);
			int statusCode = outcome.getPutItemResult().getSdkHttpMetadata().getHttpStatusCode();
			if (statusCode == 200) {
				itemInserted = true;
			}
		} catch (Exception e) {
			e.printStackTrace();
			System.out.println("Item could not be inserted to DynamoDB table.");
		}
		return itemInserted;
	}