Package io.streamthoughts.azkarra.api.query

Interface LocalStoreAccessProvider

    • Method Detail

      • localKeyValueStore

        <K,​V> LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlyKeyValueStore<K,​V>> localKeyValueStore​(String store)
        Gets a read-only access to a local key-value store.
        Type Parameters:
        K - the type of the key.
        V - the type of the value.
        Parameters:
        store - the name of the store to access.
        Returns:
        the LocalStoreAccessor instance.

      • localTimestampedKeyValueStore

        <K,​V> LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlyKeyValueStore<K,​org.apache.kafka.streams.state.ValueAndTimestamp<V>>> localTimestampedKeyValueStore​(String store)
        Gets a read-only access to the local timestamped key-value store.
        Type Parameters:
        K - the type of the key.
        V - the type of the value.
        Parameters:
        store - the name of the store to access.
        Returns:
        the LocalStoreAccessor instance.

      • localWindowStore

        <K,​V> LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlyWindowStore<K,​V>> localWindowStore​(String store)
        Gets a read-only access to a local window store.
        Type Parameters:
        K - the type of the key.
        V - the type of the value.
        Parameters:
        store - the name of the store to access.
        Returns:
        the LocalStoreAccessor instance.

      • localTimestampedWindowStore

        <K,​V> LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlyWindowStore<K,​org.apache.kafka.streams.state.ValueAndTimestamp<V>>> localTimestampedWindowStore​(String store)
        Gets a read-only access to a local window store.
        Type Parameters:
        K - the type of the key.
        V - the type of the value.
        Parameters:
        store - the name of the store to access.
        Returns:
        the LocalStoreAccessor instance.

      • localSessionStore

        <K,​V> LocalStoreAccessor<org.apache.kafka.streams.state.ReadOnlySessionStore<K,​V>> localSessionStore​(String store)
        Gets a read-only access to a local session store.
        Type Parameters:
        K - the type of the key.
        V - the type of the value.
        Parameters:
        store - the name of the store to access.
        Returns:
        the LocalStoreAccessor instance.

      • findAllEndpointsForStore

        Set<Endpoint> findAllEndpointsForStore​(String storeName)

      • findMetadataForStoreAndKey

        <K> Optional<org.apache.kafka.streams.KeyQueryMetadata> findMetadataForStoreAndKey​(String storeName,
                                                                                   K key,
                                                                                   org.apache.kafka.common.serialization.Serializer<K> keySerializer)