Scala Programming Projects

Reading transactions from Kafka

Using your browser, create a new Zeppelin Notebook named Streaming, and  then type the following code in the first cell:

case class Transaction(timestamp: java.sql.Timestamp,                       date: String,                       tid: Int,                       price: Double,                       sell: Boolean,                       amount: Double)val schema = Seq.empty[Transaction].toDS().schema

Execute the cell to define the Transaction class and the variable schema. We have to redefine the Transaction case class in Zeppelin because Zeppelin does not have access to the classes of our IntelliJ project, bitcoin-analyser. We could have instead packaged a .jar file and added it into Zeppelin's dependency settings, but as this is the only class we need, we found it easier to redefine it. The schema variable is of ...