co.cask.cdap.data.stream.decoder

Class FormatStreamEventDecoder<T>

java.lang.Object

co.cask.cdap.data.stream.decoder.FormatStreamEventDecoder<T>

Type Parameters:

T - Type of the stream body.

All Implemented Interfaces:

co.cask.cdap.api.stream.StreamEventDecoder<LongWritable,co.cask.cdap.api.stream.GenericStreamEventData<T>>

public final class FormatStreamEventDecoder<T>
extends Object
implements co.cask.cdap.api.stream.StreamEventDecoder<LongWritable,co.cask.cdap.api.stream.GenericStreamEventData<T>>

A StreamEventDecoder that decodes StreamEvent into LongWritable as key and GenericStreamEventData as value for Mapper input. The key carries the event timestamp, while the value is a GenericStreamEventData, which contains the event headers and the event body formatted by some RecordFormat.

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
FormatStreamEventDecoder(co.cask.cdap.api.data.format.RecordFormat<co.cask.cdap.api.flow.flowlet.StreamEvent,T> bodyFormat) Create a decoder for stream events that decodes the body of the stream using the given initialized format.

Method Summary

Methods

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

Methods inherited from class java.lang.Object

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

Constructor Detail

FormatStreamEventDecoder

public FormatStreamEventDecoder(co.cask.cdap.api.data.format.RecordFormat<co.cask.cdap.api.flow.flowlet.StreamEvent,T> bodyFormat)

Create a decoder for stream events that decodes the body of the stream using the given initialized format.

Parameters:

bodyFormat - Initialized format.

Method Detail

decode

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

Specified by:

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