public static void main()

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

	}