88977bea7c
Add tests to ensure File.expand_path is used to calculate relative paths
2015-08-31 17:08:49 -04:00
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
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
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
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
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
dbf7888bb7
New test/specs for bolt stream support
2015-03-10 21:40:38 +00:00
54e43e39dc
Select stream when setting source for bolt
2015-03-03 22:47:37 +00:00
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
02c79c9282
Using loggable in the topology
2014-08-11 22:19:34 -04:00
03de5d3456
Conforming to SLF4J named hierarchy in loggers
2014-07-28 10:23:10 -04:00
d847f2ca77
Using SLF4J instead of Log4J
2014-07-28 10:23:00 -04:00
00c42f5c14
OutputCollector patch
2014-07-15 13:42:56 -07:00
b67c445456
fixed specs for java proxy class name
2014-03-02 04:42:39 -05:00
36a74844f7
bolt spec changes with new collector interface
2013-07-29 15:31:55 -04:00
ab6e0b0eb5
added coveralls
2013-07-25 15:20:23 -04:00
bcfc5d2b5b
replaced instance_exec with define_method
2013-06-29 19:09:05 -04:00
c76fa6eef1
refactor and expose topology builder
2013-06-20 00:50:03 -04:00
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
3d717383e9
issue #84 - remove simple from DSL classes and add DSL namespace
2013-06-14 01:37:09 -04:00
2f8d71b829
fixed specs for new topology configuration
2013-05-14 22:00:10 -04:00
bc1b6a7455
issue #25 - add specs for spout activate/deactivate and per component configuration
2013-05-09 15:11:49 -04:00
f7f8be36ae
issue #74 - configured topology name as symbol breaks topology submission
2013-05-09 15:10:37 -04:00
b18c9b9c80
issue #25 - specs for spout activate/deactivate
2013-05-08 22:16:18 -04:00
f7da4e1d99
issue #56 - make topology class configure statement optional
2013-05-08 16:55:05 -04:00
e7fb5d193c
issue #18 & #47 , this should solve Logger issues
2012-10-14 19:06:14 -04:00
5dc7454a69
output_fields specs and fixed classes conflict issues
2012-10-08 22:59:33 -04:00
df9795a9ac
issue #41 - suppport shell bolts and spouts, issue #28 - support output_fields definition in topology DSL
2012-07-12 16:18:43 -04:00
81962dc276
added spec for on_receive body with :emit => false
2012-07-10 15:20:24 -04:00
35c30e6ab0
issue #38 , added support for spout reliable emit
2012-07-06 16:25:04 -04:00
bc57741485
issue #35 , automatically set JRuby 1.8/1.9 mode in remote cluster context
2012-06-28 13:23:56 -04:00
a988abd1b9
refactored Ruby version tokens handling
2012-06-28 13:19:03 -04:00
b72e444360
Added support for localOrShuffleGrouping
2012-06-07 10:06:39 +02:00
31ad5849b7
0.7 component configuration and Gemfile handling
2012-05-31 15:27:54 -04:00
a2fddf18a3
ajusted specs for Backtype namespace fix
2012-05-29 17:24:03 -04:00
9879f1befa
trying to resolve rake dependency problem with travis
2012-05-25 15:25:54 -04:00
83270de8bb
trying to resolve rake dependency problem with travis
2012-05-25 15:25:54 -04:00
01976ea771
added log specs and a few cleanups
2012-02-14 16:47:00 -05:00
a7d7c763eb
fix issue #10 - Fields grouping must be declared with strings, not symbols
2011-12-19 14:40:01 -05:00
851c412836
storm ids are now strings
2011-12-08 13:52:20 -05:00
73b6273e24
fox for java components support
2011-11-16 13:51:04 -05:00
3ad6bb8268
symbolic and class ids specs
2011-11-16 11:02:53 -05:00
9e6fe10f9f
multiple multile-values auto emit spec
2011-11-16 11:02:28 -05:00
96fa35ab50
multiple values auto emit
2011-11-15 23:53:13 -05:00
89396e1ad0
more specs + cleanups
2011-11-15 16:37:48 -05:00
b29ec72695
added symbolic ids support
2011-11-14 22:56:27 -05:00
ea0106ca92
SimpleTopology spec
2011-11-14 17:09:52 -05:00
ee446435e7
finalize specs
2011-11-14 12:10:20 -05:00
c9c32ebca3
simple bolt specs
2011-11-13 21:24:56 -05:00
19ca3d7010
separate tasks file, added specs
2011-11-12 22:48:31 -05:00
Robert Bavey
Keith Walters
R. Tyler Croy
Ian Smith
arielvalentin
Colin Surprenant
David Tollmyr