Repository: storm Updated Branches: refs/heads/master 16a4cb8c4 -> 24ab227ed
Deprecated FixedTupleSpout constructor with String. Added constructor with Fields so more than one output field can be specified. Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/20606640 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/20606640 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/20606640 Branch: refs/heads/master Commit: 2060664018a90cc341025800cc644474ed586cb1 Parents: 5077228 Author: Daniel Dara <[email protected]> Authored: Fri Oct 27 22:38:37 2017 -0400 Committer: Daniel Dara <[email protected]> Committed: Fri Oct 27 22:38:37 2017 -0400 ---------------------------------------------------------------------- .../org/apache/storm/testing/FixedTupleSpout.java | 18 +++++++++++++----- 1 file changed, 13 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/20606640/storm-client/src/jvm/org/apache/storm/testing/FixedTupleSpout.java ---------------------------------------------------------------------- diff --git a/storm-client/src/jvm/org/apache/storm/testing/FixedTupleSpout.java b/storm-client/src/jvm/org/apache/storm/testing/FixedTupleSpout.java index 43caf42..fe192ad 100644 --- a/storm-client/src/jvm/org/apache/storm/testing/FixedTupleSpout.java +++ b/storm-client/src/jvm/org/apache/storm/testing/FixedTupleSpout.java @@ -60,13 +60,21 @@ public class FixedTupleSpout implements IRichSpout, CompletableSpout { private Map<String, FixedTuple> _pending; private String _id; - private String _fieldName; + private Fields _fields; public FixedTupleSpout(List tuples) { - this(tuples, null); + this(tuples, (Fields) null); } + /** + * @deprecated please use {@link #FixedTupleSpout(List, Fields)} + */ + @Deprecated public FixedTupleSpout(List tuples, String fieldName) { + this(tuples, new Fields(fieldName)); + } + + public FixedTupleSpout(List tuples, Fields fields) { _id = UUID.randomUUID().toString(); synchronized(acked) { acked.put(_id, 0); @@ -84,7 +92,7 @@ public class FixedTupleSpout implements IRichSpout, CompletableSpout { } _tuples.add(ft); } - _fieldName = fieldName; + _fields = fields; } public List<FixedTuple> getSourceTuples() { @@ -168,8 +176,8 @@ public class FixedTupleSpout implements IRichSpout, CompletableSpout { @Override public void declareOutputFields(OutputFieldsDeclarer declarer) { - if (_fieldName != null) { - declarer.declare(new Fields(_fieldName)); + if (_fields != null) { + declarer.declare(_fields); } }
