kafka-streams-internals-AbstractStream.adoc

AbstractStream

AbstractStream is the base abstraction of the streams.

Table 1. AbstractStreams

AbstractStream	Description
KGroupedStreamImpl
KGroupedTableImpl
KStreamImpl
KTableImpl
SessionWindowedKStreamImpl
TimeWindowedKStreamImpl

Every AbstractStream has the following properties:

• Name

• Key Serde (Serde<K>)

• Value Serde (Serde<V>)

• Names of the source nodes (Set<String>)

• StreamsGraphNode

• InternalStreamsBuilder

ensureJoinableWith Method

Set<String> ensureJoinableWith(
  AbstractStream<K, ?> other)

ensureJoinableWith…​FIXME

Note	ensureJoinableWith is used when: KStreamImpl is requested to join, outerJoin and leftJoin KTableImpl is requested to join, leftJoin and outerJoin

toValueTransformerWithKeySupplier Static Method

ValueTransformerWithKeySupplier<K, V, VR> toValueTransformerWithKeySupplier(
  ValueTransformerSupplier<V, VR> valueTransformerSupplier)

toValueTransformerWithKeySupplier…​FIXME

Note	toValueTransformerWithKeySupplier is used when KStreamImpl is requested to transformValues and flatTransformValues.

reverseJoiner Static Method

ValueJoiner<T2, T1, R> reverseJoiner(
  ValueJoiner<T1, T2, R> joiner)

reverseJoiner…​FIXME

Note	reverseJoiner is used when: KStreamImplJoin is requested to join (for KStreamImpl.join, KStreamImpl.outerJoin and KStreamImpl.leftJoin operators) KTableImpl is requested to doJoin (for KTableImpl.join, KTableImpl.leftJoin and KTableImpl.outerJoin operators)

withKey Static Method

ValueMapperWithKey<K, V, VR> withKey(
  ValueMapper<V, VR> valueMapper)

withKey…​FIXME

Note	withKey is used when: KStreamImpl is requested to mapValues and flatMapValues KTableImpl is requested to mapValues