At this point, if you have not done so yet, you should start the following processes on your machine. Please refer to the previous sections if you are not sure how to start them:
- Zookeeper
- Kafka broker
- The
StreamingProducerAppconsuming live BTC/USD transactions and pushing them to a Kafka topic namedtransactions. - Apache Zeppelin
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().schemaExecute 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...