KTableSource (kafka 2.6.1.100-eep-810 API)

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

All Implemented Interfaces:: ConnectedStoreProvider, ProcessorSupplier<K,V>

public class KTableSource<K,V>
extends Object
implements ProcessorSupplier<K,V>

Constructor Summary

Constructors
Constructor Description

KTableSource(String storeName, String queryableName)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`enableSendingOldValues()`
`Processor<K,V>`	`get()`	Return a new `Processor` instance.
`void`	`materialize()`
`boolean`	`materialized()`
`String`	`queryableName()`

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

Constructor Detail

KTableSource

public KTableSource(String storeName,
                    String queryableName)

Method Detail
- queryableName
```
public String queryableName()
```
- get
```
public Processor<K,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
- enableSendingOldValues
```
public void enableSendingOldValues()
```
- materialize
```
public void materialize()
```
- materialized
```
public boolean materialized()
```