Public Member Functions
	RpcClient (String host, int port) throws TException

void	close () throws TException

void	disconnect () throws TException

void	createAtomicMultilog (String name, Schema schema, rpc_storage_mode storageMode) throws TException

void	createAtomicMultilog (String name, String schema, rpc_storage_mode storageMode) throws TException

void	setCurrentAtomicMultilog (String name) throws TException

void	removeAtomicMultilog () throws TException

void	addIndex (String fieldName, double bucketSize) throws TException

void	removeIndex (String fieldName) throws TException

void	addFilter (String filterName, String filterExpr) throws TException

void	removeFilter (String filterName) throws TException

void	addAggregate (String aggregateName, String filterName, String aggregateExpr) throws TException

void	removeAggregate (String aggregateName) throws TException

void	installTrigger (String triggerName, String triggerExpr) throws TException

void	removeTrigger (String triggerName) throws TException

RecordBatchBuilder	getBatchBuilder ()

long	appendRaw (ByteBuffer record) throws TException

long	append (List< String > record) throws TException

long	append (String... record) throws TException

ByteBuffer	readRaw (long offset) throws TException

Record	read (long offset) throws TException

String	getAggregate (String aggregateName, long beginMs, long endMs) throws TException

RecordStream	executeFilter (String filterExpr) throws TException

RecordStream	queryFilter (String filterName, long beginMs, long endMs, String filterExpr) throws TException

AlertStream	getAlerts (long beginMs, long endMs, String triggerName) throws TException

long	numRecords () throws TException

Detailed Description

Client for Confluo through RPC

Constructor & Destructor Documentation

◆ RpcClient()

confluo.rpc.RpcClient.RpcClient	(	String	host,
		int	port
	)		throws TException

inline

Initializes the rpc client to the specified host and port

Parameters

host	The host for the client
port	The port number to communicate through

Exceptions

TException Cannot connect to host

Member Function Documentation

◆ addAggregate()

void confluo.rpc.RpcClient.addAggregate	(	String	aggregateName,
		String	filterName,
		String	aggregateExpr
	)		throws TException

inline

Adds an aggregate to the atomic multilog

Parameters

aggregateName	The name of the aggregate
filterName	The name of the filter
aggregateExpr	The aggregate expression

Exceptions

TException Cannot add the aggregate

◆ addFilter()

void confluo.rpc.RpcClient.addFilter	(	String	filterName,
		String	filterExpr
	)		throws TException

inline

Adds a filter to the atomic multilog

Parameters

filterName	The name of the filter
filterExpr	The filter expression

Exceptions

TException Cannot add filter

◆ addIndex()

void confluo.rpc.RpcClient.addIndex	(	String	fieldName,
		double	bucketSize
	)		throws TException

inline

Adds an index to the atomic multilog

Parameters

fieldName	The name of the associated field
bucketSize	The bucket in the multilog to add the index

Exceptions

TException Cannot add the index

◆ append() [1/2]

long confluo.rpc.RpcClient.append ( List< String > record ) throws TException

inline

Writes a record to the atomic multilog

Parameters

record The record to write

Returns: The offset into the log where the record is written.

Exceptions

TException Cannot append the record

◆ append() [2/2]

long confluo.rpc.RpcClient.append ( String... record ) throws TException

inline

Writes a record to the atomic multilog

Parameters

record The record to write

Returns: The offset into the log where the record is written.

Exceptions

TException Cannot append the record

◆ appendRaw()

long confluo.rpc.RpcClient.appendRaw ( ByteBuffer record ) throws TException

inline

Writes a record to the atomic multilog

Parameters

record The record to write

Returns: The offset into the log where the record is written.

Exceptions

TException Cannot append the record

◆ close()

void confluo.rpc.RpcClient.close ( ) throws TException

inline

Closes the rpc client

Exceptions

TException Cannot disconnect

◆ createAtomicMultilog() [1/2]

void confluo.rpc.RpcClient.createAtomicMultilog	(	String	name,
		Schema	schema,
		rpc_storage_mode	storageMode
	)		throws TException

inline

Creates an atomic multilog for this client

Parameters

name	The name of the atomic multilog to create
schema	The schema for the atomic multilog
storageMode	The mode for storage

Exceptions

TException Cannot create the atomic multilog

◆ createAtomicMultilog() [2/2]

void confluo.rpc.RpcClient.createAtomicMultilog	(	String	name,
		String	schema,
		rpc_storage_mode	storageMode
	)		throws TException

inline

Creates an atomic multilog for this client

Parameters

name	The name of the atomic multilog to create
schema	The schema for the atomic multilog
storageMode	The mode for storage

Exceptions

TException Cannot create the atomic multilog

◆ disconnect()

void confluo.rpc.RpcClient.disconnect ( ) throws TException

inline

Disconnects the rpc client from the host and port

Exceptions

TException Cannot disconnect

◆ executeFilter()

RecordStream confluo.rpc.RpcClient.executeFilter ( String filterExpr ) throws TException

inline

Executes a specified filter

Parameters

filterExpr The filter expression

Returns: Record stream containing the data

Exceptions

TException Cannot execute the filter

◆ getAggregate()

String confluo.rpc.RpcClient.getAggregate	(	String	aggregateName,
		long	beginMs,
		long	endMs
	)		throws TException

inline

Gets an aggregate from the atomic multilog

Parameters

aggregateName	The name of the aggregate
beginMs	The beginning time in milliseconds
endMs	The end time in milliseconds

Returns: The aggregate

Exceptions

TException Cannot get the aggregate

◆ getAlerts()

AlertStream confluo.rpc.RpcClient.getAlerts	(	long	beginMs,
		long	endMs,
		String	triggerName
	)		throws TException

inline

Gets the alerts

Parameters

beginMs	The beginning time in milliseconds
endMs	The end time in milliseconds
triggerName	The name of the trigger

Returns: A stream of alerts

Exceptions

TException Cannot get the alerts

◆ getBatchBuilder()

RecordBatchBuilder confluo.rpc.RpcClient.getBatchBuilder ( )

inline

Gets a new record batch builder

Returns: The RPC record batch builder

◆ installTrigger()

void confluo.rpc.RpcClient.installTrigger	(	String	triggerName,
		String	triggerExpr
	)		throws TException

inline

Adds a trigger to the atomic multilog

Parameters

triggerName	The name of the trigger to add
triggerExpr	The trigger expression

Exceptions

TException Cannot add the trigger

◆ numRecords()

long confluo.rpc.RpcClient.numRecords ( ) throws TException

inline

Gets the number of records in the atomic multilog

Returns: The number of records

Exceptions

TException Cannot get the number of records

◆ queryFilter()

RecordStream confluo.rpc.RpcClient.queryFilter	(	String	filterName,
		long	beginMs,
		long	endMs,
		String	filterExpr
	)		throws TException

inline

Queries a filter

Parameters

filterName	The name of the filter
beginMs	The beginning time in milliseconds
endMs	The end time in milliseconds
filterExpr	The filter expression

Returns: A record stream containing the results of the filter

Exceptions

TException Cannot query the filter

◆ readRaw()

ByteBuffer confluo.rpc.RpcClient.readRaw ( long offset ) throws TException

inline

Reads data from a specified offset

Parameters

offset The offset from the log to readRaw from

Returns: The data get the offset

Exceptions

TException Cannot read the record

◆ removeAggregate()

void confluo.rpc.RpcClient.removeAggregate ( String aggregateName ) throws TException

inline

Removes an aggregate from the atomic multilog

Parameters

aggregateName The name of the aggregate

Exceptions

TException Cannot remove the aggregate

◆ removeAtomicMultilog()

void confluo.rpc.RpcClient.removeAtomicMultilog ( ) throws TException

inline

Removes an atomic multilog from the client

Exceptions

TException Cannot remove the atomic multilog

◆ removeFilter()

void confluo.rpc.RpcClient.removeFilter ( String filterName ) throws TException

inline

Removes a filter from the atomic multilog

Parameters

filterName The name of the filter

Exceptions

TException Cannot remove the filter

◆ removeIndex()

void confluo.rpc.RpcClient.removeIndex ( String fieldName ) throws TException

inline

Removes an index from the atomic multilog

Parameters

fieldName The name of the associated field

Exceptions

TException Cannot remove the index

◆ removeTrigger()

void confluo.rpc.RpcClient.removeTrigger ( String triggerName ) throws TException

inline

Removes a trigger from the atomic multilog

Parameters

triggerName The name of the trigger

Exceptions

TException Cannot remove the trigger

◆ setCurrentAtomicMultilog()

void confluo.rpc.RpcClient.setCurrentAtomicMultilog ( String name ) throws TException

inline

Sets the atomic multilog to the desired atomic multilog

Parameters

name	The name of atomic multilog to set the current atomic multilog to

Exceptions

TException Cannot set the atomic multilog

The documentation for this class was generated from the following file:

/Users/anuragk/Work/Projects/Confluo/confluo/javaclient/src/main/java/confluo/rpc/RpcClient.java

Public Member Functions

Detailed Description

Constructor & Destructor Documentation

◆ RpcClient()

Member Function Documentation

◆ addAggregate()

◆ addFilter()

◆ addIndex()

◆ append() [1/2]

◆ append() [2/2]

◆ appendRaw()

◆ close()

◆ createAtomicMultilog() [1/2]

◆ createAtomicMultilog() [2/2]

◆ disconnect()

◆ executeFilter()

◆ getAggregate()

◆ getAlerts()

◆ getBatchBuilder()

◆ installTrigger()

◆ numRecords()

◆ queryFilter()

◆ readRaw()

◆ removeAggregate()

◆ removeAtomicMultilog()

◆ removeFilter()

◆ removeIndex()

◆ removeTrigger()

◆ setCurrentAtomicMultilog()