Repository: samza Updated Branches: refs/heads/0.9.1 aa4dbe6dc -> 176b9abdb
SAMZA-712 Fix javadoc warning messages Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/176b9abd Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/176b9abd Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/176b9abd Branch: refs/heads/0.9.1 Commit: 176b9abdbb76e91b1b010b83f9bef15e8a73489f Parents: aa4dbe6 Author: József Márton Jung <[email protected]> Authored: Mon Jun 22 15:19:41 2015 -0700 Committer: Yi Pan (Data Infrastructure) <[email protected]> Committed: Mon Jun 22 15:19:41 2015 -0700 ---------------------------------------------------------------------- samza-api/src/main/java/org/apache/samza/task/TaskContext.java | 4 ++++ .../samza/logging/log4j/serializers/LoggingEventJsonSerde.java | 5 +++++ 2 files changed, 9 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/176b9abd/samza-api/src/main/java/org/apache/samza/task/TaskContext.java ---------------------------------------------------------------------- diff --git a/samza-api/src/main/java/org/apache/samza/task/TaskContext.java b/samza-api/src/main/java/org/apache/samza/task/TaskContext.java index 929409e..a5a325e 100644 --- a/samza-api/src/main/java/org/apache/samza/task/TaskContext.java +++ b/samza-api/src/main/java/org/apache/samza/task/TaskContext.java @@ -45,6 +45,10 @@ public interface TaskContext { * will have no effect. * * NOTE: this feature is experimental, and the API may change in a future release. + * + * @param ssp {@link org.apache.samza.system.SystemStreamPartition} whose offset should be set + * @param offset to set for the given {@link org.apache.samza.system.SystemStreamPartition} + * */ void setStartingOffset(SystemStreamPartition ssp, String offset); } http://git-wip-us.apache.org/repos/asf/samza/blob/176b9abd/samza-log4j/src/main/java/org/apache/samza/logging/log4j/serializers/LoggingEventJsonSerde.java ---------------------------------------------------------------------- diff --git a/samza-log4j/src/main/java/org/apache/samza/logging/log4j/serializers/LoggingEventJsonSerde.java b/samza-log4j/src/main/java/org/apache/samza/logging/log4j/serializers/LoggingEventJsonSerde.java index fd1c476..cbf552c 100644 --- a/samza-log4j/src/main/java/org/apache/samza/logging/log4j/serializers/LoggingEventJsonSerde.java +++ b/samza-log4j/src/main/java/org/apache/samza/logging/log4j/serializers/LoggingEventJsonSerde.java @@ -153,6 +153,11 @@ public class LoggingEventJsonSerde implements Serde<LoggingEvent> { /** * This method is not currently implemented. + * + * @param loggingEventMap a map of logging events + * + * @return {@link LoggingEvent} decoded from the given logging event map.<br> + * Currently it throws an {@link UnsupportedOperationException} as the method is not implemented yet! */ public static LoggingEvent decodeFromMap(Map<String, Object> loggingEventMap) { throw new UnsupportedOperationException("Unable to decode LoggingEvents.");
