You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by sb...@apache.org on 2014/06/20 23:27:20 UTC
[3/4] git commit: additional feature : generate CSDL for general
listening
additional feature : generate CSDL for general listening
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/d63a27a4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/d63a27a4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/d63a27a4
Branch: refs/heads/master
Commit: d63a27a446de21a7360bca190900bc6748945c43
Parents: 9ad1e04
Author: sblackmon <sb...@w2odigital.com>
Authored: Mon Jun 16 16:17:38 2014 -0500
Committer: sblackmon <sb...@w2odigital.com>
Committed: Mon Jun 16 16:17:38 2014 -0500
----------------------------------------------------------------------
.../streams/datasift/csdl/DatasiftCsdlUtil.java | 28 ++++++++++++++++++++
1 file changed, 28 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/d63a27a4/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/csdl/DatasiftCsdlUtil.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/csdl/DatasiftCsdlUtil.java b/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/csdl/DatasiftCsdlUtil.java
index 1a941c6..e317e51 100644
--- a/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/csdl/DatasiftCsdlUtil.java
+++ b/streams-contrib/streams-provider-datasift/src/main/java/org/apache/streams/datasift/csdl/DatasiftCsdlUtil.java
@@ -83,4 +83,32 @@ public class DatasiftCsdlUtil {
return csdlBuilder.toString();
}
+
+ public static String csdlFromKeywords(List<String> include, List<String> exclude) throws Exception {
+
+ StringBuilder csdlBuilder = new StringBuilder();
+
+ csdlBuilder.append("interaction.content contains_any \"");
+ ListIterator<String> listIterator = Lists.newArrayList(include).listIterator();
+ while( listIterator.hasNext() ) {
+ csdlBuilder.append(listIterator.next());
+ if (listIterator.hasNext())
+ csdlBuilder.append(",");
+ }
+ csdlBuilder.append("\"\n");
+ csdlBuilder.append(" AND NOT ( \n");
+ csdlBuilder.append("interaction.content \"");
+ listIterator = Lists.newArrayList(exclude).listIterator();
+ while( listIterator.hasNext() ) {
+ csdlBuilder.append(listIterator.next());
+ if (listIterator.hasNext())
+ csdlBuilder.append(",");
+ }
+ csdlBuilder.append("\"\n");
+ csdlBuilder.append(")\n");
+
+ log.debug(csdlBuilder.toString());
+
+ return csdlBuilder.toString();
+ }
}