Try adding the spark-streaming_2.11 artifact as a dependency too. You will be directly depending on it.
On Tue, Oct 18, 2016 at 2:16 PM Furkan KAMACI <furkankam...@gmail.com> wrote: > Hi, > > I have a search application and want to monitor queries per second for it. > I have Kafka at my backend which acts like a bus for messages. Whenever a > search request is done I publish the nano time of the current system. I > want to use Spark Streaming to aggregate such data but I am so new to it. > > I wanted to follow that example: > http://spark.apache.org/docs/latest/streaming-kafka-0-10-integration.html > > I've added that dependencies: > > <dependency> > <groupId>org.apache.spark</groupId> > <artifactId>spark-streaming-kafka-0-10_2.11</artifactId> > <version>2.0.1</version> > </dependency> > <dependency> > <groupId>org.apache.spark</groupId> > <artifactId>spark-core_2.10</artifactId> > <version>2.0.1</version> > </dependency> > > However I cannot see even Duration class at my dependencies. On the other > hand given documentation is missing and when you click Java there is no > code at tabs. > > Could you guide me how can I implement monitoring such a metric? > > Kind Regards, > Furkan KAMACI >
