co.cask.cdap.data.stream.decoder

Class BytesStreamEventDecoder

java.lang.Object

co.cask.cdap.data.stream.decoder.BytesStreamEventDecoder

All Implemented Interfaces:

co.cask.cdap.api.stream.StreamEventDecoder<LongWritable,BytesWritable>

public final class BytesStreamEventDecoder
extends Object
implements co.cask.cdap.api.stream.StreamEventDecoder<LongWritable,BytesWritable>

A StreamEventDecoder that decodes StreamEvent into LongWritable as key and BytesWritable as value for Mapper input. The key carries the event timestamp, while the value is the stream event body.

Nested Class Summary

Nested classes/interfaces inherited from interface co.cask.cdap.api.stream.StreamEventDecoder

co.cask.cdap.api.stream.StreamEventDecoder.DecodeResult<K,V>

Constructor Summary

Constructors

Constructor and Description
BytesStreamEventDecoder()

Method Summary

Methods

Modifier and Type	Method and Description
co.cask.cdap.api.stream.StreamEventDecoder.DecodeResult<LongWritable,BytesWritable>	decode(co.cask.cdap.api.flow.flowlet.StreamEvent event, co.cask.cdap.api.stream.StreamEventDecoder.DecodeResult<LongWritable,BytesWritable> result)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BytesStreamEventDecoder

public BytesStreamEventDecoder()

Method Detail

decode

public co.cask.cdap.api.stream.StreamEventDecoder.DecodeResult<LongWritable,BytesWritable> decode(co.cask.cdap.api.flow.flowlet.StreamEvent event,
                                                                                         co.cask.cdap.api.stream.StreamEventDecoder.DecodeResult<LongWritable,BytesWritable> result)

Specified by:

decode in interface co.cask.cdap.api.stream.StreamEventDecoder<LongWritable,BytesWritable>