jruby-gradle
/
redstorm
mirror of https://github.com/jruby-gradle/redstorm
1
0
Fork 0
Code Issues Releases Wiki Activity

issues #64 & #66 - JRubyShellSpout in wrong package & add missing shell components in repo (hidden by bad .gitignore)

This commit is contained in:
Colin Surprenant 2013-03-22 08:34:05 -04:00
parent ddff6b65ae
commit eaa2ae1982
2 changed files with 52 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/main/redstorm/storm/jruby/JRubyShellBolt.java Normal file
View File

@ -0,0 +1,26 @@
package redstorm.storm.jruby;
import backtype.storm.task.ShellBolt;
import backtype.storm.topology.IRichBolt;
import backtype.storm.topology.OutputFieldsDeclarer;
import backtype.storm.tuple.Fields;
import java.util.Map;
public class JRubyShellBolt extends ShellBolt implements IRichBolt {
private String[] _fields;
public JRubyShellBolt(String[] command, String[] fields) {
super(command);
_fields = fields;
}
@Override
public void declareOutputFields(OutputFieldsDeclarer declarer) {
declarer.declare(new Fields(_fields));
}
@Override
public Map<String, Object> getComponentConfiguration() {
return null;
}
}

26
src/main/redstorm/storm/jruby/JRubyShellSpout.java Normal file
View File

@ -0,0 +1,26 @@
package redstorm.storm.jruby;
import backtype.storm.spout.ShellSpout;
import backtype.storm.topology.IRichSpout;
import backtype.storm.topology.OutputFieldsDeclarer;
import backtype.storm.tuple.Fields;
import java.util.Map;
public class JRubyShellSpout extends ShellSpout implements IRichSpout {
private String[] _fields;
public JRubyShellSpout(String[] command, String[] fields) {
super(command);
_fields = fields;
}
@Override
public void declareOutputFields(OutputFieldsDeclarer declarer) {
declarer.declare(new Fields(_fields));
}
@Override
public Map<String, Object> getComponentConfiguration() {
return null;
}
}