public class WaitForDataService extends Object implements AsyncBiFunctionService.WithSerdes<String,Long,Str.Data>
AsyncBiFunctionService.WithSerdes<K,REQ,RES>
Constructor and Description |
---|
WaitForDataService(org.apache.kafka.streams.state.ReadOnlyKeyValueStore<String,Str.Data> storageKeyValueStore,
ForeachActionDispatcher<String,Str.Data> storageDispatcher) |
Modifier and Type | Method and Description |
---|---|
CompletionStage<Str.Data> |
apply(String artifactId,
Long offset) |
void |
close() |
org.apache.kafka.common.serialization.Serde<String> |
keySerde() |
org.apache.kafka.common.serialization.Serde<Long> |
reqSerde() |
org.apache.kafka.common.serialization.Serde<Str.Data> |
resSerde() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
apply, applyForStore
andThen
public static final String NAME
public WaitForDataService(org.apache.kafka.streams.state.ReadOnlyKeyValueStore<String,Str.Data> storageKeyValueStore, ForeachActionDispatcher<String,Str.Data> storageDispatcher)
public void close()
close
in interface AutoCloseable
public org.apache.kafka.common.serialization.Serde<String> keySerde()
keySerde
in interface AsyncBiFunctionService.WithSerdes<String,Long,Str.Data>
public org.apache.kafka.common.serialization.Serde<Long> reqSerde()
reqSerde
in interface AsyncBiFunctionService.WithSerdes<String,Long,Str.Data>
public org.apache.kafka.common.serialization.Serde<Str.Data> resSerde()
resSerde
in interface AsyncBiFunctionService.WithSerdes<String,Long,Str.Data>
public CompletionStage<Str.Data> apply(String artifactId, Long offset)
apply
in interface BiFunction<String,Long,CompletionStage<Str.Data>>
Copyright © 2020 Red Hat. All rights reserved.