[
https://issues.apache.org/jira/browse/RYA-443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358666#comment-16358666
]
ASF GitHub Bot commented on RYA-443:
Github user kchilton2 commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/RYA-443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358656#comment-16358656
]
ASF GitHub Bot commented on RYA-443:
Github user kchilton2 commented on a diff in the pull request:
Github user kchilton2 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/272#discussion_r167284717
--- Diff:
extras/rya.streams/query-manager/src/main/java/org/apache/rya/streams/querymanager/kafka/KafkaQueryChangeLogSource.java
---
@@ -0,0
Github user kchilton2 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/272#discussion_r167284418
--- Diff: extras/rya.streams/query-manager/pom.xml ---
@@ -0,0 +1,253 @@
+
+
+http://maven.apache.org/POM/4.0.0;
[
https://issues.apache.org/jira/browse/RYA-443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358654#comment-16358654
]
ASF GitHub Bot commented on RYA-443:
Github user kchilton2 commented on a diff in the pull request:
Github user kchilton2 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/272#discussion_r167283976
--- Diff:
extras/rya.streams/api/src/main/java/org/apache/rya/streams/api/queries/QueryChange.java
---
@@ -110,6 +110,16 @@ public boolean
[
https://issues.apache.org/jira/browse/RYA-443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358523#comment-16358523
]
ASF GitHub Bot commented on RYA-443:
Github user ejwhite922 commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/RYA-443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358531#comment-16358531
]
ASF GitHub Bot commented on RYA-443:
Github user ejwhite922 commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/RYA-443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358532#comment-16358532
]
ASF GitHub Bot commented on RYA-443:
Github user ejwhite922 commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/RYA-443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358528#comment-16358528
]
ASF GitHub Bot commented on RYA-443:
Github user ejwhite922 commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/RYA-443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358519#comment-16358519
]
ASF GitHub Bot commented on RYA-443:
Github user ejwhite922 commented on a diff in the pull request:
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/272#discussion_r167241732
--- Diff:
extras/rya.streams/query-manager/src/main/java/org/apache/rya/streams/querymanager/QueryManager.java
---
@@ -0,0 +1,884 @@
+/**
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/272#discussion_r167242987
--- Diff:
extras/rya.streams/query-manager/src/main/java/org/apache/rya/streams/querymanager/QueryManagerDaemon.java
---
@@ -0,0 +1,136 @@
[
https://issues.apache.org/jira/browse/RYA-443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358535#comment-16358535
]
ASF GitHub Bot commented on RYA-443:
Github user ejwhite922 commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/RYA-443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358521#comment-16358521
]
ASF GitHub Bot commented on RYA-443:
Github user ejwhite922 commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/RYA-443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358527#comment-16358527
]
ASF GitHub Bot commented on RYA-443:
Github user ejwhite922 commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/RYA-443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358529#comment-16358529
]
ASF GitHub Bot commented on RYA-443:
Github user ejwhite922 commented on a diff in the pull request:
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/272#discussion_r167252337
--- Diff:
extras/rya.streams/client/src/main/java/org/apache/rya/streams/client/command/ListQueriesCommand.java
---
@@ -107,12 +112,11 @@ private
[
https://issues.apache.org/jira/browse/RYA-443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358526#comment-16358526
]
ASF GitHub Bot commented on RYA-443:
Github user ejwhite922 commented on a diff in the pull request:
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/272#discussion_r167240617
--- Diff:
extras/rya.streams/query-manager/src/main/java/org/apache/rya/streams/querymanager/QueryManager.java
---
@@ -0,0 +1,884 @@
+/**
[
https://issues.apache.org/jira/browse/RYA-443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358524#comment-16358524
]
ASF GitHub Bot commented on RYA-443:
Github user ejwhite922 commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/RYA-443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358534#comment-16358534
]
ASF GitHub Bot commented on RYA-443:
Github user ejwhite922 commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/RYA-443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358533#comment-16358533
]
ASF GitHub Bot commented on RYA-443:
Github user ejwhite922 commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/RYA-443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358520#comment-16358520
]
ASF GitHub Bot commented on RYA-443:
Github user ejwhite922 commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/RYA-443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358530#comment-16358530
]
ASF GitHub Bot commented on RYA-443:
Github user ejwhite922 commented on a diff in the pull request:
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/272#discussion_r167253121
--- Diff:
extras/rya.streams/client/src/main/java/org/apache/rya/streams/client/command/ListQueriesCommand.java
---
@@ -107,12 +112,11 @@ private
[
https://issues.apache.org/jira/browse/RYA-443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358522#comment-16358522
]
ASF GitHub Bot commented on RYA-443:
Github user ejwhite922 commented on a diff in the pull request:
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/272#discussion_r167241001
--- Diff:
extras/rya.streams/query-manager/src/main/java/org/apache/rya/streams/querymanager/QueryManager.java
---
@@ -0,0 +1,884 @@
+/**
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/272#discussion_r167252837
--- Diff:
extras/rya.streams/api/src/main/java/org/apache/rya/streams/api/entity/StreamsQuery.java
---
@@ -85,4 +85,19 @@ public boolean
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/272#discussion_r167235009
--- Diff:
extras/rya.streams/kafka/src/main/java/org/apache/rya/streams/kafka/KafkaTopics.java
---
@@ -48,7 +51,28 @@
*/
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/272#discussion_r167231162
--- Diff:
extras/rya.streams/api/src/main/java/org/apache/rya/streams/api/queries/InMemoryQueryRepository.java
---
@@ -243,8 +274,68 @@ private
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/272#discussion_r167249191
--- Diff:
extras/rya.streams/query-manager/src/test/java/org/apache/rya/streams/querymanager/ThreadUtil.java
---
@@ -0,0 +1,43 @@
+/**
+
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/272#discussion_r167230725
--- Diff:
extras/rya.streams/api/src/main/java/org/apache/rya/streams/api/entity/StreamsQuery.java
---
@@ -85,4 +85,19 @@ public boolean
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/272#discussion_r167235195
--- Diff:
extras/rya.streams/kafka/src/main/java/org/apache/rya/streams/kafka/SingleThreadKafkaStreamsFactory.java
---
@@ -0,0 +1,90 @@
+/**
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/272#discussion_r167242070
--- Diff:
extras/rya.streams/query-manager/src/main/java/org/apache/rya/streams/querymanager/QueryManager.java
---
@@ -0,0 +1,884 @@
+/**
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/272#discussion_r167243543
--- Diff:
extras/rya.streams/query-manager/src/main/java/org/apache/rya/streams/querymanager/kafka/KafkaQueryChangeLogSource.java
---
@@ -0,0
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/272#discussion_r167240341
--- Diff:
extras/rya.streams/query-manager/src/main/java/org/apache/rya/streams/querymanager/QueryManager.java
---
@@ -0,0 +1,884 @@
+/**
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/272#discussion_r167236812
--- Diff: extras/rya.streams/query-manager/pom.xml ---
@@ -0,0 +1,253 @@
+
+
+http://maven.apache.org/POM/4.0.0;
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/272#discussion_r167242868
--- Diff:
extras/rya.streams/query-manager/src/main/java/org/apache/rya/streams/querymanager/QueryManager.java
---
@@ -0,0 +1,884 @@
+/**
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/272#discussion_r167232266
--- Diff:
extras/rya.streams/api/src/main/java/org/apache/rya/streams/api/queries/QueryChange.java
---
@@ -110,6 +110,16 @@ public boolean
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/272#discussion_r167234267
--- Diff:
extras/rya.streams/api/src/test/java/org/apache/rya/streams/api/queries/InMemoryQueryRepositoryTest.java
---
@@ -85,11 +92,16 @@ public
41 matches
Mail list logo