svn commit: r1572412 - in /incubator/streams/branches/STREAMS-26/streams-contrib: streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ streams-persist-hdfs/src/main/java/org/apache/streams/hdfs/ streams-provider-twitter/src/mai...

[sblackmon]

Author: sblackmon
Date: Thu Feb 27 02:26:22 2014
New Revision: 1572412

URL: http://svn.apache.org/r1572412
Log:
Added public static IDs to assist stream builders

Modified:
    
incubator/streams/branches/STREAMS-26/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistWriter.java
    
incubator/streams/branches/STREAMS-26/streams-contrib/streams-persist-hdfs/src/main/java/org/apache/streams/hdfs/WebHdfsPersistWriter.java
    
incubator/streams/branches/STREAMS-26/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamProvider.java

Modified: 
incubator/streams/branches/STREAMS-26/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistWriter.java
URL: 
http://svn.apache.org/viewvc/incubator/streams/branches/STREAMS-26/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistWriter.java?rev=1572412&r1=1572411&r2=1572412&view=diff
==============================================================================
--- 
incubator/streams/branches/STREAMS-26/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistWriter.java
 (original)
+++ 
incubator/streams/branches/STREAMS-26/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistWriter.java
 Thu Feb 27 02:26:22 2014
@@ -40,6 +40,8 @@ import java.util.concurrent.ConcurrentLi
 
 public class ElasticsearchPersistWriter implements StreamsPersistWriter, 
Flushable, Closeable
 {
+    public final static String STREAMS_ID = "ElasticsearchPersistWriter";
+
     private final static Logger LOGGER = 
LoggerFactory.getLogger(ElasticsearchPersistWriter.class);
     private final static NumberFormat MEGABYTE_FORMAT = new 
DecimalFormat("#.##");
     private final static NumberFormat NUMBER_FORMAT = new 
DecimalFormat("###,###,###,###");

Modified: 
incubator/streams/branches/STREAMS-26/streams-contrib/streams-persist-hdfs/src/main/java/org/apache/streams/hdfs/WebHdfsPersistWriter.java
URL: 
http://svn.apache.org/viewvc/incubator/streams/branches/STREAMS-26/streams-contrib/streams-persist-hdfs/src/main/java/org/apache/streams/hdfs/WebHdfsPersistWriter.java?rev=1572412&r1=1572411&r2=1572412&view=diff
==============================================================================
--- 
incubator/streams/branches/STREAMS-26/streams-contrib/streams-persist-hdfs/src/main/java/org/apache/streams/hdfs/WebHdfsPersistWriter.java
 (original)
+++ 
incubator/streams/branches/STREAMS-26/streams-contrib/streams-persist-hdfs/src/main/java/org/apache/streams/hdfs/WebHdfsPersistWriter.java
 Thu Feb 27 02:26:22 2014
@@ -30,6 +30,8 @@ import java.util.concurrent.ConcurrentLi
 
 public class WebHdfsPersistWriter implements StreamsPersistWriter, Flushable, 
Closeable
 {
+    public final static String STREAMS_ID = "WebHdfsPersistWriter";
+
     private final static Logger LOGGER = 
LoggerFactory.getLogger(WebHdfsPersistWriter.class);
 
     private final static char DELIMITER = '\t';
@@ -245,7 +247,6 @@ public class WebHdfsPersistWriter implem
 
     @Override
     public void prepare(Object configurationObject) {
-        this.hdfsConfiguration = (HdfsWriterConfiguration)configurationObject;
         connectToWebHDFS();
         path = new Path(hdfsConfiguration.getPath());
     }

Modified: 
incubator/streams/branches/STREAMS-26/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamProvider.java
URL: 
http://svn.apache.org/viewvc/incubator/streams/branches/STREAMS-26/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamProvider.java?rev=1572412&r1=1572411&r2=1572412&view=diff
==============================================================================
--- 
incubator/streams/branches/STREAMS-26/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamProvider.java
 (original)
+++ 
incubator/streams/branches/STREAMS-26/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamProvider.java
 Thu Feb 27 02:26:22 2014
@@ -36,7 +36,7 @@ import java.util.concurrent.*;
  */
 public class TwitterStreamProvider implements StreamsProvider, Serializable {
 
-    private final static String STREAMS_ID = "TwitterStreamProvider";
+    public final static String STREAMS_ID = "TwitterStreamProvider";
 
     private final static Logger LOGGER = 
LoggerFactory.getLogger(TwitterStreamProvider.class);