Updated Branches: refs/heads/master 9a04ec85b -> ae7801707
SAMZA-90; Add toString to TaskInstance. Project: http://git-wip-us.apache.org/repos/asf/incubator-samza/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-samza/commit/ae780170 Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/ae780170 Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/ae780170 Branch: refs/heads/master Commit: ae78017076f77077b6b1bf6436ac62d9a1084b90 Parents: 9a04ec8 Author: Rekha Joshi <[email protected]> Authored: Tue Dec 10 12:10:39 2013 -0800 Committer: Chris Riccomini <[email protected]> Committed: Tue Dec 10 12:10:39 2013 -0800 ---------------------------------------------------------------------- .../main/scala/org/apache/samza/container/TaskInstance.scala | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/ae780170/samza-core/src/main/scala/org/apache/samza/container/TaskInstance.scala ---------------------------------------------------------------------- diff --git a/samza-core/src/main/scala/org/apache/samza/container/TaskInstance.scala b/samza-core/src/main/scala/org/apache/samza/container/TaskInstance.scala index d7eff62..b30dd27 100644 --- a/samza-core/src/main/scala/org/apache/samza/container/TaskInstance.scala +++ b/samza-core/src/main/scala/org/apache/samza/container/TaskInstance.scala @@ -259,4 +259,9 @@ class TaskInstance( debug("Skipping storage manager shutdown for partition: %s" format partition) } } + + override def toString() = "TaskInstance for class %s and partition %s." format (task.getClass.getName, partition) + + def toDetailedString() = "TaskInstance [windowable=%s, window_time=%s, commit_time=%s, closable=%s, collector_size=%s]" format (isWindowableTask, lastWindowMs, lastCommitMs, isClosableTask, collector.envelopes.size) + }
