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

Interface Summary

Interface	Description
InternalNameProvider
KStreamAggProcessorSupplier<K,RK,V,T>
KTableProcessorSupplier<K,V,T>
KTableValueGetter<K,V>
KTableValueGetterSupplier<K,V>
WindowedSerializer<T>
WrappingNullableDeserializer<Outer,InnerK,InnerV>
WrappingNullableSerializer<Outer,InnerK,InnerV>

Class Summary

Class	Description
AbstractStream<K,V>
Change<T>
ChangedDeserializer<T>
ChangedSerializer<T>
CogroupedKStreamImpl<K,VOut>
ConsumedInternal<K,V>
FullChangeSerde<T>
GlobalKTableImpl<K,V>
GroupedInternal<K,V>
InternalStreamsBuilder
JoinedInternal<K,V,VO>
KGroupedTableImpl<K,V>	The implementation class of KGroupedTable.
KStreamAggregate<K,V,T>
KStreamFlatTransform<KIn,VIn,KOut,VOut>
KStreamFlatTransform.KStreamFlatTransformProcessor<KIn,VIn,KOut,VOut>
KStreamFlatTransformValues<KIn,VIn,VOut>
KStreamFlatTransformValues.KStreamFlatTransformValuesProcessor<KIn,VIn,VOut>
KStreamImpl<K,V>
KStreamPrint<K,V>
KStreamReduce<K,V>
KStreamSessionWindowAggregate<K,V,Agg>
KStreamTransformValues<K,V,R>
KStreamTransformValues.KStreamTransformValuesProcessor<K,V,R>
KStreamWindowAggregate<K,V,Agg,W extends Window>
KTableAggregate<K,V,T>
KTableImpl<K,S,V>	The implementation class of KTable.
KTableKTableAbstractJoinValueGetterSupplier<K,R,V1,V2>
KTableKTableJoinMerger<K,V>
KTableMaterializedValueGetterSupplier<K,V>
KTableReduce<K,V>
KTableRepartitionMap<K,V,K1,V1>	KTable repartition map functions are not exposed to public APIs, but only used for keyed aggregations.
KTableSource<K,V>
KTableSourceValueGetterSupplier<K,V>
MaterializedInternal<K,V,S extends StateStore>
NamedInternal
PrintedInternal<K,V>
PrintForeachAction<K,V>
ProducedInternal<K,V>
RepartitionedInternal<K,V>
SerializedInternal<K,V>	Deprecated.
SessionWindow	A session window covers a closed time interval with its start and end timestamp both being an inclusive boundary.
SessionWindowedCogroupedKStreamImpl<K,V>
SessionWindowedKStreamImpl<K,V>
StreamJoinedInternal<K,V1,V2>
TimestampedKeyValueStoreMaterializer<K,V>
TimeWindow	A TimeWindow covers a half-open time interval with its start timestamp as an inclusive boundary and its end timestamp as exclusive boundary.
TimeWindowedCogroupedKStreamImpl<K,V,W extends Window>
TimeWindowedKStreamImpl<K,V,W extends Window>
TransformerSupplierAdapter<KIn,VIn,KOut,VOut>
UnlimitedWindow	UnlimitedWindow is an "infinite" large window with a fixed (inclusive) start time.
WindowedStreamPartitioner<K,V>
WindowingDefaults
WrappingNullableSerde<T,InnerK,InnerV>
WrappingNullableUtils	If a component's serdes are Wrapping serdes, then they require a little extra setup to be fully initialized at run time.