Packages

package kstream

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. kstream
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. class CogroupedKStream[KIn, VOut] extends AnyRef

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

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

    KIn

    Type of keys

    VOut

    Type of values

    See also

    org.apache.kafka.streams.kstream.CogroupedKStream

  2. type Consumed[K, V] = kstream.Consumed[K, V]
  3. type Grouped[K, V] = kstream.Grouped[K, V]
  4. type Joined[K, V, VO] = kstream.Joined[K, V, VO]
  5. class KGroupedStream[K, V] extends AnyRef

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

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

    K

    Type of keys

    V

    Type of values

    See also

    org.apache.kafka.streams.kstream.KGroupedStream

  6. class KGroupedTable[K, V] extends AnyRef

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

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

    K

    Type of keys

    V

    Type of values

    See also

    org.apache.kafka.streams.kstream.KGroupedTable

  7. class KStream[K, V] extends AnyRef

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

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

    K

    Type of keys

    V

    Type of values

    See also

    org.apache.kafka.streams.kstream.KStream

  8. class KTable[K, V] extends AnyRef

    Wraps the Java class org.apache.kafka.streams.kstream.KTable and delegates method calls to the underlying Java object.

    Wraps the Java class org.apache.kafka.streams.kstream.KTable and delegates method calls to the underlying Java object.

    K

    Type of keys

    V

    Type of values

    See also

    org.apache.kafka.streams.kstream.KTable

  9. type Materialized[K, V, S <: StateStore] = kstream.Materialized[K, V, S]
  10. type Produced[K, V] = kstream.Produced[K, V]
  11. type Repartitioned[K, V] = kstream.Repartitioned[K, V]
  12. class SessionWindowedCogroupedKStream[K, V] extends AnyRef

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

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

    K

    Type of keys

    V

    Type of values

    See also

    org.apache.kafka.streams.kstream.SessionWindowedCogroupedKStream

  13. class SessionWindowedKStream[K, V] extends AnyRef

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

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

    K

    Type of keys

    V

    Type of values

    See also

    org.apache.kafka.streams.kstream.SessionWindowedKStream

  14. type StreamJoined[K, V, VO] = kstream.StreamJoined[K, V, VO]
  15. class TimeWindowedCogroupedKStream[K, V] extends AnyRef

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

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

    K

    Type of keys

    V

    Type of values

    See also

    org.apache.kafka.streams.kstream.TimeWindowedCogroupedKStream

  16. class TimeWindowedKStream[K, V] extends AnyRef

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

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

    K

    Type of keys

    V

    Type of values

    See also

    org.apache.kafka.streams.kstream.TimeWindowedKStream

Value Members

  1. object Consumed
  2. object Grouped
  3. object Joined
  4. object Materialized
  5. object Produced
  6. object Repartitioned
  7. object StreamJoined

Deprecated Value Members

  1. object Suppressed

    Duplicates the static factory methods inside the Java interface org.apache.kafka.streams.kstream.Suppressed.

    Duplicates the static factory methods inside the Java interface org.apache.kafka.streams.kstream.Suppressed.

    This was required for compatibility w/ Scala 2.11 + Java 1.8 because the Scala 2.11 compiler doesn't support the use of static methods inside Java interfaces. We have since dropped Scala 2.11 support.

    Annotations
    @deprecated
    Deprecated

    (Since version 2.5) Use org.apache.kafka.streams.kstream.Suppressed

Inherited from AnyRef

Inherited from Any

Ungrouped