You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by mf...@apache.org on 2014/05/27 18:37:31 UTC
[5/8] git commit: Merge branch 'master' into STREAMS-93
Merge branch 'master' into STREAMS-93
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/36099b6b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/36099b6b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/36099b6b
Branch: refs/heads/master
Commit: 36099b6b4d4fe75353a0a6a9b5d485635968d379
Parents: 28fa93d a2182b1
Author: Robert Douglas <rd...@w2odigital.com>
Authored: Thu May 22 17:43:26 2014 -0500
Committer: Robert Douglas <rd...@w2odigital.com>
Committed: Thu May 22 17:43:26 2014 -0500
----------------------------------------------------------------------
streams-contrib/pom.xml | 1 +
.../ElasticsearchPersistWriter.java | 121 +++++++++----
.../streams/hdfs/WebHdfsPersistReaderTask.java | 3 +-
streams-contrib/streams-processor-json/pom.xml | 86 ++++++++++
.../apache/streams/json/JsonPathExtractor.java | 140 +++++++++++++++
.../org/apache/streams/json/JsonPathFilter.java | 171 +++++++++++++++++++
.../json/test/JsonPathExtractorTest.java | 101 +++++++++++
.../src/test/resources/books.json | 21 +++
.../src/main/jsonschema/com/twitter/tweet.json | 21 +--
.../org/apache/streams/core/StreamsDatum.java | 4 +
.../local/builders/LocalStreamBuilder.java | 3 +-
.../local/tasks/StreamsProviderTask.java | 5 +-
.../apache/streams/local/tasks/StreamsTask.java | 10 +-
.../local/builders/LocalStreamBuilderTest.java | 37 +++-
.../test/providers/EmptyResultSetProvider.java | 63 +++++++
streams-runtimes/streams-runtime-pig/pom.xml | 45 +++--
.../streams/pig/StreamsComponentFactory.java | 22 ++-
.../apache/streams/pig/StreamsPigBuilder.java | 24 ++-
.../streams/pig/StreamsProcessDatumExec.java | 127 ++++++++++++--
.../streams/pig/StreamsProcessDocumentExec.java | 69 ++++----
.../streams/pig/StreamsSerializerExec.java | 36 ++--
.../org/apache/streams/pig/StreamsStorage.java | 22 ++-
.../src/test/java/PigProcessorTest.java | 32 ----
.../src/test/java/PigSerializerTest.java | 40 -----
.../streams/pig/test/CopyThriceProcessor.java | 56 ++++++
.../streams/pig/test/DoNothingProcessor.java | 54 ++++++
.../streams/pig/test/PigProcessDatumTest.java | 99 +++++++++++
.../pig/test/PigProcessDocumentTest.java | 90 ++++++++++
.../streams/pig/test/PigSerializerTest.java | 62 +++++++
.../test/resources/pigprocessdatumcopytest.pig | 4 +
.../src/test/resources/pigprocessdatumtest.pig | 4 +
.../test/resources/pigprocessdocumenttest.pig | 4 +
.../src/test/resources/pigprocessortest.pig | 7 -
.../src/test/resources/pigserializertest.pig | 12 +-
34 files changed, 1384 insertions(+), 212 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/36099b6b/streams-contrib/streams-provider-twitter/src/main/jsonschema/com/twitter/tweet.json
----------------------------------------------------------------------