Package | Description |
---|---|
org.apache.flink.state.changelog.restore | |
org.apache.flink.util | |
org.apache.flink.util.function |
Modifier and Type | Interface and Description |
---|---|
static interface |
ChangelogBackendRestoreOperation.DeltaBackendBuilder<K>
Builds
ChangelogKeyedStateBackend from the base backend and state. |
Modifier and Type | Method and Description |
---|---|
static <K,V> LinkedOptionalMap<K,V> |
LinkedOptionalMapSerializer.readOptionalMap(DataInputView in,
BiFunctionWithException<DataInputView,String,K,IOException> keyReader,
BiFunctionWithException<DataInputView,String,V,IOException> valueReader) |
static <K,V> LinkedOptionalMap<K,V> |
LinkedOptionalMapSerializer.readOptionalMap(DataInputView in,
BiFunctionWithException<DataInputView,String,K,IOException> keyReader,
BiFunctionWithException<DataInputView,String,V,IOException> valueReader) |
Modifier and Type | Method and Description |
---|---|
static <A,B,C> java.util.function.BiFunction<A,B,C> |
BiFunctionWithException.unchecked(BiFunctionWithException<A,B,C,?> biFunctionWithException)
Convert at
BiFunctionWithException into a BiFunction . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.