co.cask.cdap.data2.registry.internal.keymaker

Class StreamKeyMaker

java.lang.Object

co.cask.cdap.data2.registry.internal.keymaker.StreamKeyMaker

All Implemented Interfaces:

KeyMaker<Id.Stream>

public class StreamKeyMaker
extends Object
implements KeyMaker<Id.Stream>

KeyMaker for Id.Stream.

Constructor Summary

Constructors

Constructor and Description
StreamKeyMaker()

Method Summary

Methods

Modifier and Type	Method and Description
Id.Stream	getElement(MDSKey.Splitter splitter) Given a MDSKey.Splitter, deserialize Id from it.
MDSKey	getKey(Id.Stream streamId) Serializes Id as MDSKey.
void	skipKey(MDSKey.Splitter splitter) Given MDSKey.Splitter, skip the fields of Id.

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamKeyMaker

public StreamKeyMaker()

Method Detail

getKey

public MDSKey getKey(Id.Stream streamId)

Description copied from interface: KeyMaker

Serializes Id as MDSKey.

Specified by:

getKey in interface KeyMaker<Id.Stream>

Parameters:

streamId - id

Returns:

MDSKey for id

skipKey

public void skipKey(MDSKey.Splitter splitter)

Description copied from interface: KeyMaker

Given MDSKey.Splitter, skip the fields of Id. This is used during de-serialization.

Specified by:

skipKey in interface KeyMaker<Id.Stream>

Parameters:

splitter - splitter for id

getElement

public Id.Stream getElement(MDSKey.Splitter splitter)

Description copied from interface: KeyMaker

Given a MDSKey.Splitter, deserialize Id from it.

Specified by:

getElement in interface KeyMaker<Id.Stream>

Parameters:

splitter - splitter for id

Returns:

id