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 |
---|---|
static <T> void |
PulsarSerdeUtils.serializeList(DataOutputStream out,
List<T> list,
BiConsumerWithException<DataOutputStream,T,IOException> serializer) |
static <K,V> void |
PulsarSerdeUtils.serializeMap(DataOutputStream out,
Map<K,V> map,
BiConsumerWithException<DataOutputStream,K,IOException> keySerializer,
BiConsumerWithException<DataOutputStream,V,IOException> valueSerializer) |
static <K,V> void |
PulsarSerdeUtils.serializeMap(DataOutputStream out,
Map<K,V> map,
BiConsumerWithException<DataOutputStream,K,IOException> keySerializer,
BiConsumerWithException<DataOutputStream,V,IOException> valueSerializer) |
static <T> void |
PulsarSerdeUtils.serializeSet(DataOutputStream out,
Set<T> set,
BiConsumerWithException<DataOutputStream,T,IOException> serializer) |
Modifier and Type | Method and Description |
---|---|
void |
ConfigurationOptionLocator.discoverOptionsAndApply(Path rootDir,
BiConsumerWithException<Class<?>,Collection<OptionWithMetaInfo>,? extends Exception> optionsConsumer) |
Modifier and Type | Method and Description |
---|---|
void |
InternalTimerService.forEachEventTimeTimer(BiConsumerWithException<N,Long,Exception> consumer)
Performs an action for each registered timer.
|
void |
InternalTimerServiceImpl.forEachEventTimeTimer(BiConsumerWithException<N,Long,Exception> consumer) |
void |
InternalTimerService.forEachProcessingTimeTimer(BiConsumerWithException<N,Long,Exception> consumer)
Performs an action for each registered timer.
|
void |
InternalTimerServiceImpl.forEachProcessingTimeTimer(BiConsumerWithException<N,Long,Exception> consumer) |
Modifier and Type | Method and Description |
---|---|
void |
BatchExecutionInternalTimeService.forEachEventTimeTimer(BiConsumerWithException<N,Long,Exception> consumer) |
void |
BatchExecutionInternalTimeService.forEachProcessingTimeTimer(BiConsumerWithException<N,Long,Exception> consumer) |
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–2022 The Apache Software Foundation. All rights reserved.