Package | Description |
---|---|
org.apache.flink.streaming.tests.verify |
Modifier and Type | Method and Description |
---|---|
ValueWithTs<?> |
ValueWithTs.Serializer.createInstance(Object... values) |
ValueWithTs<UV> |
TtlUpdateContext.getUpdateWithTs() |
Modifier and Type | Method and Description |
---|---|
protected CompositeSerializer<ValueWithTs<?>> |
ValueWithTs.Serializer.createSerializerInstance(CompositeSerializer.PrecomputedParameters precomputed,
TypeSerializer<?>... originalSerializers) |
TypeSerializerSnapshot<ValueWithTs<?>> |
ValueWithTs.Serializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
protected Object |
ValueWithTs.Serializer.getField(ValueWithTs<?> value,
int index) |
protected void |
ValueWithTs.Serializer.setField(ValueWithTs<?> value,
int index,
Object fieldValue) |
Constructor and Description |
---|
TtlVerificationContext(int key,
String verifierId,
List<ValueWithTs<?>> prevUpdates,
TtlUpdateContext<?,?> updateContext) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.