You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by ch...@apache.org on 2015/09/10 00:32:17 UTC
[29/50] [abbrv] incubator-apex-malhar git commit: Fixed Twitter demo
for App Builder
Fixed Twitter demo for App Builder
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/f40ba346
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/f40ba346
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/f40ba346
Branch: refs/heads/master
Commit: f40ba346ae660e1b89de1ebbb3f8e1f7ba31cad0
Parents: a028069
Author: Timothy Farkas <ti...@datatorrent.com>
Authored: Thu Aug 6 16:07:03 2015 -0700
Committer: thomas <th...@datatorrent.com>
Committed: Thu Aug 6 22:14:05 2015 -0700
----------------------------------------------------------------------
.../contrib/twitter/TwitterSampleInput.java | 32 ++++++++++++++++++++
demos/pom.xml | 4 +--
demos/twitter/pom.xml | 2 +-
.../demos/twitter/WindowedTopCounter.java | 5 +++
4 files changed, 40 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/f40ba346/contrib/src/main/java/com/datatorrent/contrib/twitter/TwitterSampleInput.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/twitter/TwitterSampleInput.java b/contrib/src/main/java/com/datatorrent/contrib/twitter/TwitterSampleInput.java
index 916bea8..9daef7f 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/twitter/TwitterSampleInput.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/twitter/TwitterSampleInput.java
@@ -293,6 +293,14 @@ public class TwitterSampleInput implements InputOperator, ActivationListener<Ope
}
/**
+ * @return the consumerKey
+ */
+ public String getConsumerKey()
+ {
+ return consumerKey;
+ }
+
+ /**
* @param consumerKey the consumerKey to set
*/
public void setConsumerKey(String consumerKey)
@@ -301,6 +309,14 @@ public class TwitterSampleInput implements InputOperator, ActivationListener<Ope
}
/**
+ * @return the consumerSecret
+ */
+ public String getConsumerSecret()
+ {
+ return consumerSecret;
+ }
+
+ /**
* @param consumerSecret the consumerSecret to set
*/
public void setConsumerSecret(String consumerSecret)
@@ -309,6 +325,14 @@ public class TwitterSampleInput implements InputOperator, ActivationListener<Ope
}
/**
+ * @return the accessToken
+ */
+ public String getAccessToken()
+ {
+ return accessToken;
+ }
+
+ /**
* @param accessToken the accessToken to set
*/
public void setAccessToken(String accessToken)
@@ -317,6 +341,14 @@ public class TwitterSampleInput implements InputOperator, ActivationListener<Ope
}
/**
+ * @return the accessTokenSecret
+ */
+ public String getAccessTokenSecret()
+ {
+ return accessTokenSecret;
+ }
+
+ /**
* @param accessTokenSecret the accessTokenSecret to set
*/
public void setAccessTokenSecret(String accessTokenSecret)
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/f40ba346/demos/pom.xml
----------------------------------------------------------------------
diff --git a/demos/pom.xml b/demos/pom.xml
index 64c6c4a..c17120f 100644
--- a/demos/pom.xml
+++ b/demos/pom.xml
@@ -173,7 +173,7 @@
<dependency>
<groupId>com.datatorrent</groupId>
<artifactId>malhar-library</artifactId>
- <version>${datatorrent.version}</version>
+ <version>${project.version}</version>
<exclusions>
<exclusion>
<groupId>*</groupId>
@@ -184,7 +184,7 @@
<dependency>
<groupId>com.datatorrent</groupId>
<artifactId>malhar-library</artifactId>
- <version>${datatorrent.version}</version>
+ <version>${project.version}</version>
<classifier>tests</classifier>
<scope>test</scope>
<exclusions>
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/f40ba346/demos/twitter/pom.xml
----------------------------------------------------------------------
diff --git a/demos/twitter/pom.xml b/demos/twitter/pom.xml
index c55ee79..8a0bec9 100644
--- a/demos/twitter/pom.xml
+++ b/demos/twitter/pom.xml
@@ -54,7 +54,7 @@
<dependency>
<groupId>com.datatorrent</groupId>
<artifactId>malhar-contrib</artifactId>
- <version>${datatorrent.version}</version>
+ <version>${project.version}</version>
<exclusions>
<exclusion>
<groupId>*</groupId>
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/f40ba346/demos/twitter/src/main/java/com/datatorrent/demos/twitter/WindowedTopCounter.java
----------------------------------------------------------------------
diff --git a/demos/twitter/src/main/java/com/datatorrent/demos/twitter/WindowedTopCounter.java b/demos/twitter/src/main/java/com/datatorrent/demos/twitter/WindowedTopCounter.java
index 2edf7fd..3354ed4 100644
--- a/demos/twitter/src/main/java/com/datatorrent/demos/twitter/WindowedTopCounter.java
+++ b/demos/twitter/src/main/java/com/datatorrent/demos/twitter/WindowedTopCounter.java
@@ -179,6 +179,11 @@ public class WindowedTopCounter<T> extends BaseOperator
topCount = count;
}
+ public int getTopCount()
+ {
+ return topCount;
+ }
+
/**
* @return the windows
*/