org.thales.punch.libraries.storm.spout

Class AbstractFileInput.Item

java.lang.Object

org.thales.punch.libraries.storm.spout.AbstractFileInput.Item

Enclosing class:

AbstractFileInput

protected static class AbstractFileInput.Item
extends Object

Whenever something is read, it is enqueued so that stom can come pick it in nextTuple().

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
Item(String l, Map<String,String> p)

Method Summary

Modifier and Type	Method and Description
String	getLine()
Map<String,String>	getProperties()

Methods inherited from class java.lang.Object

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

Constructor Detail

Item

public Item(String l,
            Map<String,String> p)

Method Detail

getLine

public String getLine()

Returns:

the item associated data

getProperties

public Map<String,String> getProperties()