@@ -0,0 +1,647 @@
+package co.cask.cdap.templates.etl.batch.sources;%0A%0Aimport co.cask.cdap.api.flow.flowlet.StreamEvent;%0Aimport co.cask.cdap.api.stream.StreamEventDecoder;%0Aimport org.apache.hadoop.io.LongWritable;%0A%0A/**%0A*%0A*/%0Apublic final class IdentityStreamEventDecoder implements StreamEventDecoder%3CLongWritable, StreamEvent%3E %7B%0A%0A  private final LongWritable key = new LongWritable();%0A%0A  @Override%0A  public DecodeResult%3CLongWritable, StreamEvent%3E decode(StreamEvent event,%0A                                                        DecodeResult%3CLongWritable, StreamEvent%3E result) %7B%0A    key.set(event.getTimestamp());%0A    return result.setKey(key).setValue(event);%0A  %7D%0A%7D%0A

Add IdentityStreamEventDecoder