You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by sb...@apache.org on 2014/05/20 00:37:03 UTC
[2/3] git commit: resolves
https://issues.apache.org/jira/browse/STREAMS-60
resolves https://issues.apache.org/jira/browse/STREAMS-60
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/f24f2517
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/f24f2517
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/f24f2517
Branch: refs/heads/STREAMS-70
Commit: f24f2517672f57d1c118220be8eed7662b6136e5
Parents: f2383db
Author: sblackmon <sb...@w2odigital.com>
Authored: Tue May 6 11:11:01 2014 -0500
Committer: sblackmon <sb...@w2odigital.com>
Committed: Tue May 6 11:11:01 2014 -0500
----------------------------------------------------------------------
.../java/org/apache/streams/hdfs/WebHdfsPersistReaderTask.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/f24f2517/streams-contrib/streams-persist-hdfs/src/main/java/org/apache/streams/hdfs/WebHdfsPersistReaderTask.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-hdfs/src/main/java/org/apache/streams/hdfs/WebHdfsPersistReaderTask.java b/streams-contrib/streams-persist-hdfs/src/main/java/org/apache/streams/hdfs/WebHdfsPersistReaderTask.java
index b04350e..65bd6dc 100644
--- a/streams-contrib/streams-persist-hdfs/src/main/java/org/apache/streams/hdfs/WebHdfsPersistReaderTask.java
+++ b/streams-contrib/streams-persist-hdfs/src/main/java/org/apache/streams/hdfs/WebHdfsPersistReaderTask.java
@@ -4,6 +4,7 @@ import com.google.common.base.Strings;
import org.apache.hadoop.fs.FileStatus;
import org.apache.streams.core.DatumStatus;
import org.apache.streams.core.StreamsDatum;
+import org.joda.time.DateTime;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -43,7 +44,7 @@ public class WebHdfsPersistReaderTask implements Runnable {
if( !Strings.isNullOrEmpty(line) ) {
reader.countersCurrent.incrementAttempt();
String[] fields = line.split(Character.toString(reader.DELIMITER));
- StreamsDatum entry = new StreamsDatum(fields[3], fields[0]);
+ StreamsDatum entry = new StreamsDatum(fields[3], fields[0], new DateTime(Long.parseLong(fields[2])));
write( entry );
reader.countersCurrent.incrementStatus(DatumStatus.SUCCESS);
}