I'm new in programming... Hope you will help me... My requirement is to write a Java condition if arrival time of data is less than 3 mins then send it to s3 or else dont send...
My code sample is below
public class KinesisFirehoseTransformer implements RequestHandler {
@Override
public KinesisFirehoseResponse handleRequest(KinesisFirehoseEvent event, Context context) {
context.getLogger().log("Input: " + event);
List<KinesisFirehoseOutputRecord> results = event.getRecords().stream().map(record -> {
KinesisFirehoseOutputRecord outRec = new KinesisFirehoseOutputRecord();
outRec.setRecordId(record.getRecordId());
outRec.setData(record.getData());
outRec.result = KinesisFirehoseResponse.TRANSFORMED_STATE_DROPPED ;
return outRec;
}).collect(Collectors.toList());
return new KinesisFirehoseResponse(results);
}
}
Aucun commentaire:
Enregistrer un commentaire