[jira] [Commented] (RYA-443) Implement a single node query manager

[ 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:

[jira] [Commented] (RYA-443) Implement a single node query manager

[ 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] incubator-rya pull request #272: RYA-443 Rya Streams Query Manager daemon pr...

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] incubator-rya pull request #272: RYA-443 Rya Streams Query Manager daemon pr...

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;

[jira] [Commented] (RYA-443) Implement a single node query manager

[ 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] incubator-rya pull request #272: RYA-443 Rya Streams Query Manager daemon pr...

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

[jira] [Commented] (RYA-443) Implement a single node query manager

[ 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:

[jira] [Commented] (RYA-443) Implement a single node query manager

[ 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:

[jira] [Commented] (RYA-443) Implement a single node query manager

[ 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:

[jira] [Commented] (RYA-443) Implement a single node query manager

[ 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:

[jira] [Commented] (RYA-443) Implement a single node query manager

[ 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] incubator-rya pull request #272: RYA-443 Rya Streams Query Manager daemon pr...

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] incubator-rya pull request #272: RYA-443 Rya Streams Query Manager daemon pr...

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 @@

[jira] [Commented] (RYA-443) Implement a single node query manager

[ 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:

[jira] [Commented] (RYA-443) Implement a single node query manager

[ 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:

[jira] [Commented] (RYA-443) Implement a single node query manager

[ 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:

[jira] [Commented] (RYA-443) Implement a single node query manager

[ 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] incubator-rya pull request #272: RYA-443 Rya Streams Query Manager daemon pr...

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

[jira] [Commented] (RYA-443) Implement a single node query manager

[ 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] incubator-rya pull request #272: RYA-443 Rya Streams Query Manager daemon pr...

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 @@ +/**

[jira] [Commented] (RYA-443) Implement a single node query manager

[ 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:

[jira] [Commented] (RYA-443) Implement a single node query manager

[ 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:

[jira] [Commented] (RYA-443) Implement a single node query manager

[ 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:

[jira] [Commented] (RYA-443) Implement a single node query manager

[ 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:

[jira] [Commented] (RYA-443) Implement a single node query manager

[ 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] incubator-rya pull request #272: RYA-443 Rya Streams Query Manager daemon pr...

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

[jira] [Commented] (RYA-443) Implement a single node query manager

[ 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] incubator-rya pull request #272: RYA-443 Rya Streams Query Manager daemon pr...

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] incubator-rya pull request #272: RYA-443 Rya Streams Query Manager daemon pr...

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] incubator-rya pull request #272: RYA-443 Rya Streams Query Manager daemon pr...

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] incubator-rya pull request #272: RYA-443 Rya Streams Query Manager daemon pr...

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] incubator-rya pull request #272: RYA-443 Rya Streams Query Manager daemon pr...

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] incubator-rya pull request #272: RYA-443 Rya Streams Query Manager daemon pr...

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] incubator-rya pull request #272: RYA-443 Rya Streams Query Manager daemon pr...

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] incubator-rya pull request #272: RYA-443 Rya Streams Query Manager daemon pr...

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] incubator-rya pull request #272: RYA-443 Rya Streams Query Manager daemon pr...

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] incubator-rya pull request #272: RYA-443 Rya Streams Query Manager daemon pr...

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] incubator-rya pull request #272: RYA-443 Rya Streams Query Manager daemon pr...

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] incubator-rya pull request #272: RYA-443 Rya Streams Query Manager daemon pr...

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] incubator-rya pull request #272: RYA-443 Rya Streams Query Manager daemon pr...

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] incubator-rya pull request #272: RYA-443 Rya Streams Query Manager daemon pr...

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