public class FileSpout
extends org.apache.storm.topology.base.BaseRichSpout
Modifier and Type | Field and Description |
---|---|
static int |
BATCH_SIZE |
static org.slf4j.Logger |
LOG |
Constructor and Description |
---|
FileSpout(org.apache.storm.spout.Scheme scheme,
String... files) |
FileSpout(String file,
org.apache.storm.spout.Scheme scheme) |
FileSpout(String dir,
String filter,
org.apache.storm.spout.Scheme scheme) |
Modifier and Type | Method and Description |
---|---|
void |
activate() |
void |
close() |
void |
deactivate() |
void |
declareOutputFields(org.apache.storm.topology.OutputFieldsDeclarer declarer) |
void |
nextTuple() |
void |
open(Map conf,
org.apache.storm.task.TopologyContext context,
org.apache.storm.spout.SpoutOutputCollector collector) |
public static final int BATCH_SIZE
public static final org.slf4j.Logger LOG
public FileSpout(String file, org.apache.storm.spout.Scheme scheme)
public FileSpout(org.apache.storm.spout.Scheme scheme, String... files)
public void open(Map conf, org.apache.storm.task.TopologyContext context, org.apache.storm.spout.SpoutOutputCollector collector)
public void nextTuple()
public void declareOutputFields(org.apache.storm.topology.OutputFieldsDeclarer declarer)
public void close()
close
in interface org.apache.storm.spout.ISpout
close
in class org.apache.storm.topology.base.BaseRichSpout
public void activate()
activate
in interface org.apache.storm.spout.ISpout
activate
in class org.apache.storm.topology.base.BaseRichSpout
public void deactivate()
deactivate
in interface org.apache.storm.spout.ISpout
deactivate
in class org.apache.storm.topology.base.BaseRichSpout
Copyright © 2018 DigitalPebble Ltd. All rights reserved.