jruby-gradle
/
redstorm
mirror of https://github.com/jruby-gradle/redstorm
1
0
Fork 0
Code Issues Releases Wiki Activity
486 Commits 30 Branches 26 Tags 856 KiB
Commit Graph

19 Commits

Author SHA1 Message Date
Robert Bavey 88977bea7c Add tests to ensure File.expand_path is used to calculate relative paths 2015-08-31 17:08:49 -04:00
Robert Bavey c549d701d5 Merge commit 'refs/pull/129/head' of https://github.com/colinsurprenant/redstorm 
Conflicts:
	Gemfile.lock
	lib/red_storm/dsl/bolt.rb
	lib/red_storm/dsl/spout.rb
	redstorm.gemspec
 2015-08-27 14:49:57 -04:00
Keith Walters 67fd211d4d Wrongly assumed topo bolts inherit from redstorm 
Not all bolts defined in a topology inherit from the RedStorm::DSL. This
ensures the output fields in the ComponentDefinition are only copied if
the class uses the OutputFields module. Also, redefining field names for
the default stream will replace any previously defined default field
names.
 2015-04-16 23:23:00 +00:00
Keith Walters db8547ebd6 Output fields in ruby classes are declared in java 
Fixes an issue where outfields that are defined in the Spout or Bolt are
not recognized by the Nimbus server when it validates the existence of
streams for all bolts in the topology.
 2015-04-16 21:16:33 +00:00
Keith Walters 7b7f3f7c99 Bolt/Spouts in topos need to support streams 
This commit makes it possible to declare streams and fields for bolts
and streams inside of the Topology definition.
 2015-04-07 22:58:47 +00:00
R. Tyler Croy fec511c1e9 Merge remote-tracking branch 'colinsurprenant/pr/115' 
Merging in colinsurprenant/redstorm#115

Conflicts:
	.gitignore
	lib/red_storm/dsl/bolt.rb
	lib/red_storm/dsl/spout.rb
 2015-03-17 10:28:50 -07:00
Keith Walters dbf7888bb7 New test/specs for bolt stream support 2015-03-10 21:40:38 +00:00
Keith Walters 54e43e39dc Select stream when setting source for bolt 2015-03-03 22:47:37 +00:00
Ian Smith 5d7debdf16 This allows for on_* to be defined by defining the corresponding instance method 
directly.  Prior to this fix, doing this will result in "SystemStackError: stack
level too deep".

Example
module RedStorm
  module Examples
    class SplitSentenceBolt < DSL::Bolt
      def on_receive(tuple)
        tuple[0].split(' ').map{|w| [w]}
      end
    end
  end
end
 2014-11-02 09:08:04 -08:00
arielvalentin 02c79c9282 Using loggable in the topology 2014-08-11 22:19:34 -04:00
Ariel S. Valentin 03de5d3456 Conforming to SLF4J named hierarchy in loggers 2014-07-28 10:23:10 -04:00
Ariel S. Valentin d847f2ca77 Using SLF4J instead of Log4J 2014-07-28 10:23:00 -04:00
Ian Smith 00c42f5c14 OutputCollector patch 2014-07-15 13:42:56 -07:00
Colin Surprenant b67c445456 fixed specs for java proxy class name 2014-03-02 04:42:39 -05:00
Colin Surprenant 36a74844f7 bolt spec changes with new collector interface 2013-07-29 15:31:55 -04:00
Colin Surprenant bcfc5d2b5b replaced instance_exec with define_method 2013-06-29 19:09:05 -04:00
Colin Surprenant c76fa6eef1 refactor and expose topology builder 2013-06-20 00:50:03 -04:00
Colin Surprenant 28c9ca3009 issue #83 - add syntactic sugar to the Tuple class for more idiomatic Ruby Tuple usage in the DSL 2013-06-14 01:38:27 -04:00
Colin Surprenant 3d717383e9 issue #84 - remove simple from DSL classes and add DSL namespace 2013-06-14 01:37:09 -04:00