symbolic and class ids specs
This commit is contained in:
parent
9e6fe10f9f
commit
3ad6bb8268
|
@ -441,7 +441,7 @@ describe RedStorm::SimpleTopology do
|
||||||
Topology1.bolts.first.sources.first.should == [1, {:shuffle => nil}]
|
Topology1.bolts.first.sources.first.should == [1, {:shuffle => nil}]
|
||||||
end
|
end
|
||||||
|
|
||||||
it "should resolve implicit symbolic ids" do
|
it "should resolve implicit string ids" do
|
||||||
class Topology1 < RedStorm::SimpleTopology
|
class Topology1 < RedStorm::SimpleTopology
|
||||||
spout SpoutClass1
|
spout SpoutClass1
|
||||||
|
|
||||||
|
@ -461,6 +461,46 @@ describe RedStorm::SimpleTopology do
|
||||||
Topology1.bolts.first.sources.first.should == [1, {:shuffle => nil}]
|
Topology1.bolts.first.sources.first.should == [1, {:shuffle => nil}]
|
||||||
end
|
end
|
||||||
|
|
||||||
|
it "should resolve implicit symbol ids" do
|
||||||
|
class Topology1 < RedStorm::SimpleTopology
|
||||||
|
spout SpoutClass1
|
||||||
|
|
||||||
|
bolt BoltClass1 do
|
||||||
|
source :spout_class1, :shuffle
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
Topology1.spouts.first.id.should == "spout_class1"
|
||||||
|
Topology1.bolts.first.id.should == "bolt_class1"
|
||||||
|
Topology1.bolts.first.sources.first.should == [:spout_class1, {:shuffle => nil}]
|
||||||
|
|
||||||
|
Topology1.resolve_ids!(Topology1.spouts + Topology1.bolts)
|
||||||
|
|
||||||
|
Topology1.spouts.first.id.should == 1
|
||||||
|
Topology1.bolts.first.id.should == 2
|
||||||
|
Topology1.bolts.first.sources.first.should == [1, {:shuffle => nil}]
|
||||||
|
end
|
||||||
|
|
||||||
|
it "should resolve implicit class ids" do
|
||||||
|
class Topology1 < RedStorm::SimpleTopology
|
||||||
|
spout SpoutClass1
|
||||||
|
|
||||||
|
bolt BoltClass1 do
|
||||||
|
source SpoutClass1, :shuffle
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
Topology1.spouts.first.id.should == "spout_class1"
|
||||||
|
Topology1.bolts.first.id.should == "bolt_class1"
|
||||||
|
Topology1.bolts.first.sources.first.should == ["spout_class1", {:shuffle => nil}]
|
||||||
|
|
||||||
|
Topology1.resolve_ids!(Topology1.spouts + Topology1.bolts)
|
||||||
|
|
||||||
|
Topology1.spouts.first.id.should == 1
|
||||||
|
Topology1.bolts.first.id.should == 2
|
||||||
|
Topology1.bolts.first.sources.first.should == [1, {:shuffle => nil}]
|
||||||
|
end
|
||||||
|
|
||||||
it "should raise on unresolvable" do
|
it "should raise on unresolvable" do
|
||||||
class Topology1 < RedStorm::SimpleTopology
|
class Topology1 < RedStorm::SimpleTopology
|
||||||
spout SpoutClass1
|
spout SpoutClass1
|
||||||
|
|
Loading…
Reference in New Issue