Repository: beam Updated Branches: refs/heads/master 393bbc9d1 -> 406301979
More informative KafkaCheckpointMark toString Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7bef50a0 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7bef50a0 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7bef50a0 Branch: refs/heads/master Commit: 7bef50a0b6eb1cd1e0b71db4e439d31008095b6f Parents: 393bbc9 Author: Aviem Zur <aviem...@gmail.com> Authored: Fri Feb 17 12:55:43 2017 +0200 Committer: Jean-Baptiste Onofré <jbono...@apache.org> Committed: Sun Feb 19 08:50:31 2017 +0100 ---------------------------------------------------------------------- .../beam/sdk/io/kafka/KafkaCheckpointMark.java | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/7bef50a0/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaCheckpointMark.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaCheckpointMark.java b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaCheckpointMark.java index 763a98a..61a382d 100644 --- a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaCheckpointMark.java +++ b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaCheckpointMark.java @@ -17,6 +17,8 @@ */ package org.apache.beam.sdk.io.kafka; +import com.google.common.base.Joiner; + import java.io.IOException; import java.io.Serializable; import java.util.List; @@ -52,6 +54,11 @@ public class KafkaCheckpointMark implements UnboundedSource.CheckpointMark { // is restarted (checkpoint is not available for job restarts). } + @Override + public String toString() { + return "KafkaCheckpointMark{partitions=" + Joiner.on(",").join(partitions) + '}'; + } + /** * A tuple to hold topic, partition, and offset that comprise the checkpoint * for a single partition. @@ -80,6 +87,15 @@ public class KafkaCheckpointMark implements UnboundedSource.CheckpointMark { public long getNextOffset() { return nextOffset; } + + @Override + public String toString() { + return "PartitionMark{" + + "topic='" + topic + '\'' + + ", partition=" + partition + + ", nextOffset=" + nextOffset + + '}'; + } } }
