Confluo  0.1.0
confluo.rpc.RpcClient Member List

This is the complete list of members for confluo.rpc.RpcClient, including all inherited members.

addAggregate(String aggregateName, String filterName, String aggregateExpr)confluo.rpc.RpcClientinline
addFilter(String filterName, String filterExpr)confluo.rpc.RpcClientinline
addIndex(String fieldName, double bucketSize)confluo.rpc.RpcClientinline
append(List< String > record)confluo.rpc.RpcClientinline
append(String... record)confluo.rpc.RpcClientinline
appendRaw(ByteBuffer record)confluo.rpc.RpcClientinline
close()confluo.rpc.RpcClientinline
createAtomicMultilog(String name, Schema schema, rpc_storage_mode storageMode)confluo.rpc.RpcClientinline
createAtomicMultilog(String name, String schema, rpc_storage_mode storageMode)confluo.rpc.RpcClientinline
disconnect()confluo.rpc.RpcClientinline
executeFilter(String filterExpr)confluo.rpc.RpcClientinline
getAggregate(String aggregateName, long beginMs, long endMs)confluo.rpc.RpcClientinline
getAlerts(long beginMs, long endMs, String triggerName)confluo.rpc.RpcClientinline
getBatchBuilder()confluo.rpc.RpcClientinline
installTrigger(String triggerName, String triggerExpr)confluo.rpc.RpcClientinline
numRecords()confluo.rpc.RpcClientinline
queryFilter(String filterName, long beginMs, long endMs, String filterExpr)confluo.rpc.RpcClientinline
read(long offset) (defined in confluo.rpc.RpcClient)confluo.rpc.RpcClientinline
readRaw(long offset)confluo.rpc.RpcClientinline
removeAggregate(String aggregateName)confluo.rpc.RpcClientinline
removeAtomicMultilog()confluo.rpc.RpcClientinline
removeFilter(String filterName)confluo.rpc.RpcClientinline
removeIndex(String fieldName)confluo.rpc.RpcClientinline
removeTrigger(String triggerName)confluo.rpc.RpcClientinline
RpcClient(String host, int port)confluo.rpc.RpcClientinline
setCurrentAtomicMultilog(String name)confluo.rpc.RpcClientinline