svn commit: r1556700 - /incubator/streams/branches/sblackmon/

2014-01-08 Thread sblackmon
Author: sblackmon Date: Thu Jan 9 02:16:34 2014 New Revision: 1556700 URL: http://svn.apache.org/r1556700 Log: branching to commit a bunch of good stuff Added: incubator/streams/branches/sblackmon/ - copied from r1556699, incubator/streams/trunk/

svn commit: r1556895 - /incubator/streams/branches/sblackmon/atlassian-ide-plugin.xml

2014-01-09 Thread sblackmon
Author: sblackmon Date: Thu Jan 9 17:28:51 2014 New Revision: 1556895 URL: http://svn.apache.org/r1556895 Log: cleanup Removed: incubator/streams/branches/sblackmon/atlassian-ide-plugin.xml

svn commit: r1556893 [6/25] - in /incubator/streams/branches/sblackmon: ./ streams-config-graph/ streams-config-graph/src/ streams-config-graph/src/main/ streams-config-graph/src/main/java/ streams-co

2014-01-09 Thread sblackmon
Added: incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-flickr/pom.xml URL: http://svn.apache.org/viewvc/incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-flickr/pom.xml?rev=1556893view=auto

svn commit: r1556893 [25/25] - in /incubator/streams/branches/sblackmon: ./ streams-config-graph/ streams-config-graph/src/ streams-config-graph/src/main/ streams-config-graph/src/main/java/ streams-c

2014-01-09 Thread sblackmon
Added: incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/verbs/make-friend.json URL: http://svn.apache.org/viewvc/incubator/streams/branches/sblackmon/streams-pojo/src/main/jsonschema/org/apache/streams/pojo/json/verbs/make-friend.json?rev

svn commit: r1556893 [10/25] - in /incubator/streams/branches/sblackmon: ./ streams-config-graph/ streams-config-graph/src/ streams-config-graph/src/main/ streams-config-graph/src/main/java/ streams-c

2014-01-09 Thread sblackmon
Added: incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-instagram/pom.xml URL: http://svn.apache.org/viewvc/incubator/streams/branches/sblackmon/streams-contrib/streams-provider-gnip/gnip-edc-instagram/pom.xml?rev=1556893view=auto

svn commit: r1557268 - in /incubator/streams/branches/sblackmon: streams-contrib/ streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ streams-contrib/streams-persist-kafk

2014-01-10 Thread sblackmon
Author: sblackmon Date: Fri Jan 10 22:03:09 2014 New Revision: 1557268 URL: http://svn.apache.org/r1557268 Log: small updates to core and persist implementations Modified: incubator/streams/branches/sblackmon/streams-contrib/pom.xml incubator/streams/branches/sblackmon/streams-contrib

svn commit: r1557615 - in /incubator/streams/branches/sblackmon/streams-contrib: streams-persist-console/ streams-persist-console/src/main/java/org/apache/streams/console/ streams-provider-twitter/src

2014-01-12 Thread sblackmon
Author: sblackmon Date: Sun Jan 12 21:49:35 2014 New Revision: 1557615 URL: http://svn.apache.org/r1557615 Log: a few missing files Added: incubator/streams/branches/sblackmon/streams-contrib/streams-persist-console/pom.xml incubator/streams/branches/sblackmon/streams-contrib/streams

svn commit: r1560191 - in /incubator/streams/trunk/streams-storm/src/main/java/org/apache/streams/storm/trident: StreamsPersistWriterState.java StreamsProviderSpout.java

2014-01-21 Thread sblackmon
Author: sblackmon Date: Tue Jan 21 21:16:03 2014 New Revision: 1560191 URL: http://svn.apache.org/r1560191 Log: storm wrappers for providers and persistwriters Added: incubator/streams/trunk/streams-storm/src/main/java/org/apache/streams/storm/trident/StreamsPersistWriterState.java

svn commit: r1565735 - in /incubator/streams/branches/sblackmon/streams-contrib: streams-provider-facebook/src/main/java/com/facebook/api/ streams-provider-gnip/gnip-edc-googleplus/src/main/java/com/g

2014-02-07 Thread sblackmon
Author: sblackmon Date: Fri Feb 7 17:26:34 2014 New Revision: 1565735 URL: http://svn.apache.org/r1565735 Log: updated bc ActivitySerializer is now a typed interface Modified: incubator/streams/branches/sblackmon/streams-contrib/streams-provider-facebook/src/main/java/com/facebook/api

svn commit: r1566466 - in /incubator/streams/branches/sblackmon: streams-contrib/streams-persist-kafka/src/main/java/org/apache/streams/kafka/ streams-core/src/main/java/org/apache/streams/core/

2014-02-09 Thread sblackmon
Author: sblackmon Date: Sun Feb 9 23:07:39 2014 New Revision: 1566466 URL: http://svn.apache.org/r1566466 Log: this change allows a processor to create multiple activities detected within a processed document Modified: incubator/streams/branches/sblackmon/streams-contrib/streams-persist

svn commit: r1566728 - /incubator/streams/trunk/streams-contrib/streams-provider-sysomos/pom.xml

2014-02-10 Thread sblackmon
Author: sblackmon Date: Mon Feb 10 20:22:11 2014 New Revision: 1566728 URL: http://svn.apache.org/r1566728 Log: These changes should allow the project to build on Jenkins, rather than error out when jsonschema2pojo tries to build .svn directories Modified: incubator/streams/trunk/streams

svn commit: r1566745 - /incubator/streams/trunk/streams-contrib/streams-persist-elasticsearch/pom.xml

2014-02-10 Thread sblackmon
Author: sblackmon Date: Mon Feb 10 21:10:30 2014 New Revision: 1566745 URL: http://svn.apache.org/r1566745 Log: These changes should allow the project to build on Jenkins, rather than error out when jsonschema2pojo tries to build .svn directories Modified: incubator/streams/trunk/streams

svn commit: r1566751 - in /incubator/streams/trunk/streams-contrib/streams-persist-elasticsearch/src: ./ main/ main/jsonschema/ main/jsonschema/org/ main/jsonschema/org/apache/ main/jsonschema/org/apa

2014-02-10 Thread sblackmon
Author: sblackmon Date: Mon Feb 10 21:31:29 2014 New Revision: 1566751 URL: http://svn.apache.org/r1566751 Log: Scaffold for streams-persist-elasticsearch Added: incubator/streams/trunk/streams-contrib/streams-persist-elasticsearch/src/ incubator/streams/trunk/streams-contrib/streams

svn commit: r1566792 - /incubator/streams/trunk/streams-contrib/streams-provider-facebook/src/main/java/com/facebook/api/FacebookPostActivitySerializer.java

2014-02-10 Thread sblackmon
Author: sblackmon Date: Mon Feb 10 22:50:53 2014 New Revision: 1566792 URL: http://svn.apache.org/r1566792 Log: These changes should allow the project to build on Jenkins, rather than error out when jsonschema2pojo tries to build .svn directories Modified: incubator/streams/trunk/streams

svn commit: r1566891 - /incubator/streams/trunk/streams-contrib/streams-provider-rss/pom.xml

2014-02-10 Thread sblackmon
Author: sblackmon Date: Tue Feb 11 00:23:43 2014 New Revision: 1566891 URL: http://svn.apache.org/r1566891 Log: These changes should allow the project to build on Jenkins, rather than error out when jsonschema2pojo tries to build .svn directories Modified: incubator/streams/trunk/streams

svn commit: r1567419 - in /incubator/streams/trunk/streams-contrib/streams-persist-kafka: ./ src/main/java/org/apache/streams/kafka/ src/main/jsonschema/org/apache/streams/kafka/ src/main/resources/

2014-02-11 Thread sblackmon
Author: sblackmon Date: Tue Feb 11 22:17:29 2014 New Revision: 1567419 URL: http://svn.apache.org/r1567419 Log: added kafka reader capability - not yet tested! Modified: incubator/streams/trunk/streams-contrib/streams-persist-kafka/pom.xml incubator/streams/trunk/streams-contrib

svn commit: r1567420 - in /incubator/streams/trunk/streams-contrib/streams-persist-kafka/src/main/java/org/apache/streams/kafka: KafkaPersistReader.java KafkaPersistReaderTask.java

2014-02-11 Thread sblackmon
Author: sblackmon Date: Tue Feb 11 22:17:59 2014 New Revision: 1567420 URL: http://svn.apache.org/r1567420 Log: added kafka reader capability - not yet tested! Added: incubator/streams/trunk/streams-contrib/streams-persist-kafka/src/main/java/org/apache/streams/kafka

svn commit: r1571367 - /incubator/streams/branches/STREAMS-26/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistWriterTask.java

2014-02-24 Thread sblackmon
Author: sblackmon Date: Mon Feb 24 17:35:27 2014 New Revision: 1571367 URL: http://svn.apache.org/r1571367 Log: fixing STREAMS-26 Added: incubator/streams/branches/STREAMS-26/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ConsolePersistWriterTask.java

svn commit: r1571485 - in /incubator/streams/branches/STREAMS-26: ./ streams-contrib/ streams-contrib/streams-persist-hdfs/src/main/java/org/apache/streams/hdfs/ streams-contrib/streams-persist-kafka/

2014-02-24 Thread sblackmon
Author: sblackmon Date: Mon Feb 24 23:20:47 2014 New Revision: 1571485 URL: http://svn.apache.org/r1571485 Log: Activating kafka and hdfs modules Ensuring providers, processors, and persisters are serializable Modified: incubator/streams/branches/STREAMS-26/pom.xml incubator/streams

svn commit: r1571490 - in /incubator/streams/branches/STREAMS-26: streams-contrib/streams-provider-rss/ streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/ stre

2014-02-24 Thread sblackmon
Author: sblackmon Date: Mon Feb 24 23:34:13 2014 New Revision: 1571490 URL: http://svn.apache.org/r1571490 Log: adding a few missing files Added: incubator/streams/branches/STREAMS-26/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider

svn commit: r1572231 - in /incubator/streams/branches/STREAMS-26: streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/ streams-core/src/main/java/org/apache/stre

2014-02-26 Thread sblackmon
Author: sblackmon Date: Wed Feb 26 20:20:20 2014 New Revision: 1572231 URL: http://svn.apache.org/r1572231 Log: altering StreamsResultSet to be easier to use Modified: incubator/streams/branches/STREAMS-26/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter

svn commit: r1572361 - in /incubator/streams/branches/STREAMS-26/streams-contrib: streams-persist-console/src/main/java/org/apache/streams/console/ streams-provider-twitter/src/main/java/org/apache/st

2014-02-26 Thread sblackmon
Author: sblackmon Date: Thu Feb 27 00:13:52 2014 New Revision: 1572361 URL: http://svn.apache.org/r1572361 Log: some refactoring for dataflow Added: incubator/streams/branches/STREAMS-26/streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console

svn commit: r1572379 - in /incubator/streams/branches/STREAMS-26: streams-contrib/streams-persist-elasticsearch/ streams-contrib/streams-persist-hdfs/ streams-contrib/streams-persist-hdfs/src/main/jav

2014-02-26 Thread sblackmon
Author: sblackmon Date: Thu Feb 27 01:28:48 2014 New Revision: 1572379 URL: http://svn.apache.org/r1572379 Log: applied ryan's patch for type-aware deepcopy avoiding needing to serialize member fields of writers Modified: incubator/streams/branches/STREAMS-26/streams-contrib/streams-persist

svn commit: r1572650 - /incubator/streams/branches/STREAMS-26/streams-contrib/streams-persist-hdfs/src/main/jsonschema/org/apache/streams/hdfs/HdfsWriterConfiguration.json

2014-02-27 Thread sblackmon
Author: sblackmon Date: Thu Feb 27 16:36:54 2014 New Revision: 1572650 URL: http://svn.apache.org/r1572650 Log: Missing a jsonbean Added: incubator/streams/branches/STREAMS-26/streams-contrib/streams-persist-hdfs/src/main/jsonschema/org/apache/streams/hdfs/HdfsWriterConfiguration.json

svn commit: r1572764 - in /incubator/streams/branches/STREAMS-26/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor: ./ TwitterEventProcessor.java TwitterProfi

2014-02-27 Thread sblackmon
Author: sblackmon Date: Thu Feb 27 22:37:40 2014 New Revision: 1572764 URL: http://svn.apache.org/r1572764 Log: Adding a missing package Added: incubator/streams/branches/STREAMS-26/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/ incubator

svn commit: r1572821 - in /incubator/streams/branches/STREAMS-26: streams-contrib/ streams-contrib/streams-persist-console/src/main/java/org/apache/streams/console/ streams-contrib/streams-persist-ela

2014-02-27 Thread sblackmon
Author: sblackmon Date: Fri Feb 28 05:14:16 2014 New Revision: 1572821 URL: http://svn.apache.org/r1572821 Log: Adding support for perpetual streams, minor refactoring, work on moreover provider Modified: incubator/streams/branches/STREAMS-26/streams-contrib/pom.xml incubator/streams

svn commit: r1572843 - in /incubator/streams/branches/STREAMS-26/streams-contrib/streams-provider-moreover/src/main/java/org/apache/streams/data/moreover: MoreoverClient.java MoreoverProvider.java Mor

2014-02-27 Thread sblackmon
Author: sblackmon Date: Fri Feb 28 07:23:23 2014 New Revision: 1572843 URL: http://svn.apache.org/r1572843 Log: Made some tweaks and now provider is running single-threaded Modified: incubator/streams/branches/STREAMS-26/streams-contrib/streams-provider-moreover/src/main/java/org/apache

svn commit: r1573789 - in /incubator/streams/branches/STREAMS-26: ./ streams-contrib/streams-persist-elasticsearch/ streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elast

2014-03-03 Thread sblackmon
Author: sblackmon Date: Mon Mar 3 22:36:59 2014 New Revision: 1573789 URL: http://svn.apache.org/r1573789 Log: updates to ES 1.0.1, perpetual read from hdfs Modified: incubator/streams/branches/STREAMS-26/pom.xml incubator/streams/branches/STREAMS-26/streams-contrib/streams-persist

svn commit: r1574695 - in /incubator/streams/branches/STREAMS-26/streams-contrib/streams-persist-hdfs/src/main/java/org/apache/streams/hdfs: WebHdfsPersistReader.java WebHdfsPersistReaderTask.java

2014-03-05 Thread sblackmon
Author: sblackmon Date: Wed Mar 5 22:22:46 2014 New Revision: 1574695 URL: http://svn.apache.org/r1574695 Log: missing two files Added: incubator/streams/branches/STREAMS-26/streams-contrib/streams-persist-hdfs/src/main/java/org/apache/streams/hdfs/WebHdfsPersistReader.java incubator

[1/2] git commit: Cleaning up contrib modules Preparing to merge STREAMS-26

2014-03-19 Thread sblackmon
/f9165129 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/f9165129 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/f9165129 Branch: refs/heads/STREAMS-26 Commit: f916512905fc911ee7bc41fe0cef7478dc0cdefb Parents: 3499016 Author: sblackmon sblack

[2/2] git commit: Merge branch 'STREAMS-26' of https://git-wip-us.apache.org/repos/asf/incubator-streams into STREAMS-26

2014-03-19 Thread sblackmon
Merge branch 'STREAMS-26' of https://git-wip-us.apache.org/repos/asf/incubator-streams into STREAMS-26 Conflicts: provision/provision.iml streams-contrib/streams-components-test/streams-components-test.iml streams-contrib/streams-provider-rss/streams-provider-rss.iml

[1/2] git commit: these iml files shouldn't be here

2014-03-19 Thread sblackmon
Repository: incubator-streams Updated Branches: refs/heads/STREAMS-26 3a192885a - 81478217f these iml files shouldn't be here Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/d4b03f85 Tree:

git commit: changing snapshot version to test with downstream builds

2014-03-19 Thread sblackmon
Repository: incubator-streams Updated Branches: refs/heads/STREAMS-26 81478217f - 2ec7fe8cf changing snapshot version to test with downstream builds Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit:

[1/5] adding google provider, tweaks to localbuilder and hdfs reader

2014-03-21 Thread sblackmon
Repository: incubator-streams Updated Branches: refs/heads/STREAMS-26 2ec7fe8cf - 61592dc07 http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/61592dc0/streams-contrib/streams-provider-google/pom.xml -- diff --git

[5/5] git commit: adding google provider, tweaks to localbuilder and hdfs reader

2014-03-21 Thread sblackmon
java.util.Queue; -import java.util.concurrent.*; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; +import java.util.concurrent.LinkedBlockingQueue; /** * Created by sblackmon on 2/28/14. @@ -117,11 +118,19 @@ public class WebHdfsPersistReader implements

[3/5] adding google provider, tweaks to localbuilder and hdfs reader

2014-03-21 Thread sblackmon
com.typesafe.config.Config; +import org.apache.streams.config.StreamsConfigurator; +import org.apache.streams.google.gplus.GPlusConfiguration; +import org.apache.streams.google.gplus.GPlusOAuthConfiguration; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +/** + * Created by sblackmon on 12/10/13

[1/3] changing build version back to 0.1-SNAPSHOT to prepare for merge

2014-03-21 Thread sblackmon
Repository: incubator-streams Updated Branches: refs/heads/STREAMS-26 61592dc07 - e3d0469c2 http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/e3d0469c/streams-contrib/streams-provider-google/google-gplus/pom.xml --

[3/3] git commit: changing build version back to 0.1-SNAPSHOT to prepare for merge

2014-03-21 Thread sblackmon
org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import java.io.BufferedReader; -import java.io.InputStream; -import java.io.InputStreamReader; - -/** - * Created with IntelliJ IDEA. - * User: sblackmon - * Date: 8/20/13 - * Time: 5:57 PM - * To change this template use File | Settings | File

[50/71] [abbrv] git commit: Made some tweaks and now provider is running single-threaded

2014-03-21 Thread sblackmon
Author: sblackmon sblackmon@unknown Authored: Fri Feb 28 07:23:23 2014 + Committer: sblackmon sblackmon@unknown Committed: Fri Feb 28 07:23:23 2014 + -- .../streams/data/moreover/MoreoverClient.java | 2 +- .../streams/data

[44/71] [abbrv] git commit: applied ryan's patch for type-aware deepcopy avoiding needing to serialize member fields of writers

2014-03-21 Thread sblackmon
: 715e41189008779972887801eb13e2b59633fb6e Parents: 7465065 Author: sblackmon sblackmon@unknown Authored: Thu Feb 27 01:28:48 2014 + Committer: sblackmon sblackmon@unknown Committed: Thu Feb 27 01:28:48 2014 + -- .../streams-persist-elasticsearch

[60/71] [abbrv] adding google provider, tweaks to localbuilder and hdfs reader

2014-03-21 Thread sblackmon
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/61592dc0/streams-contrib/streams-provider-google/pom.xml -- diff --git a/streams-contrib/streams-provider-google/pom.xml

[42/71] [abbrv] git commit: altering StreamsResultSet to be easier to use

2014-03-21 Thread sblackmon
/incubator-streams/commit/396eb4a3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/396eb4a3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/396eb4a3 Branch: refs/heads/master Commit: 396eb4a3c30a7c33f108ff79457d9992f4c68ceb Parents: 4705fcb Author: sblackmon

[37/71] [abbrv] git commit: fixing STREAMS-26

2014-03-21 Thread sblackmon
/d256daf4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/d256daf4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/d256daf4 Branch: refs/heads/master Commit: d256daf40d9facf11af817c6c3bcd2853a1f14e4 Parents: 6ea69f2 Author: sblackmon sblackmon@unknown Authored

[71/71] [abbrv] git commit: Merge branch 'STREAMS-26'

2014-03-21 Thread sblackmon
Merge branch 'STREAMS-26' Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/d72d6b43 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/d72d6b43 Diff:

[38/71] [abbrv] git commit: Activating kafka and hdfs modules Ensuring providers, processors, and persisters are serializable

2014-03-21 Thread sblackmon
: 3d7ff8f897ab26cac62a29dff06db118e91fa418 Parents: d256daf Author: sblackmon sblackmon@unknown Authored: Mon Feb 24 23:20:47 2014 + Committer: sblackmon sblackmon@unknown Committed: Mon Feb 24 23:20:47 2014 + -- pom.xml

[23/71] [abbrv] fixing STREAMS-26 branch

2014-03-21 Thread sblackmon
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/6ea69f29/trunk/streams-contrib/streams-provider-gnip/gnip-edc-instagram/pom.xml -- diff --git a/trunk/streams-contrib/streams-provider-gnip/gnip-edc-instagram/pom.xml

[54/71] [abbrv] git commit: found and fixed failure condition in moreoverclient made HDFS id (column 1) the default ES id

2014-03-21 Thread sblackmon
/incubator-streams/tree/34990168 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/34990168 Branch: refs/heads/master Commit: 34990168bf9d01540d9100162ef5d04a48d35a32 Parents: d764d7c Author: sblackmon sblack...@w2odigital.com Authored: Mon Mar 17 14:51:40 2014 -0500 Committer

[27/71] [abbrv] fixing STREAMS-26 branch

2014-03-21 Thread sblackmon
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/6ea69f29/trunk/streams-contrib/streams-provider-gnip/gnip-edc-flickr/pom.xml -- diff --git a/trunk/streams-contrib/streams-provider-gnip/gnip-edc-flickr/pom.xml

[56/71] [abbrv] git commit: Fixed long-running test

2014-03-21 Thread sblackmon
/asf/incubator-streams/diff/3a192885 Branch: refs/heads/master Commit: 3a192885a7dc13c07dabb915a7223ca748fc1e59 Parents: f916512 Author: sblackmon sblack...@w2odigital.com Authored: Wed Mar 19 14:00:19 2014 -0500 Committer: sblackmon sblack...@w2odigital.com Committed: Wed Mar 19 14:00:19 2014 -0500

[08/71] [abbrv] fixing STREAMS-26 branch

2014-03-21 Thread sblackmon
org.apache.streams.twitter.pojo.Tweet; -import org.apache.streams.twitter.provider.TwitterEventClassifier; -import org.junit.Assert; -import org.junit.Test; - -/** - * Created by sblackmon on 12/13/13. - */ -public class TwitterEventClassifierTest { - -private String tweet = {\created_at\:\Wed Dec

[43/71] [abbrv] git commit: some refactoring for dataflow

2014-03-21 Thread sblackmon
/commit/74650657 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/74650657 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/74650657 Branch: refs/heads/master Commit: 74650657f1693ba4ca2ba539990d23a0e2a0bab1 Parents: 396eb4a Author: sblackmon sblackmon@unknown

[53/71] [abbrv] git commit: missing two files

2014-03-21 Thread sblackmon
/d764d7c9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/d764d7c9 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/d764d7c9 Branch: refs/heads/master Commit: d764d7c969ed41733f17fc1d5c266926442b4e42 Parents: ab103c9 Author: sblackmon sblackmon@unknown Authored

[29/71] [abbrv] fixing STREAMS-26 branch

2014-03-21 Thread sblackmon
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/6ea69f29/trunk/streams-contrib/streams-provider-facebook/src/test/resources/testpost.json -- diff --git

[12/71] [abbrv] fixing STREAMS-26 branch

2014-03-21 Thread sblackmon
with IntelliJ IDEA. - * User: sblackmon - * Date: 8/20/13 - * Time: 5:57 PM - * To change this template use File | Settings | File Templates. - */ -public class SysomosJsonSerDeTest { - -private final static Logger LOGGER = LoggerFactory.getLogger(SysomosJsonSerDeTest.class); - -private

[45/71] [abbrv] git commit: Added public static IDs to assist stream builders

2014-03-21 Thread sblackmon
: sblackmon sblackmon@unknown Authored: Thu Feb 27 02:26:22 2014 + Committer: sblackmon sblackmon@unknown Committed: Thu Feb 27 02:26:22 2014 + -- .../apache/streams/elasticsearch/ElasticsearchPersistWriter.java | 2 ++ .../main

[49/71] [abbrv] git commit: Adding support for perpetual streams, minor refactoring, work on moreover provider

2014-03-21 Thread sblackmon
Parents: 2eb90cd Author: sblackmon sblackmon@unknown Authored: Fri Feb 28 05:14:16 2014 + Committer: sblackmon sblackmon@unknown Committed: Fri Feb 28 05:14:16 2014 + -- streams-contrib/pom.xml

[64/71] [abbrv] git commit: adding google provider, tweaks to localbuilder and hdfs reader

2014-03-21 Thread sblackmon
java.util.Queue; -import java.util.concurrent.*; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; +import java.util.concurrent.LinkedBlockingQueue; /** * Created by sblackmon on 2/28/14. @@ -117,11 +118,19 @@ public class WebHdfsPersistReader implements

[55/71] [abbrv] git commit: Cleaning up contrib modules Preparing to merge STREAMS-26

2014-03-21 Thread sblackmon
: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/f9165129 Branch: refs/heads/master Commit: f916512905fc911ee7bc41fe0cef7478dc0cdefb Parents: 3499016 Author: sblackmon sblack...@w2odigital.com Authored: Wed Mar 19 13:36:33 2014 -0500 Committer: sblackmon sblack...@w2odigital.com Committed

[16/71] [abbrv] fixing STREAMS-26 branch

2014-03-21 Thread sblackmon
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/6ea69f29/trunk/streams-contrib/streams-provider-moreover/src/main/java/org/apache/streams/data/moreover/MoreoverResultSetWrapper.java -- diff --git

[03/71] [abbrv] fixing STREAMS-26 branch

2014-03-21 Thread sblackmon
; -import java.net.URISyntaxException; -import java.net.URL; -import java.util.ArrayList; -import java.util.List; - -/** - * Created with IntelliJ IDEA. - * User: sblackmon - * Date: 9/20/13 - * Time: 11:17 AM - * To change this template use File | Settings | File Templates. - */ -public class

[39/71] [abbrv] git commit: adding a few missing files

2014-03-21 Thread sblackmon
/commit/c0281362 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/c0281362 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/c0281362 Branch: refs/heads/master Commit: c0281362be2062cc9199c48070b4bd3e16b9c142 Parents: 3d7ff8f Author: sblackmon sblackmon@unknown

[47/71] [abbrv] git commit: Refactored to use StreamsLocalBuilder

2014-03-21 Thread sblackmon
-streams/commit/728a2258 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/728a2258 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/728a2258 Branch: refs/heads/master Commit: 728a22581839f9a45f5d887b3121fcc4a3ffdb74 Parents: 00a3a19 Author: sblackmon sblackmon

[57/71] [abbrv] git commit: these iml files shouldn't be here

2014-03-21 Thread sblackmon
these iml files shouldn't be here Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/d4b03f85 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/d4b03f85 Diff:

[25/71] [abbrv] fixing STREAMS-26 branch

2014-03-21 Thread sblackmon
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/6ea69f29/trunk/streams-contrib/streams-provider-gnip/gnip-edc-googleplus/pom.xml -- diff --git

[69/71] [abbrv] git commit: iml should not be in source control

2014-03-21 Thread sblackmon
iml should not be in source control Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/aaeb0217 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/aaeb0217 Diff:

[62/71] [abbrv] adding google provider, tweaks to localbuilder and hdfs reader

2014-03-21 Thread sblackmon
com.typesafe.config.Config; +import org.apache.streams.config.StreamsConfigurator; +import org.apache.streams.google.gplus.GPlusConfiguration; +import org.apache.streams.google.gplus.GPlusOAuthConfiguration; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +/** + * Created by sblackmon on 12/10/13

[31/71] [abbrv] fixing STREAMS-26 branch

2014-03-21 Thread sblackmon
/FacebookPublicFeedXmlActivitySerializer.java +++ /dev/null @@ -1,11 +0,0 @@ -package com.facebook.feed; - -/** - * Created with IntelliJ IDEA. - * User: sblackmon - * Date: 10/2/13 - * Time: 6:32 PM - * To change this template use File | Settings | File Templates. - */ -public class

[51/71] [abbrv] git commit: updates to ES 1.0.1, perpetual read from hdfs

2014-03-21 Thread sblackmon
/incubator-streams/commit/63a85a83 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/63a85a83 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/63a85a83 Branch: refs/heads/master Commit: 63a85a83f5904f4362ebb91f659cbd6695a60f72 Parents: e6f3d4e Author: sblackmon

[68/71] [abbrv] git commit: not adding monitor thread, because it freezes LocalStreamBuilderTest

2014-03-21 Thread sblackmon
not adding monitor thread, because it freezes LocalStreamBuilderTest Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/c614c6a8 Tree:

[48/71] [abbrv] git commit: Adding a missing package

2014-03-21 Thread sblackmon
/commit/2eb90cd6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/2eb90cd6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/2eb90cd6 Branch: refs/heads/master Commit: 2eb90cd654e8c80fd073a570fbc573d07f644a56 Parents: 728a225 Author: sblackmon sblackmon@unknown

[67/71] [abbrv] git commit: changing build version back to 0.1-SNAPSHOT to prepare for merge

2014-03-21 Thread sblackmon
org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import java.io.BufferedReader; -import java.io.InputStream; -import java.io.InputStreamReader; - -/** - * Created with IntelliJ IDEA. - * User: sblackmon - * Date: 8/20/13 - * Time: 5:57 PM - * To change this template use File | Settings | File

[06/13] adding uncommitted modules

2014-03-24 Thread sblackmon
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/89ff615e/streams-core/src/main/java/org/apache/streams/core/DatumStatus.java -- diff --git a/streams-core/src/main/java/org/apache/streams/core/DatumStatus.java

[08/13] git commit: adding uncommitted modules

2014-03-24 Thread sblackmon
@@ +package org.apache.streams.hbase; + +import com.typesafe.config.Config; +import org.apache.streams.config.StreamsConfigurator; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +/** + * Created by sblackmon on 12/10/13. + */ +public class HbaseConfigurator { + +private final

[10/13] dropping streams-pojo-extensions, BC activity can be extended without it move streams cassandra under contrib move streams-eip-routes under runtimes, renaming streams-runtime-webapp

2014-03-24 Thread sblackmon
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/adb43b29/streams-runtimes/streams-runtime-webapp/src/test/java/org/apache/streams/messaging/service/impl/CassandraActivityServiceTest.java -- diff --git

git commit: adding platform-level status counters debugging data leak

2014-03-24 Thread sblackmon
java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; @@ -32,7 +27,7 @@ import java.util.concurrent.LinkedBlockingQueue; /** * Created by sblackmon on 2/28/14. */ -public class WebHdfsPersistReader implements StreamsPersistReader { +public class WebHdfsPersistReader

git commit: fixed datum leak

2014-03-24 Thread sblackmon
Repository: incubator-streams Updated Branches: refs/heads/springcleaning 6adb12a33 - c2a858db2 fixed datum leak Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/c2a858db Tree:

git commit: added prototype pig runtime wrapper for serializers and processors added serialization exceptions storm version bump to match maven central

2014-03-25 Thread sblackmon
: 7f543e5b93327cc2fa6f5dc7e901d18b88a22949 Parents: c2a858d Author: sblackmon sblack...@w2odigital.com Authored: Tue Mar 25 18:46:12 2014 -0500 Committer: sblackmon sblack...@w2odigital.com Committed: Tue Mar 25 18:46:12 2014 -0500

[1/3] making activity.links an array of strings, so it's useful adding processor-urls, still debugging

2014-03-28 Thread sblackmon
; +import org.joda.time.DateTime; +import org.joda.time.format.DateTimeFormatter; +import org.joda.time.format.ISODateTimeFormat; + +import java.io.IOException; + +/** + * Created by sblackmon on 3/27/14. + */ +public class StreamsDateTimeDeserializer extends StdDeserializerDateTime { + +public

git commit: adding backup job adding hdfs writer config

2014-03-30 Thread sblackmon
Repository: incubator-streams Updated Branches: refs/heads/springcleaning 9e757aed9 - 5d0f6bc42 adding backup job adding hdfs writer config Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/5d0f6bc4

git commit: attempting to fix jackson date deserialization

2014-03-31 Thread sblackmon
/37480ea9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/37480ea9 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/37480ea9 Branch: refs/heads/springcleaning Commit: 37480ea9d32ed2f79527295070f8e2388ba11192 Parents: 9edf176 Author: sblackmon sblack...@w2odigital.com

git commit: attempting to fix jackson date deserialization pom cleanup of logging dependencies

2014-03-31 Thread sblackmon
: sblackmon sblack...@w2odigital.com Authored: Mon Mar 31 17:28:54 2014 -0500 Committer: sblackmon sblack...@w2odigital.com Committed: Mon Mar 31 17:28:54 2014 -0500 -- pom.xml | 10

[2/3] git commit: Merge branch 'springcleaning' of https://git-wip-us.apache.org/repos/asf/incubator-streams into springcleaning

2014-04-01 Thread sblackmon
-us.apache.org/repos/asf/incubator-streams/tree/5f1fab35 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/5f1fab35 Branch: refs/heads/springcleaning Commit: 5f1fab35c051139494009631db21b509615cbe0b Parents: ee4efbb 574e103 Author: sblackmon sblack...@w2odigital.com Authored: Tue Apr 1 00:02

[3/3] git commit: trying to isolate cause of [main] ERROR org.apache.streams.pig.StreamsProcessorExec - java.util.concurrent.ExecutionException: java.lang.NoClassDefFoundError: Could not initialize cl

2014-04-01 Thread sblackmon
: 5eeccd5a15f88b005bc646c9188234aa28a251bd Parents: 5f1fab3 Author: sblackmon sblack...@w2odigital.com Authored: Tue Apr 1 01:13:35 2014 -0500 Committer: sblackmon sblack...@w2odigital.com Committed: Tue Apr 1 01:13:35 2014 -0500 -- .../apache

git commit: attempting to fix jackson date deserialization

2014-04-01 Thread sblackmon
/a93bb176 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/a93bb176 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/a93bb176 Branch: refs/heads/springcleaning Commit: a93bb176d1c17322b860966553371fe3fefd5596 Parents: cd4355a Author: sblackmon sblack...@w2odigital.com

git commit: document executor

2014-04-01 Thread sblackmon
-us.apache.org/repos/asf/incubator-streams/tree/aa6f3e56 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/aa6f3e56 Branch: refs/heads/springcleaning Commit: aa6f3e561dbe434dd234bb265dcd3fbf6d051ae7 Parents: a93bb17 Author: sblackmon sblack...@w2odigital.com Authored: Tue Apr 1 15:15:45

git commit: pom cleanup, of logging libraries

2014-04-01 Thread sblackmon
://git-wip-us.apache.org/repos/asf/incubator-streams/tree/8883b43a Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/8883b43a Branch: refs/heads/springcleaning Commit: 8883b43a55ac07dd031aeb4222dbbb2c79be3a22 Parents: aa6f3e5 Author: sblackmon sblack...@w2odigital.com Authored

git commit: Simplified twitter provider options Userstreams are connecting need documentation on creating oauth credentials authorized for specific user stream

2014-04-03 Thread sblackmon
: 4a2ca2d7f7ee2110d546b95104ad4b31416d49dd Parents: cc9bc04 Author: sblackmon sblack...@w2odigital.com Authored: Thu Apr 3 14:03:34 2014 -0500 Committer: sblackmon sblack...@w2odigital.com Committed: Thu Apr 3 14:03:34 2014 -0500

git commit: Fixed endpoint issue in TwitterStreamProvider

2014-04-04 Thread sblackmon
Repository: incubator-streams Updated Branches: refs/heads/springcleaning 4a2ca2d7f - 10923617e Fixed endpoint issue in TwitterStreamProvider Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit:

git commit: pushing progress on lucene and storm modules

2014-04-07 Thread sblackmon
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/27e67162 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/27e67162 Branch: refs/heads/springcleaning Commit: 27e67162f260926125b70a4b92ce5644923a6138 Parents: 1092361 Author: sblackmon sblack...@w2odigital.com

git commit: Java Bean for Link Details

2014-04-10 Thread sblackmon
-wip-us.apache.org/repos/asf/incubator-streams/tree/4b3d00eb Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/4b3d00eb Branch: refs/heads/springcleaning Commit: 4b3d00eba849fdc7cce40b7f8a656d49f7ee2682 Parents: 56a395f Author: sblackmon sblack...@w2odigital.com Authored: Thu Apr

[7/7] git commit: Fixed memory leak in ES reader pipelines

2014-04-11 Thread sblackmon
-us.apache.org/repos/asf/incubator-streams/diff/f877c5fa Branch: refs/heads/springcleaning Commit: f877c5fa46918f09a429139dbe5d2dfbf5eb4ea3 Parents: 79ac9aa Author: sblackmon sblack...@w2odigital.com Authored: Fri Apr 11 07:17:13 2014 -0600 Committer: sblackmon sblack...@w2odigital.com Committed: Fri Apr

[3/7] git commit: Changes

2014-04-11 Thread sblackmon
Changes Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/d8feb5ba Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/d8feb5ba Diff:

[42/53] [abbrv] git commit: Tweaks to Twitter ES to restore examples

2014-04-17 Thread sblackmon
-us.apache.org/repos/asf/incubator-streams/diff/0c310661 Branch: refs/heads/master Commit: 0c310661c8d437acd693ca7829db78b63bccffe1 Parents: 249198c Author: sblackmon sblack...@w2odigital.com Authored: Wed Apr 2 23:27:01 2014 -0500 Committer: sblackmon sblack...@w2odigital.com Committed: Wed Apr 2 23:27

[01/53] [abbrv] dropping streams-pojo-extensions, BC activity can be extended without it move streams cassandra under contrib move streams-eip-routes under runtimes, renaming streams-runtime-webapp

2014-04-17 Thread sblackmon
Repository: incubator-streams Updated Branches: refs/heads/master d72d6b431 - 3d9649774 refs/heads/springcleaning f877c5fa4 - 3d9649774

[44/53] [abbrv] git commit: Simplified twitter provider options Userstreams are connecting need documentation on creating oauth credentials authorized for specific user stream

2014-04-17 Thread sblackmon
/4a2ca2d7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/4a2ca2d7 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/4a2ca2d7 Branch: refs/heads/master Commit: 4a2ca2d7f7ee2110d546b95104ad4b31416d49dd Parents: cc9bc04 Author: sblackmon sblack...@w2odigital.com

[34/53] [abbrv] git commit: pom cleanup, of logging libraries

2014-04-17 Thread sblackmon
-us.apache.org/repos/asf/incubator-streams/diff/8883b43a Branch: refs/heads/master Commit: 8883b43a55ac07dd031aeb4222dbbb2c79be3a22 Parents: aa6f3e5 Author: sblackmon sblack...@w2odigital.com Authored: Tue Apr 1 17:03:51 2014 -0500 Committer: sblackmon sblack...@w2odigital.com Committed: Tue Apr 1 17:03:51 2014

[53/53] [abbrv] git commit: make sure ID is propagated to ES Writer

2014-04-17 Thread sblackmon
-us.apache.org/repos/asf/incubator-streams/diff/3d964977 Branch: refs/heads/springcleaning Commit: 3d9649774801f518cb5d393a5fa749697b299d6b Parents: f877c5f Author: sblackmon sblack...@w2odigital.com Authored: Mon Apr 14 11:10:44 2014 -0500 Committer: sblackmon sblack...@w2odigital.com Committed: Mon Apr

[39/53] [abbrv] git commit: Tweaks to Twitter ES to restore examples

2014-04-17 Thread sblackmon
-us.apache.org/repos/asf/incubator-streams/diff/b8fef9d1 Branch: refs/heads/master Commit: b8fef9d1b04734e959cf2aa01d5314f6aa0e844d Parents: da2d80c Author: sblackmon sblack...@w2odigital.com Authored: Wed Apr 2 16:32:26 2014 -0500 Committer: sblackmon sblack...@w2odigital.com Committed: Wed Apr 2 16:32

[20/53] [abbrv] git commit: attempting to fix jackson date deserialization

2014-04-17 Thread sblackmon
-us.apache.org/repos/asf/incubator-streams/diff/37480ea9 Branch: refs/heads/master Commit: 37480ea9d32ed2f79527295070f8e2388ba11192 Parents: 9edf176 Author: sblackmon sblack...@w2odigital.com Authored: Mon Mar 31 15:32:46 2014 -0500 Committer: sblackmon sblack...@w2odigital.com Committed: Mon Mar

[18/53] [abbrv] attempting to fix jackson date deserialization setting up a pig runtime test capability

2014-04-17 Thread sblackmon
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/9edf1766/streams-runtimes/streams-runtime-pig/src/test/resources/serializertestout.txt -- diff --git

  1   2   3   4   5   6   7   8   9   10   >