Packages

package kafka

Type Members

  1. case class EncodedKV(key: Array[Byte], value: Array[Byte]) extends Product with Serializable
  2. class SparkStreamletContextImpl extends SparkStreamletContext

Ungrouped