public class GlobalKTableImpl<K,V> extends java.lang.Object implements GlobalKTable<K,V>
Constructor and Description |
---|
GlobalKTableImpl(KTableValueGetterSupplier<K,V> valueGetterSupplier) |
GlobalKTableImpl(KTableValueGetterSupplier<K,V> valueGetterSupplier,
boolean queryable) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
queryableStoreName()
Get the name of the local state store that can be used to query this
GlobalKTable . |
public GlobalKTableImpl(KTableValueGetterSupplier<K,V> valueGetterSupplier)
public GlobalKTableImpl(KTableValueGetterSupplier<K,V> valueGetterSupplier, boolean queryable)
public java.lang.String queryableStoreName()
GlobalKTable
GlobalKTable
.queryableStoreName
in interface GlobalKTable<K,V>
null
if this GlobalKTable
cannot be queried.