Uses of Interface
io.streamthoughts.azkarra.api.monad.Try

Packages that use Try

Package	Description
io.streamthoughts.azkarra.api.monad
io.streamthoughts.azkarra.api.query
io.streamthoughts.azkarra.api.query.internal

Uses of Try in io.streamthoughts.azkarra.api.monad

Classes in io.streamthoughts.azkarra.api.monad that implement Try

Modifier and Type	Class	Description
static class	Try.Failure<V>
static class	Try.Retriable<V>
static class	Try.Success<V>

Methods in io.streamthoughts.azkarra.api.monad that return Try

Modifier and Type	Method	Description
static <V,E extends Throwable> Try<V>	Try.failable(CheckedSupplier<V,E> supplier)
static <V> Try<V>	Try.failure(Throwable t)
<B> Try<B>	Try.Failure.flatMap(Function<? super V,Try<B>> mapper)
<B> Try<B>	Try.flatMap(Function<? super V,Try<B>> mapper)
<B> Try<B>	Try.Retriable.flatMap(Function<? super V,Try<B>> mapper)
<B> Try<B>	Try.Success.flatMap(Function<? super V,Try<B>> mapper)
<B> Try<B>	Try.Failure.map(Function<? super V,? extends B> mapper)
<B> Try<B>	Try.map(Function<? super V,? extends B> mapper)
<B> Try<B>	Try.Retriable.map(Function<? super V,? extends B> mapper)
<B> Try<B>	Try.Success.map(Function<? super V,? extends B> mapper)
Try<V>	Try.Failure.recover(Function<? super Throwable,Try<V>> fn)
Try<V>	Try.recover(Function<? super Throwable,Try<V>> f)
Try<V>	Try.Retriable.recover(Function<? super Throwable,Try<V>> f)
Try<V>	Try.Success.recover(Function<? super Throwable,Try<V>> f)
static <V> Try<V>	Try.success(V v)
<U> Try<U>	Try.Failure.transform(Function<V,Try<U>> s, Function<Throwable,Try<U>> f)
<U> Try<U>	Try.Retriable.transform(Function<V,Try<U>> s, Function<Throwable,Try<U>> f)
<U> Try<U>	Try.Success.transform(Function<V,Try<U>> s, Function<Throwable,Try<U>> f)
<U> Try<U>	Try.transform(Function<V,Try<U>> s, Function<Throwable,Try<U>> f)

Method parameters in io.streamthoughts.azkarra.api.monad with type arguments of type Try

Modifier and Type	Method	Description
<B> Try<B>	Try.Failure.flatMap(Function<? super V,Try<B>> mapper)
<B> Try<B>	Try.flatMap(Function<? super V,Try<B>> mapper)
<B> Try<B>	Try.Retriable.flatMap(Function<? super V,Try<B>> mapper)
<B> Try<B>	Try.Success.flatMap(Function<? super V,Try<B>> mapper)
Try<V>	Try.Failure.recover(Function<? super Throwable,Try<V>> fn)
Try<V>	Try.recover(Function<? super Throwable,Try<V>> f)
Try<V>	Try.Retriable.recover(Function<? super Throwable,Try<V>> f)
Try<V>	Try.Success.recover(Function<? super Throwable,Try<V>> f)
<U> Try<U>	Try.Failure.transform(Function<V,Try<U>> s, Function<Throwable,Try<U>> f)
<U> Try<U>	Try.Retriable.transform(Function<V,Try<U>> s, Function<Throwable,Try<U>> f)
<U> Try<U>	Try.Success.transform(Function<V,Try<U>> s, Function<Throwable,Try<U>> f)
<U> Try<U>	Try.transform(Function<V,Try<U>> s, Function<Throwable,Try<U>> f)

Uses of Try in io.streamthoughts.azkarra.api.query

Methods in io.streamthoughts.azkarra.api.query that return Try

Modifier and Type	Method	Description
default Try<List<KV<K,V>>>	LocalExecutableQuery.execute(LocalStoreAccessProvider provider)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	LocalExecutableQuery.execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	LoggingFailureLocalExecutableQuery.execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.
Try<T>	LocalStoreAccessor.get()

Uses of Try in io.streamthoughts.azkarra.api.query.internal

Methods in io.streamthoughts.azkarra.api.query.internal that return Try

Modifier and Type	Method	Description
Try<List<KV<String,Long>>>	KeyValueCountQuery.execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	KeyValueGetAllQuery.execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	KeyValueGetQuery.execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	KeyValueGetRangeQuery.execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	SessionFetchKeyRangeQuery.execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	SessionFetchQuery.execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	TimestampedKeyValueGetAllQuery.execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	TimestampedKeyValueGetQuery.execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	TimestampedKeyValueGetRangeQuery.execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	TimestampedWindowFetchAllQuery.execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	TimestampedWindowFetchKeyRangeQuery.execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	TimestampedWindowFetchQuery.execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<Long,V>>>	TimestampedWindowFetchTimeRangeQuery.execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	TimestampedWindowGetAllQuery.execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	WindowFetchAllQuery.execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	WindowFetchKeyRangeQuery.execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<K,V>>>	WindowFetchQuery.execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<Long,V>>>	WindowFetchTimeRangeQuery.execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.
Try<List<KV<org.apache.kafka.streams.kstream.Windowed<K>,V>>>	WindowGetAllQuery.execute(LocalStoreAccessProvider provider, long limit)	Executes this query to the specified KafkaStreams application.