· 9 years ago · Sep 14, 2016, 09:06 AM
1AmazonS3Client s3Client = new AmazonS3Client(new
2 BasicAWSCredentials(accessKey, secretKey));
3
4S3Object object = s3Client.getObject(
5 new GetObjectRequest(bucketName, "myTest.parquet"));
6InputStream objectData = object.getObjectContent();
7
8for (each line of the InputStream)
9{
10 Map<String, String> prop = new HashMap<>();
11 prop.put("field1", line.getField1());
12 prop.put("field2", line.getField2());
13 // save prop in Redis cache DB
14}