package kafka
Type Members
-
case class
EncodedKV(key: Array[Byte], value: Array[Byte]) extends Product with Serializable
- Annotations
- @deprecated
- Deprecated
(Since version 2.2.0) Use contrib-sbt-spark library instead, see https://github.com/lightbend/cloudflow-contrib
-
class
SparkStreamletContextImpl extends SparkStreamletContext
- Annotations
- @deprecated
- Deprecated
(Since version 2.2.0) Use contrib-sbt-spark library instead, see https://github.com/lightbend/cloudflow-contrib