Versions Compared

Old Version 9

changes.mady.by.user Aishwarya Pradeep Kumar

Saved on

compared with

New Version 10

changes.mady.by.user high.lee

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Two functions will need to be added to the KStream interface:

Code Block
languagejava
<VR>//java
<V> KTable<K,VR>V> toTable()
<VR><V> KTable<K,VR>V> toTable(Named)
<VR><V> KTable<K,VR>V> toTable(final Materialized<K, VR, KeyValueStore<Bytes, byte[]>> materialized)
<VR><V> KTable<K,VR>V> toTable(Named, final Materialized<K, VR, KeyValueStore<Bytes, byte[]>> materialized)

//scala  
def toTable: KTable[K, V]
def toTable(materialized: Materialized[K, V, ByteArrayKeyValueStore]): KTable[K, V]

Proposed Changes

Adding two new functions to the Kstreams DSL.

...