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,
backtype.storm.task.TopologyContext context,
backtype.storm.spout.SpoutOutputCollector collector) |
boolean |
reachedEnd()
Can be called before nextTuple() any times including 0.
|
ack, activate, deactivate, declareOutputFields, fail, getComponentConfiguration
public FiniteFileSpout()
public FiniteFileSpout(String path)
public void open(Map conf, backtype.storm.task.TopologyContext context, backtype.storm.spout.SpoutOutputCollector collector)
public void nextTuple()
public boolean reachedEnd()
reachedEnd
in interface FiniteSpout
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.