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

Class AvroToVoltProcedureParameter.SerializerConfigurator

java.lang.Object

org.voltdb.stream.api.volt.helper.AvroToVoltProcedureParameter.SerializerConfigurator

All Implemented Interfaces:

OperatorConfigurator, VoltFunctionConfigurator<org.apache.avro.generic.GenericRecord,Object[]>

Enclosing class:

AvroToVoltProcedureParameter

public static class AvroToVoltProcedureParameter.SerializerConfigurator
extends Object
implements VoltFunctionConfigurator<org.apache.avro.generic.GenericRecord,Object[]>

Method Summary

Modifier and Type	Method	Description
AvroToVoltProcedureParameter.SerializerConfigurator	withKeyExtractor(Function<org.apache.avro.generic.GenericRecord,Object> extractor)
AvroToVoltProcedureParameter.SerializerConfigurator	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 AvroToVoltProcedureParameter.SerializerConfigurator withSchemaRegistryUrl(String schemaUrl)

withKeyExtractor

public AvroToVoltProcedureParameter.SerializerConfigurator withKeyExtractor(Function<org.apache.avro.generic.GenericRecord,Object> extractor)