Package org.dbos.apiary.voltdb

Class VoltConnection

java.lang.Object

org.dbos.apiary.voltdb.VoltConnection

All Implemented Interfaces:

org.dbos.apiary.connection.ApiaryConnection

public class VoltConnection
extends Object
implements org.dbos.apiary.connection.ApiaryConnection

For internal use only.

Field Summary

Fields

Modifier and Type	Field	Description
final org.voltdb.client.Client	client
static String	kPartitionInfoTableName

Constructor Summary

Constructors

Constructor	Description
VoltConnection(String hostname, Integer port)

Method Summary

Modifier and Type	Method	Description
FunctionOutput	callFunction(ProvenanceBuffer provBuff, String service, long execID, long functionID, String funcName, Object... inputs)	For internal use only.
String	getHostname(Object... input)	For internal use only.
int	getNumPartitions()	For internal use only.
Map<Integer,String>	getPartitionHostMap()	For internal use only.
void	updatePartitionInfo()	For internal use only.

Methods inherited from class java.lang.Object

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

Field Details

client

public final org.voltdb.client.Client client

kPartitionInfoTableName

public static String kPartitionInfoTableName

Constructor Details

VoltConnection

public VoltConnection(String hostname,
 Integer port)
               throws IOException

Throws:

IOException

Method Details

callFunction

public FunctionOutput callFunction(ProvenanceBuffer provBuff,
 String service,
 long execID,
 long functionID,
 String funcName,
 Object... inputs)
                            throws IOException,
org.voltdb.client.ProcCallException

Description copied from interface: org.dbos.apiary.connection.ApiaryConnection

For internal use only.

Specified by:

callFunction in interface org.dbos.apiary.connection.ApiaryConnection

Returns:

Throws:

IOException

org.voltdb.client.ProcCallException

updatePartitionInfo

public void updatePartitionInfo()

Description copied from interface: org.dbos.apiary.connection.ApiaryConnection

For internal use only.

Specified by:

updatePartitionInfo in interface org.dbos.apiary.connection.ApiaryConnection

getHostname

public String getHostname(Object... input)

Description copied from interface: org.dbos.apiary.connection.ApiaryConnection

For internal use only.

Specified by:

getHostname in interface org.dbos.apiary.connection.ApiaryConnection

Returns:

getPartitionHostMap

public Map<Integer,String> getPartitionHostMap()

Description copied from interface: org.dbos.apiary.connection.ApiaryConnection

For internal use only.

Specified by:

getPartitionHostMap in interface org.dbos.apiary.connection.ApiaryConnection

Returns:

getNumPartitions

public int getNumPartitions()

Description copied from interface: org.dbos.apiary.connection.ApiaryConnection

For internal use only.

Specified by:

getNumPartitions in interface org.dbos.apiary.connection.ApiaryConnection

Returns: