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

Class RepartitionedInternal<K,V>

java.lang.Object

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

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

public class RepartitionedInternal<K,V>
extends Repartitioned<K,V>

Field Summary

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

keySerde, name, numberOfPartitions, partitioner, valueSerde

Constructor Summary

Constructors

Constructor	Description
RepartitionedInternal(Repartitioned<K,V> repartitioned)

Method Summary

Modifier and Type	Method	Description
Serde<K>	keySerde()
String	name()
Integer	numberOfPartitions()
StreamPartitioner<K,V>	streamPartitioner()
Serde<V>	valueSerde()

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

as, numberOfPartitions, streamPartitioner, with, withKeySerde, withName, withNumberOfPartitions, withStreamPartitioner, withValueSerde

Methods inherited from class java.lang.Object

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

Constructor Detail

RepartitionedInternal

public RepartitionedInternal(Repartitioned<K,V> repartitioned)

Method Detail

name

public String name()

keySerde

public Serde<K> keySerde()

valueSerde

public Serde<V> valueSerde()

streamPartitioner

public StreamPartitioner<K,V> streamPartitioner()

numberOfPartitions

public Integer numberOfPartitions()