GitHub user isper3at opened a pull request:
https://github.com/apache/incubator-rya/pull/279
Rya streams base
## Description
>What Changed?
Rya Streams Feature Branch
### Tests
>Coverage?
Each major feature has test coverate
### Links
[Jira](https://issues.apache.org/jira/browse/RYA-460)
### Checklist
- [ ] Code Review
- [x] Squash Commits
People To Reivew
@kchilton2
@ejwhite922
@pujav65
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/isper3at/incubator-rya Rya-Streams-base
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/incubator-rya/pull/279.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #279
commit 28ea2e29a51dc22ba3efb0bdf3aa7fac27648518
Author: Andrew Smith
Date: 2018-01-16T17:39:34Z
RYA-446 Daemonifying Query Manager
commit 38c5927768ddeb680a0b3a20155124622d0420c2
Author: Andrew Smith
Date: 2018-01-18T22:51:40Z
RYA-449 Create QueryChangeLogSource
commit 01f02535c063361614911a749809afb5cf54b2dc
Author: Andrew Smith
Date: 2018-01-19T20:43:55Z
Rya 454 added QueryExecutor interface
commit 0be94418dce2229e48cfc760be97d6f90f68fae2
Author: Andrew Smith
Date: 2018-01-23T20:20:50Z
Rya 452 Updated QueryRepository
Updated QueryRepository to be a Service
Updated InMemoryQueryRepository to be an AbstractScheduledService
Added listeners to InMemoryQueryRepository
commit fbad2c30c36e1d2df3174bfe95ec68011959689b
Author: Andrew Smith
Date: 2018-01-23T20:44:32Z
RYA-455 stopAll queries for a rya instance
commit 1dedc48e0a4e311254820ad6662f8fda446cd444
Author: kchilton2
Date: 2018-01-23T20:50:17Z
RYA-448 Implement JAXB marshalling code for the Query Manager's XML
configuration file.
commit 2b654b5368faf28f9df73749fdbe87e02ce295e6
Author: kchilton2
Date: 2018-01-23T21:17:06Z
RYA-450 Implemented a Kafka backed QueryChangeLogSource.
commit 3e0a6e89d5cf5f08c5ed5dae14a4f7faf48477e3
Author: kchilton2
Date: 2018-01-25T22:19:58Z
RYA-446 Create a bin and rpm distribution for the Rya Streams Query Manager
application.
commit b4b635461cbd0264f1edc2df40e99fa96e7f007b
Author: kchilton2
Date: 2018-01-26T17:06:07Z
RYA-458 Updating the configuration XML so that you may only specify a
single QueryChangeLogSource.
commit dc0e803bf8c14ab94c972d43e126588591cf5b91
Author: kchilton2
Date: 2018-01-26T20:55:59Z
RYA-456 Implement a Single Node implementation of QueryExecutor.
commit 33b5d5b1b39b7d3de6c2df1887b0c8dc61ad0fb8
Author: Andrew Smith
Date: 2018-01-30T19:01:54Z
Rya 451 Query manager
QueryManager with tests
updated InMemoryQueryRepository and its tests
commit 69a17be4e66e5dc6ce7ce32f44580f428f18d224
Author: kchilton2
Date: 2018-01-30T19:44:58Z
RYA-453 Implement the Query Manager's Daemon that controls the application.
commit e5ed66854c7f67b6ee6eb4c9c445737bc95568fc
Author: Andrew Smith
Date: 2018-02-01T21:04:48Z
RYA-446 Service unit file for systemd
commit b4d70758a35cc1c6b9a6c5a93e126b7a644d3526
Author: kchilton2
Date: 2018-02-01T23:31:41Z
RYA-446 Making the Rya Streams Query Manager run as a service on CentOS 7.
commit c7802a2f10b089300d71da9fa1b87e2046efa501
Author: kchilton2
Date: 2018-02-03T03:47:59Z
RYA-451 Fixing threading issues with the QueryManager class.
commit 9a44bc2132a680dec40058741ebe59d4a95fe913
Author: eric.white
Date: 2018-02-27T20:58:37Z
RYA-443 Updated query-manager RPM to use Java based plugin
commit d31f4f872115d603c676e4f465a7d42114c044cb
Author: kchilton2
Date: 2018-02-14T18:49:52Z
RYA-466 Update the Rya Streams Client to stream results to file.
commit cd91cd1f1aa0f72b59e952d59552f46b56542488
Author: kchilton2
Date: 2018-02-08T22:21:10Z
RYA-462 Updated the Kafka topic name for StreamsQueries to include the Rya
Instance name.
Conflicts:
extras/rya.streams/client/src/main/java/org/apache/rya/streams/client/command/StreamResultsCommand.java
commit 0b7226e0c27f7f24ae131c8c23121f793321bf25
Author: kchilton2
Date: 2018-02-08T22:53:41Z
RYA-463 RYA-464 Added an isInsert flag to StreamsQuery to indicate when the
results of a query need to be inserted back into Rya.
Conflicts:
common/rya.api/src/main/java/org/apache/rya/api/utils/QueryInvestigator.java
common/rya.api/src/test/java/org/apache/rya/api/utils/QueryInvestigatorTest.java
extras/rya.streams/api/src/main/java/org/apache/rya/streams/api/entity/StreamsQuery.java
extras/rya.streams/api/src/test/java/org/apache/rya/streams/api/queries/InMemoryQueryRepositoryTest.java
extras/rya.streams/client/src/main/java/org/apache/rya/streams/client/command/ListQueriesCommand.java