KTableRepartitionMap (kafka 2.6.1.100-eep-810 API)

java.lang.Object
- org.apache.kafka.streams.kstream.internals.KTableRepartitionMap<K,V,K1,V1>

All Implemented Interfaces:

KTableProcessorSupplier<K,V,KeyValue<K1,V1>>, ConnectedStoreProvider, ProcessorSupplier<K,Change<V>>
```
public class KTableRepartitionMap<K,V,K1,V1>
extends Object
implements KTableProcessorSupplier<K,V,KeyValue<K1,V1>>
```
KTable repartition map functions are not exposed to public APIs, but only used for keyed aggregations.
Given the input, it can output at most two records (one mapped from old value and one mapped from new value).

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`enableSendingOldValues()`
`Processor<K,Change<V>>`	`get()`	Return a new `Processor` instance.
`KTableValueGetterSupplier<K,KeyValue<K1,V1>>`	`view()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.kafka.streams.processor.ConnectedStoreProvider
stores

- Method Detail
  - get
```
public Processor<K,Change<V>> get()
```
    Description copied from interface: ProcessorSupplier
    
    Return a new Processor instance.
    
    Specified by:
    
    get in interface ProcessorSupplier<K,V>
    
    Returns:
    
    a new Processor instance
  - view
```
public KTableValueGetterSupplier<K,KeyValue<K1,V1>> view()
```
    Specified by:
    
    view in interface KTableProcessorSupplier<K,V,K1>
  - enableSendingOldValues
```
public void enableSendingOldValues()
```
    Specified by:
    
    enableSendingOldValues in interface KTableProcessorSupplier<K,V,K1>
    
    Throws:
    
    IllegalStateException - since this method should never be called