You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by cr...@apache.org on 2014/02/25 21:23:05 UTC
git commit: SAMZA-98;
ReadableCollector uses both var and mutable for envelopes
Repository: incubator-samza
Updated Branches:
refs/heads/master 33308ed47 -> 3af899a2c
SAMZA-98; ReadableCollector uses both var and mutable for envelopes
Project: http://git-wip-us.apache.org/repos/asf/incubator-samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-samza/commit/3af899a2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/3af899a2
Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/3af899a2
Branch: refs/heads/master
Commit: 3af899a2cf0c8e2c9f2998f1a43f60238e2c1b4c
Parents: 33308ed
Author: Steve Yates <sy...@stevendyates.com>
Authored: Tue Feb 25 12:22:58 2014 -0800
Committer: Chris Riccomini <cr...@criccomi-mn.linkedin.biz>
Committed: Tue Feb 25 12:22:58 2014 -0800
----------------------------------------------------------------------
.../src/main/scala/org/apache/samza/task/ReadableCollector.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/3af899a2/samza-core/src/main/scala/org/apache/samza/task/ReadableCollector.scala
----------------------------------------------------------------------
diff --git a/samza-core/src/main/scala/org/apache/samza/task/ReadableCollector.scala b/samza-core/src/main/scala/org/apache/samza/task/ReadableCollector.scala
index 0ec79da..444bf37 100644
--- a/samza-core/src/main/scala/org/apache/samza/task/ReadableCollector.scala
+++ b/samza-core/src/main/scala/org/apache/samza/task/ReadableCollector.scala
@@ -25,7 +25,7 @@ import org.apache.samza.system.OutgoingMessageEnvelope
/** An in-memory implementation of MessageCollector that stores all outgoing messages in a list */
class ReadableCollector extends MessageCollector {
- var envelopes = new mutable.ArrayBuffer[OutgoingMessageEnvelope]()
+ val envelopes = new mutable.ArrayBuffer[OutgoingMessageEnvelope]()
def send(envelope: OutgoingMessageEnvelope) {
envelopes += envelope