Skip to content

Commit 8795c6f

Browse files
author
Nathan Marz
committed
add helper constructors to TransactionalTopologyBuilder
1 parent 3f911f6 commit 8795c6f

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

src/jvm/backtype/storm/transactional/TransactionalTopologyBuilder.java

+8
Original file line numberDiff line numberDiff line change
@@ -55,6 +55,14 @@ public TransactionalTopologyBuilder(String id, String spoutId, ITransactionalSpo
5555

5656
public TransactionalTopologyBuilder(String id, String spoutId, IPartitionedTransactionalSpout spout, Integer spoutParallelism) {
5757
this(id, spoutId, new PartitionedTransactionalSpoutExecutor(spout), spoutParallelism);
58+
}
59+
60+
public TransactionalTopologyBuilder(String id, String spoutId, ITransactionalSpout spout) {
61+
this(id, spoutId, spout, null);
62+
}
63+
64+
public TransactionalTopologyBuilder(String id, String spoutId, IPartitionedTransactionalSpout spout) {
65+
this(id, spoutId, spout, null);
5866
}
5967

6068
public SpoutDeclarer getSpoutDeclarer() {

0 commit comments

Comments
 (0)