Index (Apiary Public API)

A B C D E F G H I K O P Q R S T U V
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

addEntry(String, Object...) - Method in class org.dbos.apiary.function.ProvenanceBuffer
apiaryCallFunction(String, Object...) - Method in class org.dbos.apiary.function.ApiaryContext: Synchronously invoke a function.
apiaryCallFunction(String, Object...) - Method in class org.dbos.apiary.function.ApiaryStatelessContext
apiaryCallFunction(String, Object...) - Method in class org.dbos.apiary.function.ApiaryTransactionalContext: Public Interface for functions.
apiaryCallFunction(String, Object...) - Method in class org.dbos.apiary.postgres.PostgresContext
apiaryCallFunction(String, Object...) - Method in class org.dbos.apiary.voltdb.VoltContext
ApiaryContext - Class in org.dbos.apiary.function: ApiaryContext provides APIs to invoke other functions and run queries.
ApiaryContext(ProvenanceBuffer, String, long, long) - Constructor for class org.dbos.apiary.function.ApiaryContext
ApiaryFunction - Interface in org.dbos.apiary.function: The base class for Apiary functions.
ApiaryFuture - Class in org.dbos.apiary.function: ApiaryFuture is returned by asynchronously invoked functions.
ApiaryFuture(long) - Constructor for class org.dbos.apiary.function.ApiaryFuture
apiaryGetTransactionId() - Method in class org.dbos.apiary.function.ApiaryTransactionalContext: Get the current transaction ID.
apiaryQueueFunction(String, Object...) - Method in class org.dbos.apiary.function.ApiaryContext: Queue a function for asynchronous execution.
apiaryRunFunction(ApiaryContext, Object...) - Method in interface org.dbos.apiary.function.ApiaryFunction
ApiaryStatelessContext - Class in org.dbos.apiary.function: ApiaryStatelessContext is a context for stateless functions.
ApiaryStatelessContext(ApiaryConnection, InternalApiaryWorkerClient, ProvenanceBuffer, String, long, long, Map<String, Callable<StatelessFunction>>) - Constructor for class org.dbos.apiary.function.ApiaryStatelessContext
ApiaryTransactionalContext - Class in org.dbos.apiary.function: ApiaryTransactionalContext is the base class for transactional function contexts.
ApiaryTransactionalContext(ProvenanceBuffer, String, long, long) - Constructor for class org.dbos.apiary.function.ApiaryTransactionalContext
ApiaryWorkerClient - Class in org.dbos.apiary.client: ApiaryWorkerClient provides an interface for invoking Apiary functions from a remote client.
ApiaryWorkerClient(String) - Constructor for class org.dbos.apiary.client.ApiaryWorkerClient: Create a client for sending synchronous requests to Apiary.
ApiaryWorkerClient(String, ZContext) - Constructor for class org.dbos.apiary.client.ApiaryWorkerClient: Create a client for sending asynchronous requests to Apiary.

B

batchSize - Static variable in class org.dbos.apiary.function.ProvenanceBuffer

C

callFunction(ProvenanceBuffer, String, long, long, String, Object...) - Method in class org.dbos.apiary.postgres.PostgresConnection
callFunction(ProvenanceBuffer, String, long, long, String, Object...) - Method in class org.dbos.apiary.voltdb.VoltConnection
checkPreviousExecution() - Method in class org.dbos.apiary.function.ApiaryContext: For internal use only.
checkPreviousExecution() - Method in class org.dbos.apiary.function.ApiaryStatelessContext
checkPreviousExecution() - Method in class org.dbos.apiary.postgres.PostgresContext
checkPreviousExecution() - Method in class org.dbos.apiary.voltdb.VoltContext
client - Variable in class org.dbos.apiary.voltdb.VoltConnection
close() - Method in class org.dbos.apiary.function.ProvenanceBuffer
conn - Variable in class org.dbos.apiary.function.ProvenanceBuffer
createTable(String, String) - Method in class org.dbos.apiary.postgres.PostgresConnection: Create a table and a corresponding events table.

D

DELETE - Enum constant in enum class org.dbos.apiary.function.ProvenanceBuffer.ExportOperation
dereferenceFutures(Map<Long, Object>) - Method in class org.dbos.apiary.function.Task
dropTable(String) - Method in class org.dbos.apiary.postgres.PostgresConnection: Drop a table and its corresponding events table if they exist.

E

execID - Variable in class org.dbos.apiary.function.ApiaryContext: For internal use only.
executeFunction(String, Object...) - Method in class org.dbos.apiary.client.ApiaryWorkerClient: Invoke a function synchronously and block waiting for the result.
executeFunction(String, String, String, long, Object...) - Method in class org.dbos.apiary.client.InternalApiaryWorkerClient
executeQuery(String, Object...) - Method in class org.dbos.apiary.postgres.PostgresContext: Execute a database query.
executeQuery(SQLStmt, Object...) - Method in class org.dbos.apiary.voltdb.VoltContext: Execute a database query.
executeUpdate(String, Object...) - Method in class org.dbos.apiary.postgres.PostgresContext: Execute a database update.
executeUpdate(SQLStmt, Object...) - Method in class org.dbos.apiary.voltdb.VoltContext: Execute a database update.
exportInterval - Static variable in class org.dbos.apiary.function.ProvenanceBuffer

F

funcName - Variable in class org.dbos.apiary.function.Task
functionID - Variable in class org.dbos.apiary.function.ApiaryContext: For internal use only.
functionID - Variable in class org.dbos.apiary.function.Task
FunctionOutput - Class in org.dbos.apiary.function: FunctionOutput stores the output of a function.
FunctionOutput(Object, List<Task>) - Constructor for class org.dbos.apiary.function.FunctionOutput
futureID - Variable in class org.dbos.apiary.function.ApiaryFuture

G

getClientID() - Method in class org.dbos.apiary.client.ApiaryWorkerClient: Get the globally unique clientID of this current client.
getFunctionOutput(Object) - Method in class org.dbos.apiary.function.ApiaryContext: For internal use only.
getFuture() - Method in class org.dbos.apiary.function.FunctionOutput: Return an ApiaryFuture output.
getHostname(Object...) - Method in class org.dbos.apiary.postgres.PostgresConnection
getHostname(Object...) - Method in class org.dbos.apiary.voltdb.VoltConnection
getInt() - Method in class org.dbos.apiary.function.FunctionOutput: Return an Integer output.
getIntArray() - Method in class org.dbos.apiary.function.FunctionOutput: Return an Integer array output.
getNumPartitions() - Method in class org.dbos.apiary.postgres.PostgresConnection
getNumPartitions() - Method in class org.dbos.apiary.voltdb.VoltConnection
getPartitionHostMap() - Method in class org.dbos.apiary.postgres.PostgresConnection
getPartitionHostMap() - Method in class org.dbos.apiary.voltdb.VoltConnection
getRecordedOutput - Static variable in class org.dbos.apiary.voltdb.VoltFunction
getSocket(String) - Method in class org.dbos.apiary.client.ApiaryWorkerClient: Get a ZMQ socket for sending asynchronous requests.
getSocket(String) - Method in class org.dbos.apiary.client.InternalApiaryWorkerClient
getString() - Method in class org.dbos.apiary.function.FunctionOutput: Return a String output.
getStringArray() - Method in class org.dbos.apiary.function.FunctionOutput: Return a String array output.
getValue() - Method in enum class org.dbos.apiary.function.ProvenanceBuffer.ExportOperation

H

hasConnection - Variable in class org.dbos.apiary.function.ProvenanceBuffer

I

input - Variable in class org.dbos.apiary.function.Task
INSERT - Enum constant in enum class org.dbos.apiary.function.ProvenanceBuffer.ExportOperation
InternalApiaryWorkerClient - Class in org.dbos.apiary.client: For internal use only.
InternalApiaryWorkerClient(ZContext) - Constructor for class org.dbos.apiary.client.InternalApiaryWorkerClient
internalGetTransactionId() - Method in class org.dbos.apiary.postgres.PostgresContext

K

kPartitionInfoTableName - Static variable in class org.dbos.apiary.voltdb.VoltConnection

O

org.dbos.apiary.client - package org.dbos.apiary.client: Provide the classes necessary to invoke Apiary functions from a remote client.
org.dbos.apiary.function - package org.dbos.apiary.function: Provide the classes necessary to write Apiary functions.
org.dbos.apiary.postgres - package org.dbos.apiary.postgres: Provide the classes necessary to write Postgres backed functions.
org.dbos.apiary.voltdb - package org.dbos.apiary.voltdb: Provide the classes necessary to write VoltDB backed functions.
output - Variable in class org.dbos.apiary.function.FunctionOutput

P

padding - Static variable in class org.dbos.apiary.function.ProvenanceBuffer
pkey - Variable in class org.dbos.apiary.voltdb.VoltFunction
PostgresConnection - Class in org.dbos.apiary.postgres: A connection to a Postgres database.
PostgresConnection(String, Integer, String, String, String) - Constructor for class org.dbos.apiary.postgres.PostgresConnection: Create a connection to a Postgres database.
PostgresContext - Class in org.dbos.apiary.postgres: PostgresContext is a context for Apiary-Postgres functions.
PostgresContext(Connection, ProvenanceBuffer, String, long, long) - Constructor for class org.dbos.apiary.postgres.PostgresContext
PostgresFunction - Class in org.dbos.apiary.postgres: All Postgres functions should extend this class and implement runFunction.
PostgresFunction() - Constructor for class org.dbos.apiary.postgres.PostgresFunction
provBuff - Variable in class org.dbos.apiary.function.ApiaryContext: For internal use only.
provBuff - Static variable in class org.dbos.apiary.voltdb.VoltFunction
ProvenanceBuffer - Class in org.dbos.apiary.function: For internal use only.
ProvenanceBuffer(String, String) - Constructor for class org.dbos.apiary.function.ProvenanceBuffer
ProvenanceBuffer.ExportOperation - Enum Class in org.dbos.apiary.function: Enum class for provenance operations.

Q

queuedTasks - Variable in class org.dbos.apiary.function.FunctionOutput

R

READ - Enum constant in enum class org.dbos.apiary.function.ProvenanceBuffer.ExportOperation
recordExecution(FunctionOutput) - Method in class org.dbos.apiary.function.ApiaryContext: For internal use only.
recordExecution(FunctionOutput) - Method in class org.dbos.apiary.function.ApiaryStatelessContext
recordExecution(FunctionOutput) - Method in class org.dbos.apiary.postgres.PostgresContext
recordExecution(FunctionOutput) - Method in class org.dbos.apiary.voltdb.VoltContext
recordInvocation(ApiaryContext, String) - Method in interface org.dbos.apiary.function.ApiaryFunction
recordInvocation(ApiaryContext, String) - Method in class org.dbos.apiary.function.StatelessFunction
recordInvocation(ApiaryContext, String) - Method in class org.dbos.apiary.postgres.PostgresFunction
recordInvocation(ApiaryContext, String) - Method in class org.dbos.apiary.voltdb.VoltFunction
recordOutput - Static variable in class org.dbos.apiary.voltdb.VoltFunction
registerFunction(String, Callable<PostgresFunction>) - Method in class org.dbos.apiary.postgres.PostgresConnection: Register a PostgresFunction.
run(int, VoltTable) - Method in class org.dbos.apiary.voltdb.VoltFunction

S

serializeExecuteRequest(String, String, long, long, long, Object...) - Static method in class org.dbos.apiary.client.InternalApiaryWorkerClient
serializeExecuteRequest(String, String, Object...) - Method in class org.dbos.apiary.client.ApiaryWorkerClient: Serialize a function invocation request, used for sending asynchronous requests.
service - Variable in class org.dbos.apiary.function.ApiaryContext: For internal use only.
StatelessFunction - Class in org.dbos.apiary.function: The base class for Apiary stateless functions.
StatelessFunction() - Constructor for class org.dbos.apiary.function.StatelessFunction

T

Task - Class in org.dbos.apiary.function: For internal use only.
Task(long, String, Object[]) - Constructor for class org.dbos.apiary.function.Task

U

UPDATE - Enum constant in enum class org.dbos.apiary.function.ProvenanceBuffer.ExportOperation
updatePartitionInfo() - Method in class org.dbos.apiary.postgres.PostgresConnection
updatePartitionInfo() - Method in class org.dbos.apiary.voltdb.VoltConnection

V

valueOf(String) - Static method in enum class org.dbos.apiary.function.ProvenanceBuffer.ExportOperation: Returns the enum constant of this class with the specified name.
values() - Static method in enum class org.dbos.apiary.function.ProvenanceBuffer.ExportOperation: Returns an array containing the constants of this enum class, in the order they are declared.
VoltConnection - Class in org.dbos.apiary.voltdb: For internal use only.
VoltConnection(String, Integer) - Constructor for class org.dbos.apiary.voltdb.VoltConnection
VoltContext - Class in org.dbos.apiary.voltdb: VoltContext is a context for Apiary-VoltDB functions.
VoltContext(VoltFunction, ProvenanceBuffer, String, long, long) - Constructor for class org.dbos.apiary.voltdb.VoltContext
VoltFunction - Class in org.dbos.apiary.voltdb: All VoltDB functions should extend this class and implement runFunction.
VoltFunction() - Constructor for class org.dbos.apiary.voltdb.VoltFunction

A B C D E F G H I K O P Q R S T U V
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form