Package org.voltdb.stream.api.volt

Class ProcedureVoltStreamSinkConfigurator

java.lang.Object

org.voltdb.stream.api.volt.AbstractVoltStreamSinkConfigurator<Object[],ProcedureVoltStreamSinkConfigurator>

org.voltdb.stream.api.volt.ProcedureVoltStreamSinkConfigurator

All Implemented Interfaces:

OperatorConfigurator, VoltStreamSinkConfigurator<Object[]>

public class ProcedureVoltStreamSinkConfigurator
extends AbstractVoltStreamSinkConfigurator<Object[],ProcedureVoltStreamSinkConfigurator>

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT_PROCEDURE_NAME

Fields inherited from class org.voltdb.stream.api.volt.AbstractVoltStreamSinkConfigurator

DEFAULT_HOST, VOLTDB_CLIENT_PORT

Constructor Summary

Constructors

Constructor	Description
ProcedureVoltStreamSinkConfigurator()
ProcedureVoltStreamSinkConfigurator(String procedureName)

Method Summary

Modifier and Type	Method	Description
static ProcedureVoltStreamSinkConfigurator	aSink()
String	getProcedureName()
int	getRetries()
ProcedureVoltStreamSinkConfigurator	withProcedureName(String procedureName)
ProcedureVoltStreamSinkConfigurator	withRetry(int retries)

Methods inherited from class org.voltdb.stream.api.volt.AbstractVoltStreamSinkConfigurator

emptyToNull, fromHostPortProperties, getExceptionHandler, getHostAndPorts, self, withExceptionHandler, withHostAndPort, withHostAndStandardPort

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

DEFAULT_PROCEDURE_NAME

public static final String DEFAULT_PROCEDURE_NAME

Constructor Details

ProcedureVoltStreamSinkConfigurator

public ProcedureVoltStreamSinkConfigurator()

ProcedureVoltStreamSinkConfigurator

public ProcedureVoltStreamSinkConfigurator(String procedureName)

Method Details

aSink

public static ProcedureVoltStreamSinkConfigurator aSink()

withProcedureName

public ProcedureVoltStreamSinkConfigurator withProcedureName(String procedureName)

withRetry

public ProcedureVoltStreamSinkConfigurator withRetry(int retries)

getProcedureName

public String getProcedureName()

getRetries

public int getRetries()