Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.serialization.Serde<ValueWithSequence<E>> |
AggregateSerdes.valueWithSequence() |
Modifier and Type | Method and Description |
---|---|
<S> ValueWithSequence<S> |
ValueWithSequence.map(java.util.function.Function<V,S> f) |
static <V> ValueWithSequence<V> |
ValueWithSequence.of(V a) |
Modifier and Type | Method and Description |
---|---|
static ValueWithSequence<org.apache.avro.generic.GenericRecord> |
AvroGenericUtils.ValueWithSequenceAvroHelper.fromGenericRecord(org.apache.avro.generic.GenericRecord record) |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.serialization.Serde<ValueWithSequence<E>> |
AvroAggregateSerdes.valueWithSequence() |
Modifier and Type | Method and Description |
---|---|
static org.apache.avro.generic.GenericRecord |
AvroGenericUtils.ValueWithSequenceAvroHelper.toGenericRecord(ValueWithSequence<org.apache.avro.generic.GenericRecord> valueWithSequence) |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.serialization.Serde<ValueWithSequence<E>> |
JsonAggregateSerdes.valueWithSequence() |
Modifier and Type | Method and Description |
---|---|
AggregateTestHelper.PublishBuilder |
AggregateTestHelper.PublishResponse.thenPublish(java.util.function.Function<AggregateUpdate<A>,ValueWithSequence<C>> commandGenerator)
Combinator to chain together multiple publishCommand commands.
|
Copyright © 2019. All rights reserved.