Package org.apache.kafka.streams.kstream.internals

Class GlobalKTableImpl<K,V>

java.lang.Object

org.apache.kafka.streams.kstream.internals.GlobalKTableImpl<K,V>

All Implemented Interfaces:

GlobalKTable<K,V>

public class GlobalKTableImpl<K,V>
extends Object
implements GlobalKTable<K,V>

Method Summary

Modifier and Type	Method	Description
String	queryableStoreName()	Get the name of the local state store that can be used to query this GlobalKTable.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

queryableStoreName

public String queryableStoreName()

Description copied from interface: GlobalKTable

Get the name of the local state store that can be used to query this GlobalKTable.

Specified by:

queryableStoreName in interface GlobalKTable<K,V>

Returns:

the underlying state store name, or null if this GlobalKTable cannot be queried.