Uses of Class
org.thales.punch.libraries.storm.spout.AbstractFileInput.Item

Packages that use AbstractFileInput.Item

Package	Description
org.thales.punch.libraries.storm.spout	Punchplatform spouts package.

Uses of AbstractFileInput.Item in org.thales.punch.libraries.storm.spout

Fields in org.thales.punch.libraries.storm.spout with type parameters of type AbstractFileInput.Item

Modifier and Type	Field and Description
protected LinkedBlockingQueue<AbstractFileInput.Item>	AbstractFileInput.failed Ths queue holds failed tuples, the failed lines of data that must be reemitted.
protected LinkedBlockingQueue<AbstractFileInput.Item>	AbstractFileInput.inputQueue Internal FileSpout queue to put read items before doing the actual processing.
protected static Map<String,LinkedBlockingQueue<AbstractFileInput.Item>>	AbstractFileInput.inputQueues Keep track of internal queues based on the Storm component ID.

Methods in org.thales.punch.libraries.storm.spout that return AbstractFileInput.Item

Modifier and Type	Method and Description
protected AbstractFileInput.Item	AbstractFileInput.drainNextLogs()