KTableImpl

KTableImpl is…​FIXME

mapValues Method

KTable<K, VR> mapValues(
  final ValueMapper<? super V, ? extends VR> mapper)
KTable<K, VR> mapValues(
  final ValueMapper<? super V, ? extends VR> mapper,
  final Materialized<K, VR, KeyValueStore<Bytes, byte[]>> materialized)
KTable<K, VR> mapValues(
  final ValueMapperWithKey<? super K, ? super V, ? extends VR> mapper)
KTable<K, VR> mapValues(
  final ValueMapperWithKey<? super K, ? super V, ? extends VR> mapper,
  final Materialized<K, VR, KeyValueStore<Bytes, byte[]>> materialized)
Note
 mapValues is part of KTable Contract to…​FIXME.

mapValues…​FIXME

Note
 mapValues is used when…​FIXME

join Method

<V1, R> KTable<K, R> join(
  final KTable<K, V1> other,
  final ValueJoiner<? super V, ? super V1, ? extends R> joiner)
<VO, VR> KTable<K, VR> join(
  final KTable<K, VO> other,
  final ValueJoiner<? super V, ? super VO, ? extends VR> joiner,
  final Materialized<K, VR, KeyValueStore<Bytes, byte[]>> materialized)
Note
 join is part of KTable Contract to…​FIXME.

join…​FIXME

Note
 join is used when…​FIXME

leftJoin Method

<V1, R> KTable<K, R> leftJoin(
  final KTable<K, V1> other,
  final ValueJoiner<? super V, ? super V1, ? extends R> joiner)
<VO, VR> KTable<K, VR> leftJoin(
  final KTable<K, VO> other,
  final ValueJoiner<? super V, ? super VO, ? extends VR> joiner,
  final Materialized<K, VR, KeyValueStore<Bytes, byte[]>> materialized)
Note
 leftJoin is part of KTable Contract to…​FIXME.

leftJoin…​FIXME

Note
 leftJoin is used when…​FIXME

outerJoin Method

<V1, R> KTable<K, R> outerJoin(
  final KTable<K, V1> other,
  final ValueJoiner<? super V, ? super V1, ? extends R> joiner)
<VO, VR> KTable<K, VR> outerJoin(
  final KTable<K, VO> other,
  final ValueJoiner<? super V, ? super VO, ? extends VR> joiner,
  final Materialized<K, VR, KeyValueStore<Bytes, byte[]>> materialized)
Note
 outerJoin is part of KTable Contract to…​FIXME.

outerJoin…​FIXME

Note
 outerJoin is used when…​FIXME

doFilter Internal Method

KTable<K, V> doFilter(
  Predicate<? super K, ? super V> predicate,
  MaterializedInternal<K, V, KeyValueStore<Bytes, byte[]>> materialized,
  boolean filterNot)

doFilter…​FIXME

Note
 doFilter is used when KTableImpl is requested to filter and filterNot.

doMapValues Internal Method

KTable<K, VR> doMapValues(
  ValueMapperWithKey<
    ? super K,
    ? super V,
    ? extends VR> mapper,
  MaterializedInternal<K, VR, KeyValueStore<Bytes, byte[]>> materializedInternal)

doMapValues…​FIXME

Note
 doMapValues is used exclusively when KTableImpl is requested to mapValues.

doTransformValues Internal Method

KTable<K, VR> doTransformValues(
  ValueTransformerWithKeySupplier<
    ? super K,
    ? super V,
    ? extends VR> transformerSupplier,
  MaterializedInternal<K, VR, KeyValueStore<Bytes, byte[]>> materialized,
  String... stateStoreNames)

doTransformValues…​FIXME

Note
 doTransformValues is used exclusively when KTableImpl is requested to transformValues.

buildJoin Internal Method

<V1, R> KTable<K, R> buildJoin(
  final AbstractStream<K> other,
  final ValueJoiner<? super V, ? super V1, ? extends R> joiner,
  final boolean leftOuter,
  final boolean rightOuter,
  final String joinMergeName,
  final String internalQueryableName)

buildJoin ensureJoinableWith the other stream.

buildJoin…​FIXME

Note
 buildJoin is used exclusively when KTableImpl is requested to doJoin.

doJoin Internal Method

KTable<K, VR> doJoin(
  KTable<K, VO> other,
  ValueJoiner<? super V, ? super VO, ? extends VR> joiner,
  MaterializedInternal<K, VR, KeyValueStore<Bytes, byte[]>> materializedInternal,
  boolean leftOuter,
  boolean rightOuter)

doJoin…​FIXME

Note
 doJoin is used when KTableImpl is requested to join, leftJoin and outerJoin.

valueGetterSupplier Method

KTableValueGetterSupplier<K, V> valueGetterSupplier()

valueGetterSupplier…​FIXME

Note
 valueGetterSupplier is used when…​FIXME

enableSendingOldValues Method

void enableSendingOldValues()

enableSendingOldValues…​FIXME

Note
 enableSendingOldValues is used when…​FIXME

filter Method

KTable<K, V> filter(
  final Predicate<? super K, ? super V> predicate)
KTable<K, V> filter(
  final Predicate<? super K, ? super V> predicate,
  final Materialized<K, V, KeyValueStore<Bytes, byte[]>> materialized)
Note
 filter is part of the KTable Contract to…​FIXME.

filter…​FIXME

filterNot Method

KTable<K, V> filterNot(
  final Predicate<? super K, ? super V> predicate)
KTable<K, V> filterNot(
  final Predicate<? super K, ? super V> predicate,
  final Materialized<K, V, KeyValueStore<Bytes, byte[]>> materialized)
Note
 filterNot is part of the KTable Contract to…​FIXME.

filterNot…​FIXME

transformValues Method

KTable<K, VR> transformValues(
  final ValueTransformerWithKeySupplier<? super K, ? super V, ? extends VR> transformerSupplier,
  final Materialized<K, VR, KeyValueStore<Bytes, byte[]>> materialized,
  final String... stateStoreNames)
KTable<K, VR> transformValues(
  final ValueTransformerWithKeySupplier<? super K, ? super V, ? extends VR> transformerSupplier,
  final String... stateStoreNames)
Note
 transformValues is part of the KTable Contract to…​FIXME.

transformValues…​FIXME

suppress Method

KTable<K, V> suppress(
  Suppressed<? super K> suppressed)
Note
 suppress is part of the KTable Contract to…​FIXME.

suppress…​FIXME

results matching ""

    No results matching ""