Package | Description |
---|---|
org.apache.flink.connector.jdbc | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.util | |
org.apache.flink.util.function |
Modifier and Type | Interface and Description |
---|---|
interface |
JdbcStatementBuilder<T>
Sets
PreparedStatement parameters to use in JDBC Sink based on a specific type of
StreamRecord. |
Modifier and Type | Method and Description |
---|---|
void |
InternalTimerServiceImpl.forEachEventTimeTimer(BiConsumerWithException<N,Long,Exception> consumer) |
void |
InternalTimerService.forEachEventTimeTimer(BiConsumerWithException<N,Long,Exception> consumer)
Performs an action for each registered timer.
|
void |
InternalTimerServiceImpl.forEachProcessingTimeTimer(BiConsumerWithException<N,Long,Exception> consumer) |
void |
InternalTimerService.forEachProcessingTimeTimer(BiConsumerWithException<N,Long,Exception> consumer)
Performs an action for each registered timer.
|
Modifier and Type | Method and Description |
---|---|
static <K,V> void |
LinkedOptionalMapSerializer.writeOptionalMap(DataOutputView out,
LinkedOptionalMap<K,V> map,
BiConsumerWithException<DataOutputView,K,IOException> keyWriter,
BiConsumerWithException<DataOutputView,V,IOException> valueWriter) |
static <K,V> void |
LinkedOptionalMapSerializer.writeOptionalMap(DataOutputView out,
LinkedOptionalMap<K,V> map,
BiConsumerWithException<DataOutputView,K,IOException> keyWriter,
BiConsumerWithException<DataOutputView,V,IOException> valueWriter) |
Modifier and Type | Method and Description |
---|---|
static <A,B> java.util.function.BiConsumer<A,B> |
BiConsumerWithException.unchecked(BiConsumerWithException<A,B,?> biConsumerWithException)
Convert a
BiConsumerWithException into a BiConsumer . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.