Package org.voltdb.stream.api.volt

Class AbstractVoltStreamSinkConfigurator<T,S extends AbstractVoltStreamSinkConfigurator<T,S>>

java.lang.Object

org.voltdb.stream.api.volt.AbstractVoltStreamSinkConfigurator<T,S>

All Implemented Interfaces:

OperatorConfigurator, VoltStreamSinkConfigurator<T>

Direct Known Subclasses:

BulkVoltStreamSinkConfigurator, ProcedureVoltStreamSinkConfigurator

public abstract class AbstractVoltStreamSinkConfigurator<T,S extends AbstractVoltStreamSinkConfigurator<T,S>>
extends Object
implements VoltStreamSinkConfigurator<T>

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT_HOST
static final int	VOLTDB_CLIENT_PORT

Constructor Summary

Constructors

Constructor	Description
AbstractVoltStreamSinkConfigurator()

Method Summary

Modifier and Type	Method	Description
protected String	emptyToNull(String string)
S	fromHostPortProperties(String hostProperty, String portProperty)
ExceptionHandler	getExceptionHandler()
Set<String>	getHostAndPorts()
protected S	self()
S	withExceptionHandler(ExceptionHandler exceptionHandler)
S	withHostAndPort(String hostname, int port)
S	withHostAndStandardPort(String hostname)

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_HOST

public static final String DEFAULT_HOST

VOLTDB_CLIENT_PORT

public static final int VOLTDB_CLIENT_PORT

See Also:

• Constant Field Values

Constructor Details

AbstractVoltStreamSinkConfigurator

public AbstractVoltStreamSinkConfigurator()

Method Details

withHostAndPort

public S withHostAndPort(String hostname,
 int port)

withHostAndStandardPort

public S withHostAndStandardPort(String hostname)

fromHostPortProperties

public S fromHostPortProperties(String hostProperty,
 String portProperty)

withExceptionHandler

public S withExceptionHandler(ExceptionHandler exceptionHandler)

getHostAndPorts

public Set<String> getHostAndPorts()

self

protected S self()

emptyToNull

protected String emptyToNull(String string)

getExceptionHandler

public ExceptionHandler getExceptionHandler()