RYA-377 Added missing license headers to test data.
Project: http://git-wip-us.apache.org/repos/asf/incubator-rya/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rya/commit/a95fe5ad Tree: http://git-wip-us.apache.org/repos/asf/incubator-rya/tree/a95fe5ad Diff: http://git-wip-us.apache.org/repos/asf/incubator-rya/diff/a95fe5ad Branch: refs/heads/master Commit: a95fe5add788ccce805fb2fd4b7b09a3893779dc Parents: 8399dfe Author: kchilton2 <[email protected]> Authored: Thu Oct 26 13:57:08 2017 -0400 Committer: caleb <[email protected]> Committed: Tue Jan 9 15:12:59 2018 -0500 ---------------------------------------------------------------------- .../kafka/interactor/KafkaLoadStatementsIT.java | 3 +-- .../kafka/src/test/resources/invalid.INVALID | 17 +++++++++++++++++ .../kafka/src/test/resources/statements.ttl | 16 ++++++++++++++++ 3 files changed, 34 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/a95fe5ad/extras/rya.streams/kafka/src/test/java/org/apache/rya/streams/kafka/interactor/KafkaLoadStatementsIT.java ---------------------------------------------------------------------- diff --git a/extras/rya.streams/kafka/src/test/java/org/apache/rya/streams/kafka/interactor/KafkaLoadStatementsIT.java b/extras/rya.streams/kafka/src/test/java/org/apache/rya/streams/kafka/interactor/KafkaLoadStatementsIT.java index 8103e57..5a81d23 100644 --- a/extras/rya.streams/kafka/src/test/java/org/apache/rya/streams/kafka/interactor/KafkaLoadStatementsIT.java +++ b/extras/rya.streams/kafka/src/test/java/org/apache/rya/streams/kafka/interactor/KafkaLoadStatementsIT.java @@ -39,7 +39,6 @@ import org.apache.kafka.clients.producer.ProducerConfig; import org.apache.kafka.common.serialization.StringDeserializer; import org.apache.kafka.common.serialization.StringSerializer; import org.apache.rya.api.model.VisibilityStatement; -import org.apache.rya.streams.kafka.interactor.KafkaLoadStatements; import org.apache.rya.streams.kafka.serialization.VisibilityStatementDeserializer; import org.apache.rya.streams.kafka.serialization.VisibilityStatementSerializer; import org.apache.rya.test.kafka.KafkaITBase; @@ -97,7 +96,7 @@ public class KafkaLoadStatementsIT extends KafkaITBase { try (final KafkaConsumer<String, VisibilityStatement> consumer = new KafkaConsumer<>(consumerProps)) { consumer.subscribe(Arrays.asList(rule.getKafkaTopicName())); - final ConsumerRecords<String, VisibilityStatement> records = consumer.poll(1000); + final ConsumerRecords<String, VisibilityStatement> records = consumer.poll(2000); assertEquals(3, records.count()); final Iterator<ConsumerRecord<String, VisibilityStatement>> iter = records.iterator(); http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/a95fe5ad/extras/rya.streams/kafka/src/test/resources/invalid.INVALID ---------------------------------------------------------------------- diff --git a/extras/rya.streams/kafka/src/test/resources/invalid.INVALID b/extras/rya.streams/kafka/src/test/resources/invalid.INVALID index f71c8c6..52d18b4 100644 --- a/extras/rya.streams/kafka/src/test/resources/invalid.INVALID +++ b/extras/rya.streams/kafka/src/test/resources/invalid.INVALID @@ -1 +1,18 @@ +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license agreements. See the NOTICE file +# distributed with this work for additional information +# regarding copyright ownership. The ASF licenses this file +# to you under the Apache License, Version 2.0 (the +# "License"); you may not use this file except in compliance +# with the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, +# software distributed under the License is distributed on an +# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY +# KIND, either express or implied. See the License for the +# specific language governing permissions and limitations +# under the License. + this file should not be parsed due to invalid extension \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/a95fe5ad/extras/rya.streams/kafka/src/test/resources/statements.ttl ---------------------------------------------------------------------- diff --git a/extras/rya.streams/kafka/src/test/resources/statements.ttl b/extras/rya.streams/kafka/src/test/resources/statements.ttl index 3456cc2..c19e22d 100644 --- a/extras/rya.streams/kafka/src/test/resources/statements.ttl +++ b/extras/rya.streams/kafka/src/test/resources/statements.ttl @@ -1,3 +1,19 @@ +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license agreements. See the NOTICE file +# distributed with this work for additional information +# regarding copyright ownership. The ASF licenses this file +# to you under the Apache License, Version 2.0 (the +# "License"); you may not use this file except in compliance +# with the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, +# software distributed under the License is distributed on an +# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY +# KIND, either express or implied. See the License for the +# specific language governing permissions and limitations +# under the License. @prefix example: <http://example#> . example:alice example:talksTo example:bob .
