public class FiniteFileSpout extends FileSpout implements FiniteSpout
INPUT_FILE_PATH, path, reader
ATTRIBUTE_LINE, collector
Constructor and Description |
---|
FiniteFileSpout() |
FiniteFileSpout(String path) |
Modifier and Type | Method and Description |
---|---|
void |
nextTuple() |
void |
open(Map conf,
org.apache.storm.task.TopologyContext context,
org.apache.storm.spout.SpoutOutputCollector collector) |
boolean |
reachedEnd()
Can be called before nextTuple() any times including 0.
|
ack, activate, deactivate, declareOutputFields, fail, getComponentConfiguration
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public FiniteFileSpout()
public FiniteFileSpout(String path)
public void open(Map conf, org.apache.storm.task.TopologyContext context, org.apache.storm.spout.SpoutOutputCollector collector)
public void nextTuple()
public boolean reachedEnd()
reachedEnd
in interface FiniteSpout
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.