Skip to content

Commit 3b21a8b

Browse files
author
Nathan Marz
committed
remove StintBolt
1 parent b4e87a6 commit 3b21a8b

File tree

4 files changed

+1
-41
lines changed

4 files changed

+1
-41
lines changed

src/jvm/backtype/storm/drpc/IStintBolt.java

-8
This file was deleted.

src/jvm/backtype/storm/drpc/KeyedFairBolt.java

-4
Original file line numberDiff line numberDiff line change
@@ -25,10 +25,6 @@ public KeyedFairBolt(IRichBolt delegate) {
2525
public KeyedFairBolt(IBasicBolt delegate) {
2626
this(new BasicBoltExecutor(delegate));
2727
}
28-
29-
public KeyedFairBolt(IStintBolt delegate) {
30-
this(new StintBoltExecutor(delegate));
31-
}
3228

3329

3430
public void prepare(Map stormConf, TopologyContext context, OutputCollector collector) {

src/jvm/backtype/storm/drpc/LinearDRPCTopologyBuilder.java

+1-11
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,7 @@
11
package backtype.storm.drpc;
22

3-
import backtype.storm.Config;
43
import backtype.storm.Constants;
54
import backtype.storm.ILocalDRPC;
6-
import backtype.storm.StormSubmitter;
75
import backtype.storm.drpc.CoordinatedBolt.SourceArgs;
86
import backtype.storm.generated.StormTopology;
97
import backtype.storm.generated.StreamInfo;
@@ -44,15 +42,7 @@ public LinearDRPCInputDeclarer addBolt(IBasicBolt bolt, int parallelism) {
4442
public LinearDRPCInputDeclarer addBolt(IBasicBolt bolt) {
4543
return addBolt(bolt, 1);
4644
}
47-
48-
public LinearDRPCInputDeclarer addBolt(IStintBolt bolt, int parallelism) {
49-
return addBolt(new StintBoltExecutor(bolt), parallelism);
50-
}
51-
52-
public LinearDRPCInputDeclarer addBolt(IStintBolt bolt) {
53-
return addBolt(bolt, 1);
54-
}
55-
45+
5646
public StormTopology createLocalTopology(ILocalDRPC drpc) {
5747
return createTopology(new DRPCSpout(_function, drpc));
5848
}

src/jvm/backtype/storm/drpc/StintBoltExecutor.java

-18
This file was deleted.

0 commit comments

Comments
 (0)