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:

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

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

toValueTransformerWithKeySupplier…FIXME

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

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)

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

results matching ""