|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object com.sun.labs.minion.pipeline.StageAdapter com.sun.labs.minion.pipeline.Dropper
public class Dropper
A class that just drops things, but keeps track of the amount of data processed.
Field Summary | |
---|---|
protected float |
bytesProcessed
The number of bytes that have been indexed. |
protected int |
docsProcessed
The number of documents that we've processed. |
protected java.text.DecimalFormat |
form
A format object for formatting the output. |
protected static java.lang.Object |
lock
|
protected static java.lang.String |
logTag
The log tag. |
protected static int |
PROGRESS_INTERVAL
The number of files to index between progress reports. |
protected long |
startTime
The time that we started indexing. |
Fields inherited from class com.sun.labs.minion.pipeline.StageAdapter |
---|
downstream, name |
Constructor Summary | |
---|---|
Dropper()
|
Method Summary | |
---|---|
void |
endDocument(long size)
Processes the event that comes at the end of a document. |
void |
reportProgress()
Reports on our progress. |
void |
token(Token t)
Processes a token from further up the pipeline. |
protected java.lang.String |
toMB(long x)
|
Methods inherited from class com.sun.labs.minion.pipeline.StageAdapter |
---|
defineField, dump, endField, getDownstream, getName, newProperties, punctuation, savedData, setDownstream, setName, shutdown, startDocument, startField, text |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected static java.lang.Object lock
protected long startTime
protected int docsProcessed
protected float bytesProcessed
protected java.text.DecimalFormat form
protected static int PROGRESS_INTERVAL
protected static java.lang.String logTag
Constructor Detail |
---|
public Dropper()
Method Detail |
---|
public void token(Token t)
token
in interface Stage
token
in class StageAdapter
t
- The token to process.public void endDocument(long size)
endDocument
in interface Stage
endDocument
in class StageAdapter
size
- The size of the data that was processed for this file.protected java.lang.String toMB(long x)
public void reportProgress()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |