Package org.voltdb.stream.api.volt.helper

Class KafkaToVoltProcedureParameter.Configurator<K,V>

java.lang.Object

org.voltdb.stream.api.volt.helper.KafkaToVoltProcedureParameter.Configurator<K,V>

All Implemented Interfaces:

OperatorConfigurator, VoltFunctionConfigurator<KafkaRequest<K,V>,Object[]>

Enclosing class:

KafkaToVoltProcedureParameter

public static class KafkaToVoltProcedureParameter.Configurator<K,V>
extends Object
implements VoltFunctionConfigurator<KafkaRequest<K,V>,Object[]>

Method Summary

Modifier and Type	Method	Description
KafkaToVoltProcedureParameter.Configurator<K,V>	withHeaderFilter(Function<Map<String,String>,Map<String,String>> filter)
KafkaToVoltProcedureParameter.Configurator<K,V>	withKeyExtractor(BiFunction<K,Map<String,String>,Object> extractor)
KafkaToVoltProcedureParameter.Configurator<K,V>	withSchemaRegistryUrl(String schemaUrl)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.voltdb.stream.api.extension.OperatorConfigurator

configure, getConfiguration

Method Details

withSchemaRegistryUrl

public KafkaToVoltProcedureParameter.Configurator<K,V> withSchemaRegistryUrl(String schemaUrl)

withKeyExtractor

public KafkaToVoltProcedureParameter.Configurator<K,V> withKeyExtractor(BiFunction<K,Map<String,String>,Object> extractor)

withHeaderFilter

public KafkaToVoltProcedureParameter.Configurator<K,V> withHeaderFilter(Function<Map<String,String>,Map<String,String>> filter)