class DateTimeBucketAssigner implements BucketAssigner<IN, String> {

	@Override
	public String getBucketId(IN element, BucketAssigner.Context context) {
		if (dateTimeFormatter == null) {
			dateTimeFormatter = DateTimeFormatter.ofPattern(formatString).withZone(zoneId);
		}
		return dateTimeFormatter.format(Instant.ofEpochMilli(context.currentProcessingTime()));
	}

	public  DateTimeBucketAssigner();
	public  DateTimeBucketAssigner(String formatString);
	public  DateTimeBucketAssigner(ZoneId zoneId);
	public  DateTimeBucketAssigner(String formatString, ZoneId zoneId);

}