rya-377 Fixing broken build.
Project: http://git-wip-us.apache.org/repos/asf/incubator-rya/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rya/commit/1535b462 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rya/tree/1535b462 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rya/diff/1535b462 Branch: refs/heads/master Commit: 1535b4620c821aa171f2b5f26646c400344c5363 Parents: 9cd0c56 Author: kchilton2 <kevin.e.chil...@gmail.com> Authored: Thu Nov 30 16:37:36 2017 -0500 Committer: caleb <caleb.me...@parsons.com> Committed: Tue Jan 9 15:13:01 2018 -0500 ---------------------------------------------------------------------- .../apache/rya/streams/kafka/processors/filter/GeoFilterIT.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/1535b462/extras/rya.streams/kafka/src/test/java/org/apache/rya/streams/kafka/processors/filter/GeoFilterIT.java ---------------------------------------------------------------------- diff --git a/extras/rya.streams/kafka/src/test/java/org/apache/rya/streams/kafka/processors/filter/GeoFilterIT.java b/extras/rya.streams/kafka/src/test/java/org/apache/rya/streams/kafka/processors/filter/GeoFilterIT.java index 4057e18..b9d81ef 100644 --- a/extras/rya.streams/kafka/src/test/java/org/apache/rya/streams/kafka/processors/filter/GeoFilterIT.java +++ b/extras/rya.streams/kafka/src/test/java/org/apache/rya/streams/kafka/processors/filter/GeoFilterIT.java @@ -32,8 +32,8 @@ import org.apache.rya.api.function.projection.RandomUUIDFactory; import org.apache.rya.api.model.VisibilityBindingSet; import org.apache.rya.api.model.VisibilityStatement; import org.apache.rya.indexing.GeoConstants; -import org.apache.rya.streams.kafka.KafkaTestUtil; import org.apache.rya.streams.kafka.KafkaTopics; +import org.apache.rya.streams.kafka.RyaStreamsTestUtil; import org.apache.rya.streams.kafka.processors.filter.FilterProcessorSupplier.FilterProcessor; import org.apache.rya.streams.kafka.serialization.VisibilityBindingSetDeserializer; import org.apache.rya.streams.kafka.topology.TopologyFactory; @@ -117,7 +117,7 @@ public class GeoFilterIT { expected.add( new VisibilityBindingSet(bs, "a") ); // Run the test. - KafkaTestUtil.runStreamProcessingTest(kafka, statementsTopic, resultsTopic, builder, 2000, statements, expected, VisibilityBindingSetDeserializer.class); + RyaStreamsTestUtil.runStreamProcessingTest(kafka, statementsTopic, resultsTopic, builder, 2000, statements, expected, VisibilityBindingSetDeserializer.class); } private List<VisibilityStatement> getStatements() throws Exception {