Merge pull request #9 from apache/master Merge Apache Master 2014/10/21
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/6a8ed61c Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/6a8ed61c Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/6a8ed61c Branch: refs/heads/master Commit: 6a8ed61c593ada5ff208c9323121106bbcba715a Parents: 6ecf46d d6b1f77 Author: Ryan Ebanks <[email protected]> Authored: Tue Oct 21 15:17:38 2014 -0500 Committer: Ryan Ebanks <[email protected]> Committed: Tue Oct 21 15:17:38 2014 -0500 ---------------------------------------------------------------------- .../streams-persist-elasticsearch/pom.xml | 47 +++++++ .../ElasticsearchMetadataUtil.java | 106 ++++++++++++++++ .../ElasticsearchPersistDeleter.java | 6 +- .../ElasticsearchPersistUpdater.java | 6 +- .../ElasticsearchPersistWriter.java | 47 +------ .../DatumFromMetadataAsDocumentProcessor.java | 122 +++++++++++++++++++ .../processor/DatumFromMetadataProcessor.java | 103 ++++++++++++++++ .../processor/DocumentToMetadataProcessor.java | 100 +++++++++++++++ .../ElasticsearchConfiguration.json | 3 +- .../test/TestDatumFromMetadataProcessor.java | 81 ++++++++++++ .../test/TestDocumentToMetadataProcessor.java | 63 ++++++++++ .../test/TestElasticsearchPersistWriter.java | 70 +++++++++++ .../provider/TwitterTimelineProvider.java | 14 ++- .../provider/TwitterTimelineProviderTest.java | 39 ++++++ 14 files changed, 751 insertions(+), 56 deletions(-) ----------------------------------------------------------------------
