stream.data

Class Unfold

java.lang.Object

stream.data.Unfold

All Implemented Interfaces:

Processor

public class Unfold
extends Object
implements Processor

Author:

chris

Field Summary

Fields

Modifier and Type	Field and Description
(package private) String	key
(package private) static org.slf4j.Logger	log
(package private) Sink[]	output

Constructor Summary

Constructors

Constructor and Description
Unfold()

Method Summary

Methods

Modifier and Type	Method and Description
void	emit(Data item)
String	getKey()
Sink[]	getOutput()
Data	process(Data input)
void	setKey(String key)
void	setOutput(Sink[] output)

Methods inherited from class java.lang.Object

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

Field Detail

log

static org.slf4j.Logger log

key

String key

output

Sink[] output

Constructor Detail

Unfold

public Unfold()

Method Detail

process

public Data process(Data input)

Specified by:

process in interface Processor

See Also:

Processor.process(stream.Data)

emit

public void emit(Data item)

getKey

public String getKey()

Returns:

the key

setKey

public void setKey(String key)

Parameters:

key - the key to set

getOutput

public Sink[] getOutput()

Returns:

the output

setOutput

public void setOutput(Sink[] output)

Parameters:

output - the output to set