Package org.voltdb.stream.api.volt

Class VoltProcedureConfigurator<I,O>

java.lang.Object

org.voltdb.stream.api.volt.VoltProcedureConfigurator<I,O>

All Implemented Interfaces:

OperatorConfigurator, VoltFunctionConfigurator<I,O>

public class VoltProcedureConfigurator<I,O>
extends Object
implements VoltFunctionConfigurator<I,O>

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT_SINK_HOST
static final int	FLUSH_INTERVAL
static final int	MAX_BATCH_SIZE
static final int	VOLTDB_CLIENT_PORT

Constructor Summary

Constructors

Constructor	Description
VoltProcedureConfigurator(String procedureName)

Method Summary

Modifier and Type	Method	Description
ExceptionHandler	getExceptionHandler()
int	getFlushInterval()
int	getMaxBatchSize()
String	getRemoteBufferName()
String	getRemoteProcedureName()
String	getRemoteTopicName()
int	getRetries()
String	getSchemaRegistryUrl()
Set<String>	getTopicsHostAndPorts()
Set<String>	getVoltClientHostAndPorts()
static <I, O> VoltProcedureConfigurator<I,O>	procedureCall(String procedureName)
VoltProcedureConfigurator<I,O>	withExceptionHandler(ExceptionHandler exceptionHandler)
VoltProcedureConfigurator<I,O>	withFlushInterval(Duration interval)
VoltProcedureConfigurator<I,O>	withHostAndPort(String hostProperty, String portProperty)
VoltProcedureConfigurator<I,O>	withHostAndStandardPort(String hostProperty)
VoltProcedureConfigurator<I,O>	withMaxBatchSize(int size)
VoltProcedureConfigurator<I,O>	withProcedureName(String procedureName)
VoltProcedureConfigurator<I,O>	withRetry(int retries)
VoltProcedureConfigurator<I,O>	withSchemaRegistryUrl(String schemaRegistryUrl)
VoltProcedureConfigurator<I,O>	withTopicsAndPort(String hostProperty, String portProperty)

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

Field Details

VOLTDB_CLIENT_PORT

public static final int VOLTDB_CLIENT_PORT

See Also:

• Constant Field Values

DEFAULT_SINK_HOST

public static final String DEFAULT_SINK_HOST

MAX_BATCH_SIZE

public static final int MAX_BATCH_SIZE

FLUSH_INTERVAL

public static final int FLUSH_INTERVAL

Constructor Details

VoltProcedureConfigurator

public VoltProcedureConfigurator(String procedureName)

Method Details

procedureCall

public static <I,
O> VoltProcedureConfigurator<I,O> procedureCall(String procedureName)

withHostAndPort

public VoltProcedureConfigurator<I,O> withHostAndPort(String hostProperty,
 String portProperty)

withTopicsAndPort

public VoltProcedureConfigurator<I,O> withTopicsAndPort(String hostProperty,
 String portProperty)

withHostAndStandardPort

public VoltProcedureConfigurator<I,O> withHostAndStandardPort(String hostProperty)

withProcedureName

public VoltProcedureConfigurator<I,O> withProcedureName(String procedureName)

withMaxBatchSize

public VoltProcedureConfigurator<I,O> withMaxBatchSize(int size)

withFlushInterval

public VoltProcedureConfigurator<I,O> withFlushInterval(Duration interval)

withExceptionHandler

public VoltProcedureConfigurator<I,O> withExceptionHandler(ExceptionHandler exceptionHandler)

withSchemaRegistryUrl

public VoltProcedureConfigurator<I,O> withSchemaRegistryUrl(String schemaRegistryUrl)

withRetry

public VoltProcedureConfigurator<I,O> withRetry(int retries)

getVoltClientHostAndPorts

public Set<String> getVoltClientHostAndPorts()

getTopicsHostAndPorts

public Set<String> getTopicsHostAndPorts()

getRemoteProcedureName

public String getRemoteProcedureName()

getRemoteBufferName

public String getRemoteBufferName()

getRemoteTopicName

public String getRemoteTopicName()

getMaxBatchSize

public int getMaxBatchSize()

getFlushInterval

public int getFlushInterval()

getExceptionHandler

public ExceptionHandler getExceptionHandler()

getSchemaRegistryUrl

public String getSchemaRegistryUrl()

getRetries

public int getRetries()