package streams

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. trait Deserializer[T >: Null] extends org.apache.kafka.common.serialization.Deserializer[T]
  2. class KGroupedStreamS[K, V] extends AnyRef

    Wraps the Java class KGroupedStream and delegates method calls to the underlying Java object.

  3. class KGroupedTableS[K, V] extends AnyRef

    Wraps the Java class KGroupedTable and delegates method calls to the underlying Java object.

  4. class KStreamS[K, V] extends AnyRef

    Wraps the Java class KStream and delegates method calls to the underlying Java object.

  5. class KTableS[K, V] extends AnyRef

    Wraps the Java class KTable and delegates method calls to the underlying Java object.

  6. trait ScalaSerde[T] extends Serde[T]
  7. trait Serializer[T] extends org.apache.kafka.common.serialization.Serializer[T]
  8. class SessionWindowedKStreamS[K, V] extends AnyRef

    Wraps the Java class SessionWindowedKStream and delegates method calls to the underlying Java object.

  9. trait StatelessScalaSerde[T >: Null] extends Serde[T] with ScalaSerde[T]
  10. class StreamsBuilderS extends AnyRef

    Wraps the Java class StreamsBuilder and delegates method calls to the underlying Java object.

  11. class TimeWindowedKStreamS[K, V] extends AnyRef

    Wraps the Java class TimeWindowedKStream and delegates method calls to the underlying Java object.

Value Members

  1. object DefaultSerdes

    Implicit values for default serdes

  2. object FunctionConversions

    Implicit classes that offer conversions of Scala function literals to SAM (Single Abstract Method) objects in Java.

    Implicit classes that offer conversions of Scala function literals to SAM (Single Abstract Method) objects in Java. These make the Scala APIs much more expressive, with less boilerplate and more succinct.

  3. object ImplicitConversions

    Implicit conversions between the Scala wrapper objects and the underlying Java objects.

Ungrouped