AbstractStream<K,V> |
|
Change<T> |
|
ChangedDeserializer<T> |
|
ChangedSerializer<T> |
|
ConsumedInternal<K,V> |
|
FullChangeSerde<T> |
|
GlobalKTableImpl<K,V> |
|
GroupedInternal<K,V> |
|
InternalStreamsBuilder |
|
KeyValueStoreMaterializer<K,V> |
|
KGroupedTableImpl<K,V> |
|
KStreamAggregate<K,V,T> |
|
KStreamImpl<K,V> |
|
KStreamPrint<K,V> |
|
KStreamReduce<K,V> |
|
KStreamSessionWindowAggregate<K,V,Agg> |
|
KStreamTransform<K,V,K1,V1> |
|
KStreamTransform.KStreamTransformProcessor<K1,V1,K2,V2> |
|
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> |
|
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> |
|
PrintedInternal<K,V> |
|
PrintForeachAction<K,V> |
|
ProducedInternal<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.
|
SessionWindowedKStreamImpl<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.
|
TimeWindowedKStreamImpl<K,V,W extends Window> |
|
UnlimitedWindow |
UnlimitedWindow is an "infinite" large window with a fixed (inclusive) start time.
|
WindowedStreamPartitioner<K,V> |
|
WindowingDefaults |
|