Github user ejwhite922 commented on the issue:
https://github.com/apache/incubator-rya/pull/291
@jomach This will be in the next published release of Rya (4.0.0). It is
not available on any repo yet. Until then the source can be built locally from
master.
---
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/299#discussion_r200360089
--- Diff: extras/rya.manual/src/site/markdown/loaddata.md ---
@@ -92,29 +92,56 @@ The default "format" is RDF/XML, but these formats are
GitHub user ejwhite922 opened a pull request:
https://github.com/apache/incubator-rya/pull/297
RYA-495 Updated the Vagrantfile's dependencies
## Description
The Vagrantfile referenced sites that no longer hosted the dependencies for
Accumulo and Hadoop. New sites were used
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/296#discussion_r187667486
--- Diff:
extras/kafka.connect/mongo/src/main/java/org/apache/rya/kafka/connect/mongo/MongoRyaSinkTask.java
---
@@ -0,0 +1,122
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/296#discussion_r187667235
--- Diff:
extras/kafka.connect/accumulo/src/main/java/org/apache/rya/kafka/connect/accumulo/AccumuloRyaSinkTask.java
---
@@ -0,0 +1,111
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/296#discussion_r187629391
--- Diff:
extras/kafka.connect/accumulo/src/main/java/org/apache/rya/kafka/connect/accumulo/AccumuloRyaSinkTask.java
---
@@ -0,0 +1,111
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/296#discussion_r187636404
--- Diff: extras/kafka.connect/client/pom.xml ---
@@ -0,0 +1,135 @@
+
+
+http://maven.apache.org/POM/4.0.0;
+ xmlns:xsi
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/296#discussion_r187636622
--- Diff:
extras/kafka.connect/client/src/main/java/org/apache/rya/kafka/connect/client/CLIDriver.java
---
@@ -0,0 +1,121
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/296#discussion_r187640119
--- Diff:
dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoDBRdfConfiguration.java
---
@@ -274,16 +274,17 @@ public boolean
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/296#discussion_r187634162
--- Diff:
extras/kafka.connect/api/src/main/java/org/apache/rya/kafka/connect/api/sink/RyaSinkConnector.java
---
@@ -0,0 +1,69
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/296#discussion_r187631961
--- Diff:
extras/kafka.connect/accumulo/src/main/java/org/apache/rya/kafka/connect/accumulo/AccumuloRyaSinkTask.java
---
@@ -0,0 +1,111
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/296#discussion_r187638302
--- Diff:
extras/kafka.connect/mongo/src/main/java/org/apache/rya/kafka/connect/mongo/MongoRyaSinkTask.java
---
@@ -0,0 +1,122
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/296#discussion_r187637697
--- Diff:
extras/kafka.connect/client/src/main/java/org/apache/rya/kafka/connect/client/command/WriteStatementsCommand.java
---
@@ -0,0 +1,187
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/296#discussion_r187629343
--- Diff:
extras/kafka.connect/accumulo/src/main/java/org/apache/rya/kafka/connect/accumulo/AccumuloRyaSinkTask.java
---
@@ -0,0 +1,111
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/296#discussion_r187628752
--- Diff:
extras/kafka.connect/accumulo/src/main/java/org/apache/rya/kafka/connect/accumulo/AccumuloRyaSinkTask.java
---
@@ -0,0 +1,111
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/296#discussion_r187627726
--- Diff:
extras/kafka.connect/accumulo-it/src/test/java/org/apache/rya/kafka/connect/accumulo/AccumuloRyaSinkTaskIT.java
---
@@ -0,0 +1,100
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/296#discussion_r187638405
--- Diff:
extras/kafka.connect/mongo/src/main/java/org/apache/rya/kafka/connect/mongo/MongoRyaSinkTask.java
---
@@ -0,0 +1,122
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/296#discussion_r187632758
--- Diff:
extras/kafka.connect/api/src/main/java/org/apache/rya/kafka/connect/api/StatementsDeserializer.java
---
@@ -0,0 +1,92
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/296#discussion_r187634433
--- Diff:
extras/kafka.connect/api/src/main/java/org/apache/rya/kafka/connect/api/sink/RyaSinkTask.java
---
@@ -0,0 +1,144
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/296#discussion_r187633086
--- Diff:
extras/kafka.connect/api/src/main/java/org/apache/rya/kafka/connect/api/StatementsSerializer.java
---
@@ -0,0 +1,77
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/295#discussion_r187352392
--- Diff:
extras/indexing/src/test/java/org/apache/rya/api/client/accumulo/AccumuloExecuteSparqlQueryIT.java
---
@@ -0,0 +1,143
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/295#discussion_r187352243
--- Diff:
extras/indexing/src/test/java/org/apache/rya/api/client/accumulo/AccumuloExecuteSparqlQueryIT.java
---
@@ -0,0 +1,143
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/295#discussion_r187347869
--- Diff:
extras/indexing/src/test/java/org/apache/rya/api/client/accumulo/AccumuloExecuteSparqlQueryIT.java
---
@@ -0,0 +1,143
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/295#discussion_r187352662
--- Diff:
extras/shell/src/test/java/org/apache/rya/shell/AccumuloRyaCommandsIT.java ---
@@ -0,0 +1,91 @@
+/**
+ * Licensed to the Apache
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/294#discussion_r186189650
--- Diff:
dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/dao/SimpleMongoDBStorageStrategy.java
---
@@ -194,6 +204,7 @@ public BasicDBObject
Github user ejwhite922 commented on the issue:
https://github.com/apache/incubator-rya/pull/294
I'll squash it but it should need another sign off before merging.
---
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/294#discussion_r185266277
--- Diff: common/rya.api/src/test/resources/ISO-3166-1_Country_Codes.txt ---
@@ -0,0 +1,236 @@
+AF
--- End diff --
Testing
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/294#discussion_r185265223
--- Diff:
common/rya.api/src/main/java/org/apache/rya/api/utils/LiteralLanguageUtils.java
---
@@ -0,0 +1,37 @@
+/*
+ * Licensed
Github user ejwhite922 commented on the issue:
https://github.com/apache/incubator-rya/pull/294
asfbot build
---
GitHub user ejwhite922 opened a pull request:
https://github.com/apache/incubator-rya/pull/294
RYA-492 Added language support for Literals
## Description
File loading wasn't working when a language tag was used with a Literal.
RDF4J is stricter than OpenRDF with needing
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/293#discussion_r184127031
--- Diff:
dao/mongodb.rya/src/test/java/org/apache/rya/mongodb/aggregation/PipelineQueryIT.java
---
@@ -423,28 +423,28 @@ public void
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/293#discussion_r184128364
--- Diff:
dao/mongodb.rya/src/test/java/org/apache/rya/mongodb/MongoDBRyaDAO2IT.java ---
@@ -40,11 +40,11 @@
/**
* Integration tests
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/293#discussion_r184149352
--- Diff: pom.xml ---
@@ -381,6 +458,26 @@ under the License.
rya.indexing.pcj
${project.version
Github user ejwhite922 closed the pull request at:
https://github.com/apache/incubator-rya/pull/282
---
Github user ejwhite922 commented on the issue:
https://github.com/apache/incubator-rya/pull/245
@jomach could you close this PR when you have a chance? It's a duplicate
of [PR-291](https://github.com/apache/incubator-rya/pull/291) which has been
pulled in and closed. Thanks.
---
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/291#discussion_r182854497
--- Diff:
common/rya.api/src/main/java/org/apache/rya/api/domain/VarNameUtils.java ---
@@ -0,0 +1,202 @@
+/*
+ * Licensed to the Apache
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/291#discussion_r182849348
--- Diff:
common/rya.api/src/main/java/org/apache/rya/api/persist/index/RyaSecondaryIndexer.java
---
@@ -19,31 +19,29 @@
* under
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/291#discussion_r182849296
--- Diff: dao/accumulo.rya/pom.xml ---
@@ -43,25 +43,30 @@ under the License.
-org.openrdf.sesame
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/291#discussion_r182849235
--- Diff: extras/vagrantExample/src/main/vagrant/Vagrantfile ---
@@ -52,8 +52,8 @@ Vagrant.configure(2) do |config|
export
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/291#discussion_r182849095
--- Diff:
extras/indexing/src/main/java/org/apache/rya/indexing/IndexPlanValidator/ThreshholdPlanSelector.java
---
@@ -111,9 +110,9 @@ public
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/291#discussion_r182846009
--- Diff:
extras/indexing/src/main/java/org/apache/rya/indexing/FilterFunctionOptimizer.java
---
@@ -157,18 +156,18 @@ private void buildQuery
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/291#discussion_r182844645
--- Diff: common/rya.api/src/main/java/org/apache/rya/api/domain/Node.java
---
@@ -21,14 +21,14 @@
-import
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/291#discussion_r182844330
--- Diff: common/rya.api/src/main/java/org/apache/rya/api/domain/Node.java
---
@@ -21,14 +21,14 @@
-import
Github user ejwhite922 commented on the issue:
https://github.com/apache/incubator-rya/pull/245
This can be closed. New PR under my branch is opened for it
[here](https://github.com/apache/incubator-rya/pull/291) (PR-291)
---
GitHub user ejwhite922 opened a pull request:
https://github.com/apache/incubator-rya/pull/291
RYA-405 Migration of OpenRDF Sesame libraries to RDF4J
## Description
Continued from [PR-245](https://github.com/apache/incubator-rya/pull/245).
This updates Rya from OpenRDF Sesame
Github user ejwhite922 commented on the issue:
https://github.com/apache/incubator-rya/pull/245
@kchilton2 Yea, it'll be one commit.
---
Github user ejwhite922 commented on the issue:
https://github.com/apache/incubator-rya/pull/245
@jomach Thanks, but just waiting to hear if the dev list wants this in
3.2.13 or 4.0. Either way the updated PR is ready and should be up as soon as
that issue is resolved. Hopefully
Github user ejwhite922 commented on the issue:
https://github.com/apache/incubator-rya/pull/245
@theRealImy Sorry for the late reply; I just starting looking at this PR
again. This PR will be a part of this release. I will start getting this
updated with the latest commits since
Github user ejwhite922 commented on the issue:
https://github.com/apache/incubator-rya/pull/282
That one can't be built by Jenkins so the rpm would need to be built
locally.
---
Github user ejwhite922 commented on the issue:
https://github.com/apache/incubator-rya/pull/282
I fixed the issue with `rpm -e` not working with the version number. The
plugin's version property was including "-incubating" which RPM's don't like
"-" in that pr
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/286#discussion_r178586652
--- Diff:
extras/rya.streams/kafka/src/main/java/org/apache/rya/streams/kafka/interactor/KafkaTopicPropertiesBuilder.java
---
@@ -0,0 +1,46
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/286#discussion_r178588294
--- Diff:
extras/rya.streams/kafka/src/main/java/org/apache/rya/streams/kafka/interactor/KafkaTopicPropertiesBuilder.java
---
@@ -0,0 +1,46
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/286#discussion_r178586989
--- Diff:
extras/rya.streams/kafka/src/main/java/org/apache/rya/streams/kafka/interactor/KafkaTopicPropertiesBuilder.java
---
@@ -0,0 +1,46
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/286#discussion_r178587123
--- Diff:
extras/rya.streams/kafka/src/main/java/org/apache/rya/streams/kafka/interactor/KafkaTopicPropertiesBuilder.java
---
@@ -0,0 +1,46
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/285#discussion_r178577153
--- Diff: extras/indexingExample/src/main/java/MongoRyaDirectExample.java
---
@@ -805,6 +819,38 @@ public static void testAddAndDeleteNoContext
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/285#discussion_r178577147
--- Diff:
extras/rya.streams/client/src/test/java/org/apache/rya/streams/client/command/RunQueryCommandIT.java
---
@@ -196,4 +203,74 @@ public
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/285#discussion_r178576981
--- Diff:
extras/rya.streams/kafka/src/main/java/org/apache/rya/streams/kafka/processors/join/KeyValueJoinStateStore.java
---
@@ -77,30 +77,39
GitHub user ejwhite922 opened a pull request:
https://github.com/apache/incubator-rya/pull/285
RYA-469 Added tests for Rya Streams join iterator bug using LUBM data.
## Description
Joins were not working in Rya Streams. The KeyValueJoinStateStore needed
to have a queryId
Github user ejwhite922 commented on the issue:
https://github.com/apache/incubator-rya/pull/282
What error is it giving?
I am able to run `sudo rpm -e rya.streams.query-manager` without issue.
I'll upload the rpm that is working for me to my share. Sorry I
Github user ejwhite922 commented on the issue:
https://github.com/apache/incubator-rya/pull/282
@jdasch Yep, `sudo yum remove rya.streams.query-manager` works as well.
---
Github user ejwhite922 commented on the issue:
https://github.com/apache/incubator-rya/pull/284
I think we should still go with
[#282](https://github.com/apache/incubator-rya/pull/282). See comments in
there.
---
Github user ejwhite922 commented on the issue:
https://github.com/apache/incubator-rya/pull/282
I just tested today and this patch works on my CentOS 7 VM. I did an
install -> uninstall -> install -> uninstall of the rpm which all completed
successfully. I used the
Github user ejwhite922 commented on the issue:
https://github.com/apache/incubator-rya/pull/282
asfbot build
---
GitHub user ejwhite922 opened a pull request:
https://github.com/apache/incubator-rya/pull/282
RYA-443 Fixed Rya Streams Query Manager RPM version
## Description
Fixed the Query Manager RPM so that the "rpm.version" property gets
generated and replaced in all t
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/273#discussion_r172288309
--- Diff: extras/rya.manual/src/site/markdown/rya-streams.md ---
@@ -0,0 +1,386 @@
+
+
+# Rya Streams
+
+Introduced in 3.2.13
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/273#discussion_r172288178
--- Diff: extras/rya.manual/src/site/markdown/rya-streams.md ---
@@ -0,0 +1,386 @@
+
+
+# Rya Streams
+
+Introduced in 3.2.13
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/273#discussion_r172288365
--- Diff: extras/rya.manual/src/site/markdown/rya-streams.md ---
@@ -0,0 +1,386 @@
+
+
+# Rya Streams
+
+Introduced in 3.2.13
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/275#discussion_r171402268
--- Diff:
common/rya.api/src/main/java/org/apache/rya/api/utils/QueryInvestigator.java ---
@@ -0,0 +1,104 @@
+/**
+ * Licensed
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/275#discussion_r170336478
--- Diff:
extras/rya.streams/client/src/main/java/org/apache/rya/streams/client/command/StreamResultsCommand.java
---
@@ -167,17 +182,38
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/275#discussion_r170329580
--- Diff:
common/rya.api/src/test/java/org/apache/rya/api/utils/QueryInvestigatorTest.java
---
@@ -0,0 +1,123 @@
+/**
+ * Licensed
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/275#discussion_r170329694
--- Diff:
common/rya.api/src/test/java/org/apache/rya/api/utils/QueryInvestigatorTest.java
---
@@ -0,0 +1,123 @@
+/**
+ * Licensed
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/275#discussion_r170336740
--- Diff:
extras/rya.streams/client/src/main/java/org/apache/rya/streams/client/command/StreamResultsCommand.java
---
@@ -167,17 +182,38
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/275#discussion_r170322179
--- Diff:
common/rya.api/src/main/java/org/apache/rya/api/utils/QueryInvestigator.java ---
@@ -0,0 +1,104 @@
+/**
+ * Licensed
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/275#discussion_r170329299
--- Diff:
common/rya.api/src/main/java/org/apache/rya/api/utils/QueryInvestigator.java ---
@@ -0,0 +1,104 @@
+/**
+ * Licensed
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/273#discussion_r170102338
--- Diff: extras/rya.manual/src/site/markdown/rya-streams.md ---
@@ -0,0 +1,385 @@
+
+
+# Rya Streams
+
+Introduced in 3.2.12
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/273#discussion_r170079504
--- Diff: extras/rya.manual/src/site/markdown/rya-streams.md ---
@@ -0,0 +1,385 @@
+
+
+# Rya Streams
+
+Introduced in 3.2.12
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/273#discussion_r170104093
--- Diff: extras/rya.manual/src/site/markdown/rya-streams.md ---
@@ -0,0 +1,385 @@
+
+
+# Rya Streams
+
+Introduced in 3.2.12
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/273#discussion_r170100877
--- Diff: extras/rya.manual/src/site/markdown/rya-streams.md ---
@@ -0,0 +1,385 @@
+
+
+# Rya Streams
+
+Introduced in 3.2.12
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/273#discussion_r170100421
--- Diff: extras/rya.manual/src/site/markdown/rya-streams.md ---
@@ -0,0 +1,385 @@
+
+
+# Rya Streams
+
+Introduced in 3.2.12
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/273#discussion_r170100767
--- Diff: extras/rya.manual/src/site/markdown/rya-streams.md ---
@@ -0,0 +1,385 @@
+
+
+# Rya Streams
+
+Introduced in 3.2.12
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/273#discussion_r170099096
--- Diff: extras/rya.manual/src/site/markdown/rya-streams.md ---
@@ -0,0 +1,385 @@
+
+
+# Rya Streams
+
+Introduced in 3.2.12
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/273#discussion_r170077160
--- Diff: extras/rya.manual/src/site/markdown/rya-streams.md ---
@@ -0,0 +1,385 @@
+
+
+# Rya Streams
+
+Introduced in 3.2.12
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/273#discussion_r170099050
--- Diff: extras/rya.manual/src/site/markdown/rya-streams.md ---
@@ -0,0 +1,385 @@
+
+
+# Rya Streams
+
+Introduced in 3.2.12
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/273#discussion_r170080373
--- Diff: extras/rya.manual/src/site/markdown/rya-streams.md ---
@@ -0,0 +1,385 @@
+
+
+# Rya Streams
+
+Introduced in 3.2.12
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/273#discussion_r170082068
--- Diff: extras/rya.manual/src/site/markdown/rya-streams.md ---
@@ -0,0 +1,385 @@
+
+
+# Rya Streams
+
+Introduced in 3.2.12
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/273#discussion_r170096470
--- Diff: extras/rya.manual/src/site/markdown/rya-streams.md ---
@@ -0,0 +1,385 @@
+
+
+# Rya Streams
+
+Introduced in 3.2.12
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/273#discussion_r170098679
--- Diff: extras/rya.manual/src/site/markdown/rya-streams.md ---
@@ -0,0 +1,385 @@
+
+
+# Rya Streams
+
+Introduced in 3.2.12
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/273#discussion_r170078481
--- Diff: extras/rya.manual/src/site/markdown/rya-streams.md ---
@@ -0,0 +1,385 @@
+
+
+# Rya Streams
+
+Introduced in 3.2.12
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/273#discussion_r170102871
--- Diff: extras/rya.manual/src/site/markdown/rya-streams.md ---
@@ -0,0 +1,385 @@
+
+
+# Rya Streams
+
+Introduced in 3.2.12
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/273#discussion_r170097432
--- Diff: extras/rya.manual/src/site/markdown/rya-streams.md ---
@@ -0,0 +1,385 @@
+
+
+# Rya Streams
+
+Introduced in 3.2.12
Github user ejwhite922 commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/272#discussion_r170073123
--- 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_r170069054
--- Diff: extras/rya.streams/query-manager/pom.xml ---
@@ -0,0 +1,253 @@
+
+
+http://maven.apache.org/POM/4.0.0;
xmlns:xsi="
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
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
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
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
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 equals
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
1 - 100 of 276 matches
Mail list logo
