Seq
scala
SparkRepl
embedded
SparkTemplate
embedded
SparkTestDuration
embedded
Status
Event
Stream
scala
StringBuilder
scala
StringIndexOutOfBoundsException
scala
sc
SparkTemplate
scala
root
send
KafkaProducer
serializable
scala
server
EmbeddedKafka EmbeddedZookeeper
shutdown
EmbeddedKafka EmbeddedZookeeper KafkaConsumer
snapshotDir
EmbeddedZookeeper
spark
datastax
streams
KafkaConsumer