S3Emitter to allow folders about amazon-kinesis-connectors

[samsach]

I found it was just easier to write my own implementation of IEmitter rather than use S3emitter. I pass in the config during construction that allows for the client to configure their own naming strategy with a couple of new properties. Works nice!

[poovizhiashokkumar]

It is easy to achieve with the following changes to the sample code:

1. In S3sample.properties:

createS3Bucket = true

1. In S3Emitter.java:

/* Add the required imports */

import java.text.SimpleDateFormat;
import java.util.Calendar;

public class S3Emitter implements IEmitter<byte[]> {
.
.
protected final String date_bucket = new SimpleDateFormat("yyyy_MM_dd_HH").format(Calendar.getInstance().getTime());

public S3Emitter(KinesisConnectorConfiguration configuration) {
.
s3Bucket = configuration.S3_BUCKET + "/" + date_bucket;
.
}

Hope this helps!

[chenkirk]

Thanks. This is working well.