You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ni...@apache.org on 2015/06/23 00:19:59 UTC
samza git commit: SAMZA-712 Fix javadoc warning messages
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 <j....@levi9.com>
Authored: Mon Jun 22 15:19:41 2015 -0700
Committer: Yi Pan (Data Infrastructure) <yi...@linkedin.com>
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.");