Package org.apache.kafka.streams.kstream.internals

Class GroupedInternal<K,V>

java.lang.Object

org.apache.kafka.streams.kstream.Grouped<K,V>

org.apache.kafka.streams.kstream.internals.GroupedInternal<K,V>

public class GroupedInternal<K,V>
extends Grouped<K,V>

Field Summary

Fields inherited from class org.apache.kafka.streams.kstream.Grouped

keySerde, name, valueSerde

Constructor Summary

Constructors

Constructor	Description
GroupedInternal(Grouped<K,V> grouped)

Method Summary

Modifier and Type	Method	Description
Serde<K>	keySerde()
String	name()
Serde<V>	valueSerde()

Methods inherited from class org.apache.kafka.streams.kstream.Grouped

as, keySerde, valueSerde, with, with, withKeySerde, withName, withValueSerde

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GroupedInternal

public GroupedInternal(Grouped<K,V> grouped)

Method Detail

keySerde

public Serde<K> keySerde()

valueSerde

public Serde<V> valueSerde()

name

public String name()