From 2060664018a90cc341025800cc644474ed586cb1 Mon Sep 17 00:00:00 2001 From: Daniel Dara Date: Fri, 27 Oct 2017 22:38:37 -0400 Subject: [PATCH] Deprecated FixedTupleSpout constructor with String. Added constructor with Fields so more than one output field can be specified. --- .../apache/storm/testing/FixedTupleSpout.java | 18 +++++++++++++----- 1 file changed, 13 insertions(+), 5 deletions(-) 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 43caf429b74..fe192adb06f 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 static void clear(String stormId) { private Map _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 FixedTupleSpout(List tuples, String fieldName) { } _tuples.add(ft); } - _fieldName = fieldName; + _fields = fields; } public List getSourceTuples() { @@ -168,8 +176,8 @@ public void deactivate() { @Override public void declareOutputFields(OutputFieldsDeclarer declarer) { - if (_fieldName != null) { - declarer.declare(new Fields(_fieldName)); + if (_fields != null) { + declarer.declare(_fields); } }