| |
- ArgumentOutOfRange_swigregister(...)
- ArgumentOutOfRange_throwMyself(...)
- ArgumentOutOfRange_throwMyself(ArgumentOutOfRange self)
- BoolVector___bool__(...)
- BoolVector___bool__(BoolVector self) -> bool
- BoolVector___delitem__(...)
- __delitem__(difference_type i)
BoolVector___delitem__(BoolVector self, PySliceObject slice)
- BoolVector___delslice__(...)
- BoolVector___delslice__(BoolVector self, difference_type i, difference_type j)
- BoolVector___getitem__(...)
- __getitem__(PySliceObject slice) -> BoolVector
BoolVector___getitem__(BoolVector self, difference_type i) -> value_type
- BoolVector___getslice__(...)
- BoolVector___getslice__(BoolVector self, difference_type i, difference_type j) -> BoolVector
- BoolVector___len__(...)
- BoolVector___len__(BoolVector self) -> size_type
- BoolVector___nonzero__(...)
- BoolVector___nonzero__(BoolVector self) -> bool
- BoolVector___setitem__(...)
- __setitem__(PySliceObject slice, BoolVector v)
__setitem__(PySliceObject slice)
BoolVector___setitem__(BoolVector self, difference_type i, value_type x)
- BoolVector___setslice__(...)
- __setslice__(difference_type i, difference_type j, BoolVector v = std::vector< bool,std::allocator< bool > >())
BoolVector___setslice__(BoolVector self, difference_type i, difference_type j)
- BoolVector_append(...)
- BoolVector_append(BoolVector self, value_type x)
- BoolVector_assign(...)
- BoolVector_assign(BoolVector self, size_type n, value_type x)
- BoolVector_back(...)
- BoolVector_back(BoolVector self) -> value_type
- BoolVector_begin(...)
- BoolVector_begin(BoolVector self) -> iterator
- BoolVector_capacity(...)
- BoolVector_capacity(BoolVector self) -> size_type
- BoolVector_clear(...)
- BoolVector_clear(BoolVector self)
- BoolVector_empty(...)
- BoolVector_empty(BoolVector self) -> bool
- BoolVector_end(...)
- BoolVector_end(BoolVector self) -> iterator
- BoolVector_erase(...)
- erase(iterator pos) -> iterator
BoolVector_erase(BoolVector self, iterator first, iterator last) -> iterator
- BoolVector_front(...)
- BoolVector_front(BoolVector self) -> value_type
- BoolVector_get_allocator(...)
- BoolVector_get_allocator(BoolVector self) -> allocator_type
- BoolVector_insert(...)
- insert(iterator pos, value_type x) -> iterator
BoolVector_insert(BoolVector self, iterator pos, size_type n, value_type x)
- BoolVector_iterator(...)
- BoolVector_iterator(BoolVector self) -> SwigPyIterator
- BoolVector_pop(...)
- BoolVector_pop(BoolVector self) -> value_type
- BoolVector_pop_back(...)
- BoolVector_pop_back(BoolVector self)
- BoolVector_push_back(...)
- BoolVector_push_back(BoolVector self, value_type x)
- BoolVector_rbegin(...)
- BoolVector_rbegin(BoolVector self) -> reverse_iterator
- BoolVector_rend(...)
- BoolVector_rend(BoolVector self) -> reverse_iterator
- BoolVector_reserve(...)
- BoolVector_reserve(BoolVector self, size_type n)
- BoolVector_resize(...)
- resize(size_type new_size)
BoolVector_resize(BoolVector self, size_type new_size, value_type x)
- BoolVector_size(...)
- BoolVector_size(BoolVector self) -> size_type
- BoolVector_swap(...)
- BoolVector_swap(BoolVector self, BoolVector v)
- BoolVector_swigregister(...)
- ClientSettings_checkClientExitStatus(...)
- ClientSettings_checkClientExitStatus(ClientSettings self) -> bool
sb::ClientSettings::checkClientExitStatus
Should we check the client exit status.
Returns
-------
if we should check the client exit status
- ClientSettings_getExitStatusTimeout(...)
- ClientSettings_getExitStatusTimeout(ClientSettings self) -> NMSTL::Time
sb::ClientSettings::getExitStatusTimeout
Get the timeout used when sending a request to the server to get the clients
exit status.
Returns
-------
Time (in milliseconds) of the time to wait for the clients exit status
- ClientSettings_getHeartbeatTimeout(...)
- ClientSettings_getHeartbeatTimeout(ClientSettings self) -> NMSTL::Time
sb::ClientSettings::getHeartbeatTimeout
Get the heart beat timeout.
Returns
-------
Time (in milliseconds) the tuple quiesent timeout
- ClientSettings_getMaxDequeuerQueueSize(...)
- ClientSettings_getMaxDequeuerQueueSize(ClientSettings self) -> unsigned int
sb::ClientSettings::getMaxDequeuerQueueSize
- ClientSettings_getMaxInputPacketSize(...)
- ClientSettings_getMaxInputPacketSize(ClientSettings self) -> unsigned int
sb::ClientSettings::getMaxInputPacketSize
Get the maximum size of the input tuple in binary mode.
Returns
-------
max size of the input tuple (in bytes)
- ClientSettings_getMaxTupleBufferCacheSize(...)
- ClientSettings_getMaxTupleBufferCacheSize(ClientSettings self) -> unsigned int
sb::ClientSettings::getMaxTupleBufferCacheSize
- ClientSettings_getOpenTimeout(...)
- ClientSettings_getOpenTimeout(ClientSettings self) -> NMSTL::Time
sb::ClientSettings::getOpenTimeout
Get the timeout used when opening a connection.
Returns
-------
Time (in milliseconds) that the tuple i/o will wait before assuming the server
is down.
- ClientSettings_getReconnectSleep(...)
- ClientSettings_getReconnectSleep(ClientSettings self) -> NMSTL::Time
sb::ClientSettings::getReconnectSleep
Get the amount of time to sleep between reconnect requests.
Returns
-------
Time (in milliseconds) to sleep between reconnect timeouts in the event that the
TupleConnection is disconnected from its server.
- ClientSettings_getWriteTimeout(...)
- ClientSettings_getWriteTimeout(ClientSettings self) -> NMSTL::Time
sb::ClientSettings::getWriteTimeout
Get the timeout used when writing to a connection.
Returns
-------
Time (in milliseconds) that the tuple i/o will wait before assuming the server
is down.
- ClientSettings_getXmlRpcTimeout(...)
- ClientSettings_getXmlRpcTimeout(ClientSettings self) -> NMSTL::Time
sb::ClientSettings::getXmlRpcTimeout
Get the timeout used when making an xmlrpc request.
Returns
-------
Time (in milliseconds) that the tuple i/o will wait before assuming the server
is down.
- ClientSettings_setExitStatusTimeout(...)
- ClientSettings_setExitStatusTimeout(ClientSettings self, NMSTL::Time exitStatusTimeout)
sb::ClientSettings::setExitStatusTimeout
Set the timeout used when sending a request to the server to get the clients
exit status.
Parameters
----------
* `exitStatusTimeout` :
new value (in milliseconds) for the exit status timeout
- ClientSettings_setHeartbeatTimeout(...)
- ClientSettings_setHeartbeatTimeout(ClientSettings self, NMSTL::Time heartbeatTimeout)
sb::ClientSettings::setHeartbeatTimeout
Set the heart beat timeout.
Parameters
----------
* `heartbeatTimeout` :
new value (in milliseconds) for the heartbeat timeout
- ClientSettings_setMaxDequeuerQueueSize(...)
- ClientSettings_setMaxDequeuerQueueSize(ClientSettings self, unsigned int maxDequeuerQueueSize)
sb::ClientSettings::setMaxDequeuerQueueSize
Set the maximum number of tuples to be kept in the Dequeuer Thread's internal
queue before applying back-pressure to the server.
Parameters
----------
* `maxDequeuerQueueSize` :
maximum number of tuples to allow to wait in the Dequeuer Thread's internal
queue before blocking dequeues from the server.
- ClientSettings_setMaxInputPacketSize(...)
- ClientSettings_setMaxInputPacketSize(ClientSettings self, unsigned int maxInputPacketSize)
sb::ClientSettings::setMaxInputPacketSize
Set the maximum size of the input tuple in binary mode.
Parameters
----------
* `maxInputPacketSize` :
new value (in milliseconds) for the maxInputPacket size
- ClientSettings_setOpenTimeout(...)
- ClientSettings_setOpenTimeout(ClientSettings self, NMSTL::Time tupleOpenTimeout)
sb::ClientSettings::setOpenTimeout
Set the timeout used when opening a binary connection.
Parameters
----------
* `tupleOpenTimeout` :
new value (in milliseconds) for the tuple open timeout
- ClientSettings_setReconnectSleep(...)
- ClientSettings_setReconnectSleep(ClientSettings self, NMSTL::Time reconnectSleep)
sb::ClientSettings::setReconnectSleep
Set the amount of time to sleep between reconnect requests.
Parameters
----------
* `reconnectSleep` :
new value (in milliseconds) for reconnect sleep
- ClientSettings_setTcpNoDelay(...)
- ClientSettings_setTcpNoDelay(ClientSettings self, bool tcpNoDelay)
sb::ClientSettings::setTcpNoDelay
Enable/disable TCP_NO_DELAY.
Parameters
----------
* `tcpNoDelay` :
enable/disable TCP_NO_DELAY
- ClientSettings_setWriteTimeout(...)
- ClientSettings_setWriteTimeout(ClientSettings self, NMSTL::Time tupleWriteTimeout)
sb::ClientSettings::setWriteTimeout
Set the timeout used when writing to a connection.
Parameters
----------
* `tupleWriteTimeout` :
new value (in milliseconds) for the tuple write timeout
- ClientSettings_setXmlRpcTimeout(...)
- ClientSettings_setXmlRpcTimeout(ClientSettings self, NMSTL::Time xmlrpcTimeout)
sb::ClientSettings::setXmlRpcTimeout
Set the timeout used when making an xmlrpc request.
Parameters
----------
* `xmlrpcTimeout` :
new value (in milliseconds) for the xmlrpc request timeout
- ClientSettings_swigregister(...)
- ClientSettings_tcpNoDelay(...)
- ClientSettings_tcpNoDelay(ClientSettings self) -> bool
sb::ClientSettings::tcpNoDelay
Is TCP_NODELAY set.
Returns
-------
if tcpNoDealy set
- Client_canDequeue(...)
- Client_canDequeue(Client self) -> bool
sb::StreamBaseClient::canDequeue
Return true if we can call dequeue without blocking.
This means that there is something to dequeue from the server. This dequeued
item could be Tuples, a null (server shutdown) or an exception.
Returns
-------
boolean if we can dequeue without blocking
- Client_checkLicense(...)
- Client_checkLicense(Client self, string featureName) -> bool
- Client_close(...)
- Client_close(Client self)
sb::StreamBaseClient::close
Terminate the client.
May be invoked from a different thread. StreamBaseClient memory, network, and
thread resources are not released until close() is called.
Returns immediately.
- Client_dequeue(...)
- dequeue() -> DequeueResult
Client_dequeue(Client self, int timeout_ms) -> DequeueResult
Dequeue tuples from any subscribed stream
This method blocks until at least one tuple is available on any
subscribed stream, or the StreamBase server is shut down.
- Client_describe(...)
- Client_describe(Client self, string entity) -> string
sb::StreamBaseClient::describe
Returns an XML description of an entity, or an empty string if the method does
not exist.
- Client_doByteSwap(...)
- Client_doByteSwap(Client self) -> bool
- Client_enableBuffering(...)
- enableBuffering(int buffer_size, int flush_interval = DEFAULT_FLUSH_INTERVAL)
Client_enableBuffering(Client self, int buffer_size)
sb::StreamBaseClient::enableBuffering
Turn on buffering. The WakeAndFlushBuffer thread is only started if
flush_interval > 0.
- Client_enableConnectionlessEnqueue(...)
- Client_enableConnectionlessEnqueue(Client self, bool enable)
- Client_enableHeartbeating(...)
- Client_enableHeartbeating(Client self)
sb::StreamBaseClient::enableHeartbeating
Enable heartbeating for this client. Generally this is only for enqueue-only
clients.
- Client_enqueue(...)
- enqueue(string stream_name, Tuple tuple)
enqueue(StreamProperties props, Tuple tuple)
enqueue(string stream_name, TupleList tuples)
Client_enqueue(Client self, StreamProperties props, TupleList tuples)
enqueue(self, string stream_name, (tuple,list,dict) pyTuple)
enqueue(self, StreamProperties props, (tuple,list,dict) pyTuple)
Enqueue tuples to an input stream.
This method may block due to network congestion or StreamBase
server congestion.
If provided a Python tuple, list, or dict, enqueue will attempt to
convert it to a Tuple object using the Schema of the target stream
before sending it to the server.
- Client_flushAllBuffers(...)
- Client_flushAllBuffers(Client self)
sb::StreamBaseClient::flushAllBuffers
Flush any pending enqueue buffers.
This operation has no effect if buffering is not enabled.
Exceptions
----------
* `StreamBaseException` :
if there is an IO error while flushing the buffer
- Client_flushBuffer(...)
- flushBuffer(StreamProperties props)
Client_flushBuffer(Client self, string stream_name)
sb::StreamBaseClient::flushBuffer
Flush any pending enqueue buffer for the stream name provided.
This operation has no effect if buffering is not enabled or there is no buffer
to flush for the given stream. **Note:** Note that this will cause inter-
stream ordering to be interrupted.
Parameters
----------
* `stream_name` :
the stream whose enqueue buffers to flush, if not empty
Exceptions
----------
* `StreamBaseException` :
if there is an IO error while flushing the buffer
Deprecated
stream_name use StreamProperties based flushBuffer
use flushAllBuffers() to preserve inter-stream ordering
- Client_getBufferSize(...)
- Client_getBufferSize(Client self) -> int
sb::StreamBaseClient::getBufferSize
Return buffer size (in tuples)
- Client_getConnectionID(...)
- Client_getConnectionID(Client self) -> string
sb::StreamBaseClient::getConnectionID
Return the Connection ID for this Client Connection.
Only Valid once an enqueue/dequeue has been attempted.
Returns
-------
connection ID in binary format
- Client_getConnectionIdAsHexString(...)
- Client_getConnectionIdAsHexString(Client self) -> string
sb::StreamBaseClient::getConnectionIdAsHexString
Return the Connection ID for this Client Connection.
Only Valid once an enqueue/dequeue has been attempted.
Returns
-------
connection ID in Hexadecimal format
- Client_getDynamicVariables(...)
- Client_getDynamicVariables(Client self, string modulePath) -> Tuple
sb::StreamBaseClient::getDynamicVariables
Get all the dynamic variables in the given module, and return them as a Tuple
where the field names are the names of the dynamic variables, and the field
values are the current values of the dynamic variables.
Exceptions
----------
* `StreamBaseException` :
on network or other errors, or if there are no dynamic variables in the
named module
- Client_getIsBuffering(...)
- Client_getIsBuffering(Client self) -> bool
sb::StreamBaseClient::getIsBuffering
Return whether buffering is turned on or off.
- Client_getIsConnectionlessEnqueue(...)
- Client_getIsConnectionlessEnqueue(Client self) -> bool
- Client_getSchemaByHash(...)
- Client_getSchemaByHash(Client self, string hash) -> Schema
sb::StreamBaseClient::getSchemaByHash
Returns a schema with a particular hash.
- Client_getSchemaByName(...)
- Client_getSchemaByName(Client self, string name) -> Schema
sb::StreamBaseClient::getSchemaByName
Returns a schema by name.
This will only succeed for named schemas; anonymous schemas assigned to a port
should instead be looked up via getStreamProperties().getSchema().
- Client_getSchemaForStream(...)
- getSchemaForStream(string entity, CaptureTransformStrategy strategy = FLATTEN) -> Schema
Client_getSchemaForStream(Client self, string entity) -> Schema
sb::StreamBaseClient::getSchemaForStream
Returns the schema of a stream, throwing an exception if the stream does not
exist.
- Client_getSettings(...)
- Client_getSettings(Client self) -> ClientSettings
sb::StreamBaseClient::getSettings
Get the settings for the client.
- Client_getStreamProperties(...)
- getStreamProperties(string entity, CaptureTransformStrategy strategy = FLATTEN) -> StreamProperties
Client_getStreamProperties(Client self, string entity) -> StreamProperties
sb::StreamBaseClient::getStreamProperties
Returns a description of a stream, throwing an exception if the stream does not
exist.
Parameters
----------
* `entity` :
the path of the stream
* `strategy` :
how to handle capture fields on the stream
- Client_getStreamPropertiesByHash(...)
- Client_getStreamPropertiesByHash(Client self, string hex) -> StreamProperties
sb::StreamBaseClient::getStreamPropertiesByHash
Returns a description of a stream, throwing an exception if the stream does not
exist.
- Client_getTupleDequeueCount(...)
- Client_getTupleDequeueCount(Client self) -> long long
sb::StreamBaseClient::getTupleDequeueCount
Returns the number of tuples this client has dequeued from the server.
This number does not include tuples that may be dequeued as part of system
services such as heartbeating. This number does however include tuples that have
been dequeued but have been intercepted by the Interceptor.
- Client_getTupleEnqueueCount(...)
- Client_getTupleEnqueueCount(Client self) -> long long
sb::StreamBaseClient::getTupleEnqueueCount
Returns the number of tuples this client has actually enqueued to the server.
Note that this number will not include any tuples that have been buffered but
have not actually been enqueued to the server.
- Client_getURI(...)
- Client_getURI(Client self) -> URI
sb::StreamBaseClient::getURI
Return the URI we're talking to.
- Client_getURIs(...)
- Client_getURIs(Client self) -> URIVector
sb::StreamBaseClient::getURIs
- Client_getVersion(...)
- Client_getVersion(Client self) -> string
sb::StreamBaseClient::getVersion
Returns the client version as a string.
- Client_internalCommand(...)
- Client_internalCommand(Client self, StringVector arguments)
- Client_isClosed(...)
- Client_isClosed(Client self) -> bool
sb::StreamBaseClient::isClosed
Return true if the client connection is closed.
The client connection can be closed by calling the close() method, or by a
server shutdown, or a network error.
- Client_isConnected(...)
- Client_isConnected(Client self) -> bool
sb::StreamBaseClient::isConnected
Returns true if this TupleConnections has any live connections to a server.
Note that a return of "false" doesn't necessarily indicate an error since the
TupleConnection's state (e.g., lack of subscriptions) might mean no connections
are needed.
Returns
-------
boolean if we are connected
- Client_isStreamSubscribed(...)
- Client_isStreamSubscribed(Client self, string entity) -> bool
sb::StreamBaseClient::isStreamSubscribed
Returns true if this stream has been subscribed to.
Parameters
----------
* `entity` :
the path of the stream
- Client_listEntities(...)
- listEntities(string type, int flags)
listEntities(Type type, int flags)
Client_listEntities(Client self, Type type)
sb::StreamBaseClient::listEntities
Lists all entities of a particular type.
(One can then use "describe" to obtain a description of an entity.) names is
cleared first.
- Client_operatorStatus(...)
- Client_operatorStatus(Client self, string containerName)
-> a list of the the statuses of Java operators and adapters as strings
- Client_readTable(...)
- readTable(string tablePath, int limit, string predicate = "") -> TupleList
Client_readTable(Client self, string tablePath, int limit) -> TupleList
sb::StreamBaseClient::readTable
Read rows out of the table at this path.
Limit to the specified number of rows returned, or -1 for no limit. Filter rows
according to predicate, or return all rows if predicate is empty.
Returns
-------
a list of matching rows.
- Client_resubscribe(...)
- resubscribe(string stream_name, string logical_stream, string predicate) -> StreamProperties
Client_resubscribe(Client self, StreamProperties props, string logical_stream,
string predicate) -> StreamProperties
sb::StreamBaseClient::resubscribe
Resubscribes to an already subscribed stream.
Returns
-------
the StreamProperties for the stream
- Client_setDynamicVariable(...)
- Client_setDynamicVariable(Client self, string dynamicVariablePath, string value)
sb::StreamBaseClient::setDynamicVariable
Set the dynamic variable at the given path to the given value, expressed as a
string in CSV style.
Exceptions
----------
* `StreamBaseException` :
if the dynamic variable does not exist, or the value is not appropriate for
setting the dynamic variable
- Client_setQuiescentLimit(...)
- Client_setQuiescentLimit(Client self, int timeoutMS) -> int
sb::StreamBaseClient::setQuiescentLimit
Sets how many milliseconds a dequeueing client will tolerate not receiving a
client heart beat from the StreamBase server that it is connected to.
The default value is 120 seconds (120000). By default, StreamBase servers emit
"client heart beats" every 10 seconds so StreamBase applications have no
requirement to send data regularly.
Parameters
----------
* `timeoutMS` :
The number of milliseconds that is allowed to pass without receiving a
message from the StreamBase server client heart beat stream.
- Client_status(...)
- status(bool verbose = False)
Client_status(Client self)
sb::StreamBaseClient::status
status the streambase daemons
- Client_subscribe(...)
- subscribe(string stream_name) -> StreamProperties
subscribe(StreamProperties props) -> StreamProperties
subscribe(string stream_name, string logical_stream, string predicate) -> StreamProperties
Client_subscribe(Client self, StreamProperties props, string logical_stream,
string predicate) -> StreamProperties
sb::StreamBaseClient::subscribe
Subscribes to a stream with a predicate to apply to output tuples.
The stream name of dequeued tuples is logical_stream. When unsubscribing, use
logical_stream.
Parameters
----------
* `props` :
the stream to subscribe to, error if empty
* `logical_stream` :
the name of the logical stream to associate with this predicate (if empty,
defaults to streamname)
* `predicate` :
a predicate to apply to subset the stream, error if empty
Returns
-------
the StreamProperties for the stream
- Client_swigregister(...)
- Client_typecheck(...)
- typecheck(string sbapp, bool full = False)
Client_typecheck(Client self, string sbapp)
sb::StreamBaseClient::typecheck
Typechecks a potential modification to the application, outputting properties of
all streams in the application.
streams is cleared first.
Parameters
----------
* `sbapp` :
the application
* `streams` :
the schema defs of the streams
* `full` :
do a full typecheck
- Client_unsubscribe(...)
- unsubscribe(string stream_name)
Client_unsubscribe(Client self, StreamProperties props)
sb::StreamBaseClient::unsubscribe
UnSubscribes to a stream.
Note: Any tuples that are in-flight during an unsubscribe request will be
dequeued until the stream is fully drained.
- Client_useRawTuples_get(...)
- Client_useRawTuples_set(...)
- CompleteDataType___eq__(...)
- x.__eq__(y) <==> x==y
- CompleteDataType___ge__(...)
- x.__ge__(y) <==> x>=y
- CompleteDataType___gt__(...)
- x.__gt__(y) <==> x>y
- CompleteDataType___le__(...)
- x.__le__(y) <==> x<=y
- CompleteDataType___lt__(...)
- x.__lt__(y) <==> x<y
- CompleteDataType___ne__(...)
- x.__ne__(y) <==> x!=y
- CompleteDataType___nonzero__(...)
- x.__nonzero__() <==> x != 0
- CompleteDataType___str__(...)
- x.__str__() <==> str(x)
sb::CompleteDataType::as_string
Returns a string representation of this CompleteDataType.
- CompleteDataType_compare(...)
- CompleteDataType_compare(CompleteDataType self, CompleteDataType fv) -> int
sb::CompleteDataType::compare
Compare the current CompleteDataType against the provided CompleteDataType by
base type (eg DataType::BOOL, INT, ::TUPLE, etc).
Therefore, for example a LIST of type INT and a LIST of type TUPLE are equal.
Returns
-------
-1 if the current CompleteDataType is less than the provided CompleteDataType, 0
if the current is equal to the provided CompleteDataType, and 1 if the current
is greater than the provided CompleteDataType.
- CompleteDataType_forBlob(...)
- CompleteDataType_forBlob() -> CompleteDataType
sb::CompleteDataType::forBlob
Return a CompleteDataType of type DataType::BLOB.
- CompleteDataType_forBool(...)
- CompleteDataType_forBool() -> CompleteDataType
sb::CompleteDataType::forBool
Return a CompleteDataType of type DataType::BOOL.
- CompleteDataType_forCapture(...)
- CompleteDataType_forCapture(string captureName) -> CompleteDataType
sb::CompleteDataType::forCapture
Return a CompleteDataType of type DataType::CAPTURE with the given capture type
name.
- CompleteDataType_forDouble(...)
- CompleteDataType_forDouble() -> CompleteDataType
sb::CompleteDataType::forDouble
Return a CompleteDataType of type DataType::DOUBLE.
- CompleteDataType_forFunction(...)
- CompleteDataType_forFunction(Schema argumentSchema, CompleteDataType returnType) -> CompleteDataType
sb::CompleteDataType::forFunction
Return a CompleteDataType of type DataType::FUNCTION with the given argument
schema and return type.
- CompleteDataType_forInt(...)
- CompleteDataType_forInt() -> CompleteDataType
sb::CompleteDataType::forInt
Return a CompleteDataType of type DataType::INT.
- CompleteDataType_forList(...)
- CompleteDataType_forList(CompleteDataType elemType) -> CompleteDataType
sb::CompleteDataType::forList
Return a CompleteDataType of type DataType::LIST with the given CompleteDataType
as the type of its elements.
- CompleteDataType_forLong(...)
- CompleteDataType_forLong() -> CompleteDataType
sb::CompleteDataType::forLong
Return a CompleteDataType of type DataType::LONG.
- CompleteDataType_forSimpleType(...)
- CompleteDataType_forSimpleType(DataType type) -> CompleteDataType
sb::CompleteDataType::forSimpleType
Convenience method.
Return the CompleteDataType appropriate to the given DataType. Invalid on
DataType::TUPLE and DataType::LIST, since they require extra information to
fully specify their CompleteDataType.
- CompleteDataType_forString(...)
- CompleteDataType_forString() -> CompleteDataType
sb::CompleteDataType::forString
Return a CompleteDataType of type DataType::STRING.
- CompleteDataType_forTimestamp(...)
- CompleteDataType_forTimestamp() -> CompleteDataType
sb::CompleteDataType::forTimestamp
Return a CompleteDataType of type DataType::TIMESTAMP.
- CompleteDataType_forTuple(...)
- CompleteDataType_forTuple(Schema s) -> CompleteDataType
sb::CompleteDataType::forTuple
Return a CompleteDataType of type DataType::TUPLE with the given Schema.
- CompleteDataType_getArgumentSchema(...)
- CompleteDataType_getArgumentSchema(CompleteDataType self) -> Schema
If this CompleteDataType has an argument schema, returns it
For all other types, returns None.
- CompleteDataType_getCaptureTypeName(...)
- CompleteDataType_getCaptureTypeName(CompleteDataType self) -> string
sb::CompleteDataType::getCaptureTypeName
- CompleteDataType_getElementCompleteType(...)
- CompleteDataType_getElementCompleteType(CompleteDataType self) -> CompleteDataType
If this CompleteDataType has an element type, returns the element's
CompleteDataType. For all other types, returns None.
- CompleteDataType_getReturnType(...)
- CompleteDataType_getReturnType(CompleteDataType self) -> CompleteDataType
If this CompleteDataType has a return type, returns it as a
CompleteDataType. For all other types, returns None.
- CompleteDataType_getSchema(...)
- CompleteDataType_getSchema(CompleteDataType self) -> Schema
sb::CompleteDataType::getSchema
If this CompleteDataType has a nested tuple, return its Schema.
For all other types, return a null Schema.
- CompleteDataType_getType(...)
- CompleteDataType_getType(CompleteDataType self) -> DataType
sb::CompleteDataType::getType
Return the primitive DataType of the CompleteDataType.
- CompleteDataType_hasElementType(...)
- CompleteDataType_hasElementType(CompleteDataType self) -> bool
sb::CompleteDataType::hasElementType
Returns true if this CompleteDataType has an element CompleteDataType (eg it is
a DataType::LIST of DataType::INTs, the latter being its element type).
- CompleteDataType_hasSchema(...)
- CompleteDataType_hasSchema(CompleteDataType self) -> bool
sb::CompleteDataType::hasSchema
Returns true if this CompleteDataType contains a Schema (eg it is a
DataType::TUPLE).
- CompleteDataType_swigregister(...)
- DataType___int__(...)
- x.__int__() <==> int(x)
- DataType___str__(...)
- x.__str__() <==> str(x)
sb::DataType::as_string
Return a string representation of the data type.
- DataType_getSize(...)
- DataType_getSize(DataType self) -> size_t
sb::DataType::getSize
- DataType_isFixedSize(...)
- DataType_isFixedSize(DataType type) -> bool
sb::DataType::isFixedSize
Return false if the type is variable-length (e.g., STRING or BLOB)
- DataType_swigregister(...)
- DequeueResult_getLeadershipStatus(...)
- DequeueResult_getLeadershipStatus(DequeueResult self) -> LeadershipStatus
sb::DequeueResult::getLeadershipStatus
Return the leadership status of the server that produced this dequeue result.
- DequeueResult_getServerURI(...)
- DequeueResult_getServerURI(DequeueResult self) -> URI
Returns the URI of the server that produced these results.
- DequeueResult_getStatus(...)
- DequeueResult_getStatus(DequeueResult self) -> Status
sb::DequeueResult::getStatus
Return the status of this DequeueResult.
DequeueResult::GOOD means the DequeueResult contains tuples.
Returns
-------
the status of this DequeueResult
- DequeueResult_getStreamName(...)
- DequeueResult_getStreamName(DequeueResult self) -> string
sb::DequeueResult::getStreamName
Returns the name of the stream on which tuples were dequeued.
- DequeueResult_getStreamProperties(...)
- DequeueResult_getStreamProperties(DequeueResult self) -> StreamProperties
Returns the StreamProperties for this DequeueResult.
- DequeueResult_getTuple(...)
- DequeueResult_getTuple(DequeueResult self, int index) -> Tuple
Returns the index'th tuple.
- DequeueResult_getTupleCount(...)
- DequeueResult_getTupleCount(DequeueResult self) -> int
sb::DequeueResult::getTupleCount
Returns the number of tuples dequeued.
- DequeueResult_getTuples(...)
- DequeueResult_getTuples(DequeueResult self) -> TupleList
Returns the list of tuples.
- DequeueResult_reuseTuple(...)
- DequeueResult_reuseTuple(DequeueResult self)
sb::DequeueResult::reuseTuple
Currently a no-op maintained for backwards compatibility.
Deprecated
- DequeueResult_swigregister(...)
- DoubleVector___bool__(...)
- DoubleVector___bool__(DoubleVector self) -> bool
- DoubleVector___delitem__(...)
- __delitem__(difference_type i)
DoubleVector___delitem__(DoubleVector self, PySliceObject slice)
- DoubleVector___delslice__(...)
- DoubleVector___delslice__(DoubleVector self, difference_type i, difference_type j)
- DoubleVector___getitem__(...)
- __getitem__(PySliceObject slice) -> DoubleVector
DoubleVector___getitem__(DoubleVector self, difference_type i) -> value_type
- DoubleVector___getslice__(...)
- DoubleVector___getslice__(DoubleVector self, difference_type i, difference_type j) -> DoubleVector
- DoubleVector___len__(...)
- DoubleVector___len__(DoubleVector self) -> size_type
- DoubleVector___nonzero__(...)
- DoubleVector___nonzero__(DoubleVector self) -> bool
- DoubleVector___setitem__(...)
- __setitem__(PySliceObject slice, DoubleVector v)
__setitem__(PySliceObject slice)
DoubleVector___setitem__(DoubleVector self, difference_type i, value_type x)
- DoubleVector___setslice__(...)
- __setslice__(difference_type i, difference_type j, DoubleVector v = std::vector< double,std::allocator< double > >())
DoubleVector___setslice__(DoubleVector self, difference_type i, difference_type j)
- DoubleVector_append(...)
- DoubleVector_append(DoubleVector self, value_type x)
- DoubleVector_assign(...)
- DoubleVector_assign(DoubleVector self, size_type n, value_type x)
- DoubleVector_back(...)
- DoubleVector_back(DoubleVector self) -> value_type
- DoubleVector_begin(...)
- DoubleVector_begin(DoubleVector self) -> iterator
- DoubleVector_capacity(...)
- DoubleVector_capacity(DoubleVector self) -> size_type
- DoubleVector_clear(...)
- DoubleVector_clear(DoubleVector self)
- DoubleVector_empty(...)
- DoubleVector_empty(DoubleVector self) -> bool
- DoubleVector_end(...)
- DoubleVector_end(DoubleVector self) -> iterator
- DoubleVector_erase(...)
- erase(iterator pos) -> iterator
DoubleVector_erase(DoubleVector self, iterator first, iterator last) -> iterator
- DoubleVector_front(...)
- DoubleVector_front(DoubleVector self) -> value_type
- DoubleVector_get_allocator(...)
- DoubleVector_get_allocator(DoubleVector self) -> allocator_type
- DoubleVector_insert(...)
- insert(iterator pos, value_type x) -> iterator
DoubleVector_insert(DoubleVector self, iterator pos, size_type n, value_type x)
- DoubleVector_iterator(...)
- DoubleVector_iterator(DoubleVector self) -> SwigPyIterator
- DoubleVector_pop(...)
- DoubleVector_pop(DoubleVector self) -> value_type
- DoubleVector_pop_back(...)
- DoubleVector_pop_back(DoubleVector self)
- DoubleVector_push_back(...)
- DoubleVector_push_back(DoubleVector self, value_type x)
- DoubleVector_rbegin(...)
- DoubleVector_rbegin(DoubleVector self) -> reverse_iterator
- DoubleVector_rend(...)
- DoubleVector_rend(DoubleVector self) -> reverse_iterator
- DoubleVector_reserve(...)
- DoubleVector_reserve(DoubleVector self, size_type n)
- DoubleVector_resize(...)
- resize(size_type new_size)
DoubleVector_resize(DoubleVector self, size_type new_size, value_type x)
- DoubleVector_size(...)
- DoubleVector_size(DoubleVector self) -> size_type
- DoubleVector_swap(...)
- DoubleVector_swap(DoubleVector self, DoubleVector v)
- DoubleVector_swigregister(...)
- EntityType___str__(...)
- x.__str__() <==> str(x)
sb::StreamBaseEntityType::as_string
Return a string naming the entity type.
- EntityType_as_enum(...)
- as_enum(string aType, bool allow_plural = False) -> Type
EntityType_as_enum(string aType) -> Type
sb::StreamBaseEntityType::as_enum
Parse a string as an entity type.
Parameters
----------
* `aType` :
the string to parse
* `allow_plural` :
true if a plural version of the entity types (e.g., "streams" instead of
"stream") is allowed
Exceptions
----------
* `StreamBaseException` :
if the entity type cannot be parsed
- EntityType_swigregister(...)
- Errors_swigregister(...)
- FieldValueVector___bool__(...)
- FieldValueVector___bool__(FieldValueVector self) -> bool
- FieldValueVector___delitem__(...)
- __delitem__(difference_type i)
FieldValueVector___delitem__(FieldValueVector self, PySliceObject slice)
- FieldValueVector___delslice__(...)
- FieldValueVector___delslice__(FieldValueVector self, difference_type i, difference_type j)
- FieldValueVector___getitem__(...)
- __getitem__(PySliceObject slice) -> FieldValueVector
FieldValueVector___getitem__(FieldValueVector self, difference_type i) -> value_type
- FieldValueVector___getslice__(...)
- FieldValueVector___getslice__(FieldValueVector self, difference_type i, difference_type j) -> FieldValueVector
- FieldValueVector___len__(...)
- FieldValueVector___len__(FieldValueVector self) -> size_type
- FieldValueVector___nonzero__(...)
- FieldValueVector___nonzero__(FieldValueVector self) -> bool
- FieldValueVector___setitem__(...)
- __setitem__(PySliceObject slice, FieldValueVector v)
__setitem__(PySliceObject slice)
FieldValueVector___setitem__(FieldValueVector self, difference_type i, value_type x)
- FieldValueVector___setslice__(...)
- __setslice__(difference_type i, difference_type j, FieldValueVector v = std::vector< sb::FieldValue,std::allocator< sb::FieldValue > >())
FieldValueVector___setslice__(FieldValueVector self, difference_type i, difference_type j)
- FieldValueVector_append(...)
- FieldValueVector_append(FieldValueVector self, value_type x)
- FieldValueVector_assign(...)
- FieldValueVector_assign(FieldValueVector self, size_type n, value_type x)
- FieldValueVector_back(...)
- FieldValueVector_back(FieldValueVector self) -> value_type
- FieldValueVector_begin(...)
- FieldValueVector_begin(FieldValueVector self) -> iterator
- FieldValueVector_capacity(...)
- FieldValueVector_capacity(FieldValueVector self) -> size_type
- FieldValueVector_clear(...)
- FieldValueVector_clear(FieldValueVector self)
- FieldValueVector_empty(...)
- FieldValueVector_empty(FieldValueVector self) -> bool
- FieldValueVector_end(...)
- FieldValueVector_end(FieldValueVector self) -> iterator
- FieldValueVector_erase(...)
- erase(iterator pos) -> iterator
FieldValueVector_erase(FieldValueVector self, iterator first, iterator last) -> iterator
- FieldValueVector_front(...)
- FieldValueVector_front(FieldValueVector self) -> value_type
- FieldValueVector_get_allocator(...)
- FieldValueVector_get_allocator(FieldValueVector self) -> allocator_type
- FieldValueVector_insert(...)
- insert(iterator pos, value_type x) -> iterator
FieldValueVector_insert(FieldValueVector self, iterator pos, size_type n, value_type x)
- FieldValueVector_iterator(...)
- FieldValueVector_iterator(FieldValueVector self) -> SwigPyIterator
- FieldValueVector_pop(...)
- FieldValueVector_pop(FieldValueVector self) -> value_type
- FieldValueVector_pop_back(...)
- FieldValueVector_pop_back(FieldValueVector self)
- FieldValueVector_push_back(...)
- FieldValueVector_push_back(FieldValueVector self, value_type x)
- FieldValueVector_rbegin(...)
- FieldValueVector_rbegin(FieldValueVector self) -> reverse_iterator
- FieldValueVector_rend(...)
- FieldValueVector_rend(FieldValueVector self) -> reverse_iterator
- FieldValueVector_reserve(...)
- FieldValueVector_reserve(FieldValueVector self, size_type n)
- FieldValueVector_resize(...)
- resize(size_type new_size)
FieldValueVector_resize(FieldValueVector self, size_type new_size, value_type x)
- FieldValueVector_size(...)
- FieldValueVector_size(FieldValueVector self) -> size_type
- FieldValueVector_swap(...)
- FieldValueVector_swap(FieldValueVector self, FieldValueVector v)
- FieldValueVector_swigregister(...)
- FieldValue___eq__(...)
- x.__eq__(y) <==> x==y
- FieldValue___ge__(...)
- x.__ge__(y) <==> x>=y
- FieldValue___gt__(...)
- x.__gt__(y) <==> x>y
- FieldValue___le__(...)
- x.__le__(y) <==> x<=y
- FieldValue___lt__(...)
- x.__lt__(y) <==> x<y
- FieldValue___ne__(...)
- x.__ne__(y) <==> x!=y
- FieldValue___str__(...)
- x.__str__() <==> str(x)
sb::FieldValue::as_string
Return a string representation of this FieldValue.
- FieldValue_compare(...)
- FieldValue_compare(FieldValue self, FieldValue fv) -> int
sb::FieldValue::compare
Compare the current FieldValue against the provided FieldValue.
Null FieldValues are less than non-null FieldValues. Provides a total ordering
over the set of possible FieldValues, so does not check types. Ordering of
FieldValues of heterogeneous types is not guaranteed but is consistent.
Returns
-------
-1 if the current FieldValue is less than the provided FieldValue, 0 if the
current is equal to the provided FieldValue, and 1 if the current is greater
than the provided FieldValue.
- FieldValue_forLong(...)
- FieldValue_forLong(long long val) -> FieldValue
- FieldValue_getBlob(...)
- FieldValue_getBlob(FieldValue self) -> string
sb::FieldValue::getBlob
Return the value of a blob FieldValue as a string.
Will throw an exception if this FieldValue is not of type DataType::BLOB.
- FieldValue_getBool(...)
- FieldValue_getBool(FieldValue self) -> bool
sb::FieldValue::getBool
Return the value of a boolean FieldValue.
Will throw an exception if this FieldValue is not of type DataType::BOOL.
- FieldValue_getCapture(...)
- FieldValue_getCapture(FieldValue self) -> string
sb::FieldValue::getCapture
Return the value of a Capture FieldValue, as a string Will throw an exception if
this FieldValue is not of type DataType::CAPTURE.
- FieldValue_getCompleteType(...)
- FieldValue_getCompleteType(FieldValue self) -> CompleteDataType
Returns the CompleteDataType of this FieldValue.
- FieldValue_getDouble(...)
- FieldValue_getDouble(FieldValue self) -> double
sb::FieldValue::getDouble
Return the value of a double FieldValue.
Will throw an exception if this FieldValue is not of type DataType::DOUBLE.
- FieldValue_getFalse(...)
- FieldValue_getFalse() -> FieldValue
- FieldValue_getFunction(...)
- FieldValue_getFunction(FieldValue self) -> Function
sb::FieldValue::getFunction
Return the value of a Function FieldValue Will throw an exception if this
FieldValue is not of type DataType::FUNCTION.
- FieldValue_getInt(...)
- FieldValue_getInt(FieldValue self) -> int
sb::FieldValue::getInt
Return the value of an integer FieldValue.
Will throw an exception if this FieldValue is not of type DataType::INT.
- FieldValue_getList(...)
- FieldValue_getList(FieldValue self) -> FieldValueVector
Returns the value of a List FieldValue.
- FieldValue_getLong(...)
- FieldValue_getLong(FieldValue self) -> long long
sb::FieldValue::getLong
Return the value of a long FieldValue.
Will throw an exception if this FieldValue is not of type DataType::LONG.
- FieldValue_getSize(...)
- FieldValue_getSize(FieldValue self) -> size_t
- FieldValue_getString(...)
- FieldValue_getString(FieldValue self) -> string
sb::FieldValue::getString
Return the value of a string FieldValue.
Will throw an exception if this FieldValue is not of type DataType::STRING.
- FieldValue_getTimestamp(...)
- FieldValue_getTimestamp(FieldValue self) -> Timestamp
sb::FieldValue::getTimestamp
Return the value of a Timestamp FieldValue as a Timestamp.
Will throw an exception if this FieldValue is not of type DataType::TIMESTAMP.
- FieldValue_getTrue(...)
- FieldValue_getTrue() -> FieldValue
- FieldValue_getTuple(...)
- FieldValue_getTuple(FieldValue self) -> Tuple
Returns the value of a Tuple FieldValue.
- FieldValue_getType(...)
- FieldValue_getType(FieldValue self) -> DataType
sb::FieldValue::getType
Get the primitive DataType of this FieldValue.
- FieldValue_isNull(...)
- FieldValue_isNull(FieldValue self) -> bool
sb::FieldValue::isNull
Return true if this FieldValue represents a null value.
- FieldValue_sameType(...)
- FieldValue_sameType(FieldValue self, FieldValue fv) -> bool
sb::FieldValue::sameType
Returns true if this FieldValue and the provided FieldValue are of the same
type.
"Of the same type" is defined as their CompleteDataType members being
equivalent.
- FieldValue_swigregister(...)
- FieldValue_toCSVString(...)
- FieldValue_toCSVString(FieldValue self, char delim, string null_string, char quote) -> string
- FieldValue_toDelimitedString(...)
- FieldValue_toDelimitedString(FieldValue self, string delimiter, string null_string,
bool include_names, bool quote_all_strings) -> string
- FieldVector___bool__(...)
- FieldVector___bool__(FieldVector self) -> bool
- FieldVector___delitem__(...)
- __delitem__(difference_type i)
FieldVector___delitem__(FieldVector self, PySliceObject slice)
- FieldVector___delslice__(...)
- FieldVector___delslice__(FieldVector self, difference_type i, difference_type j)
- FieldVector___getitem__(...)
- __getitem__(PySliceObject slice) -> FieldVector
FieldVector___getitem__(FieldVector self, difference_type i) -> value_type
- FieldVector___getslice__(...)
- FieldVector___getslice__(FieldVector self, difference_type i, difference_type j) -> FieldVector
- FieldVector___len__(...)
- FieldVector___len__(FieldVector self) -> size_type
- FieldVector___nonzero__(...)
- FieldVector___nonzero__(FieldVector self) -> bool
- FieldVector___setitem__(...)
- __setitem__(PySliceObject slice, FieldVector v)
__setitem__(PySliceObject slice)
FieldVector___setitem__(FieldVector self, difference_type i, value_type x)
- FieldVector___setslice__(...)
- __setslice__(difference_type i, difference_type j, FieldVector v = std::vector< sb::Field,std::allocator< sb::Field > >())
FieldVector___setslice__(FieldVector self, difference_type i, difference_type j)
- FieldVector_append(...)
- FieldVector_append(FieldVector self, value_type x)
- FieldVector_assign(...)
- FieldVector_assign(FieldVector self, size_type n, value_type x)
- FieldVector_back(...)
- FieldVector_back(FieldVector self) -> value_type
- FieldVector_begin(...)
- FieldVector_begin(FieldVector self) -> iterator
- FieldVector_capacity(...)
- FieldVector_capacity(FieldVector self) -> size_type
- FieldVector_clear(...)
- FieldVector_clear(FieldVector self)
- FieldVector_empty(...)
- FieldVector_empty(FieldVector self) -> bool
- FieldVector_end(...)
- FieldVector_end(FieldVector self) -> iterator
- FieldVector_erase(...)
- erase(iterator pos) -> iterator
FieldVector_erase(FieldVector self, iterator first, iterator last) -> iterator
- FieldVector_front(...)
- FieldVector_front(FieldVector self) -> value_type
- FieldVector_get_allocator(...)
- FieldVector_get_allocator(FieldVector self) -> allocator_type
- FieldVector_insert(...)
- insert(iterator pos, value_type x) -> iterator
FieldVector_insert(FieldVector self, iterator pos, size_type n, value_type x)
- FieldVector_iterator(...)
- FieldVector_iterator(FieldVector self) -> SwigPyIterator
- FieldVector_pop(...)
- FieldVector_pop(FieldVector self) -> value_type
- FieldVector_pop_back(...)
- FieldVector_pop_back(FieldVector self)
- FieldVector_push_back(...)
- FieldVector_push_back(FieldVector self, value_type x)
- FieldVector_rbegin(...)
- FieldVector_rbegin(FieldVector self) -> reverse_iterator
- FieldVector_rend(...)
- FieldVector_rend(FieldVector self) -> reverse_iterator
- FieldVector_reserve(...)
- FieldVector_reserve(FieldVector self, size_type n)
- FieldVector_resize(...)
- resize(size_type new_size)
FieldVector_resize(FieldVector self, size_type new_size, value_type x)
- FieldVector_size(...)
- FieldVector_size(FieldVector self) -> size_type
- FieldVector_swap(...)
- FieldVector_swap(FieldVector self, FieldVector v)
- FieldVector_swigregister(...)
- Field___str__(...)
- x.__str__() <==> str(x)
sb::Field::as_string
Returns a string representation of a field.
- Field_as_xml(...)
- Field_as_xml(Field self) -> string
- Field_getArgumentSchema(...)
- Field_getArgumentSchema(Field self) -> Schema
sb::Field::getArgumentSchema
- Field_getCompleteType(...)
- Field_getCompleteType(Field self) -> CompleteDataType
sb::Field::getCompleteType
Returns the complete type of a field (e.g., DataType::LIST of DataType::INTs).
- Field_getElementCompleteType(...)
- Field_getElementCompleteType(Field self) -> CompleteDataType
sb::Field::getElementCompleteType
Returns the complete type of a field's elements (e.g., on a DataType::LIST of
DataType::INTs, returns a CompleteDataType of DataType::INT).
- Field_getFieldPath(...)
- Field_getFieldPath(Field self) -> FieldVector
sb::Field::getFieldPath
- Field_getFixedSize(...)
- Field_getFixedSize(Field self) -> size_t
sb::Field::getFixedSize
Returns the size of a field if it has a fixed size or -1.
- Field_getIndex(...)
- Field_getIndex(Field self) -> int
sb::Field::getIndex
Returns the index of the field.
- Field_getName(...)
- Field_getName(Field self) -> string
sb::Field::getName
Returns the name of a field.
- Field_getReturnType(...)
- Field_getReturnType(Field self) -> CompleteDataType
sb::Field::getReturnType
- Field_getSchema(...)
- Field_getSchema(Field self) -> Schema
sb::Field::getSchema
Returns the field's schema (valid only if the field's type is TUPLE)
- Field_getType(...)
- Field_getType(Field self) -> DataType
sb::Field::getType
Returns the type of a field (e.g., DataType::INT).
- Field_sameType(...)
- Field_sameType(Field self, Field other) -> bool
sb::Field::sameType
Return true if the fields are the same type (including size information)
- Field_swigregister(...)
- Function_compare(...)
- Function_compare(Function self, Function f) -> int
- Function_getBody(...)
- Function_getBody(Function self) -> string
Returns the body of the function.
- Function_getEnvironment(...)
- Function_getEnvironment(Function self) -> Tuple
Returns a Tuple representing the environment against which the function body is evaluated.
- Function_getFunctionDefinition(...)
- Function_getFunctionDefinition(Function self) -> string
- Function_getInFieldTransformer(...)
- Function_getInFieldTransformer(Function self) -> string
- Function_getInnerType(...)
- Function_getInnerType(Function self) -> CompleteDataType
- Function_getName(...)
- Function_getName(Function self) -> string
Returns the name of the function.
- Function_getOutFieldTransformer(...)
- Function_getOutFieldTransformer(Function self) -> string
- Function_getType(...)
- Function_getType(Function self) -> CompleteDataType
- Function_isCoerced(...)
- Function_isCoerced(Function self) -> bool
- Function_swigregister(...)
- IntVector___bool__(...)
- IntVector___bool__(IntVector self) -> bool
- IntVector___delitem__(...)
- __delitem__(difference_type i)
IntVector___delitem__(IntVector self, PySliceObject slice)
- IntVector___delslice__(...)
- IntVector___delslice__(IntVector self, difference_type i, difference_type j)
- IntVector___getitem__(...)
- __getitem__(PySliceObject slice) -> IntVector
IntVector___getitem__(IntVector self, difference_type i) -> value_type
- IntVector___getslice__(...)
- IntVector___getslice__(IntVector self, difference_type i, difference_type j) -> IntVector
- IntVector___len__(...)
- IntVector___len__(IntVector self) -> size_type
- IntVector___nonzero__(...)
- IntVector___nonzero__(IntVector self) -> bool
- IntVector___setitem__(...)
- __setitem__(PySliceObject slice, IntVector v)
__setitem__(PySliceObject slice)
IntVector___setitem__(IntVector self, difference_type i, value_type x)
- IntVector___setslice__(...)
- __setslice__(difference_type i, difference_type j, IntVector v = std::vector< int,std::allocator< int > >())
IntVector___setslice__(IntVector self, difference_type i, difference_type j)
- IntVector_append(...)
- IntVector_append(IntVector self, value_type x)
- IntVector_assign(...)
- IntVector_assign(IntVector self, size_type n, value_type x)
- IntVector_back(...)
- IntVector_back(IntVector self) -> value_type
- IntVector_begin(...)
- IntVector_begin(IntVector self) -> iterator
- IntVector_capacity(...)
- IntVector_capacity(IntVector self) -> size_type
- IntVector_clear(...)
- IntVector_clear(IntVector self)
- IntVector_empty(...)
- IntVector_empty(IntVector self) -> bool
- IntVector_end(...)
- IntVector_end(IntVector self) -> iterator
- IntVector_erase(...)
- erase(iterator pos) -> iterator
IntVector_erase(IntVector self, iterator first, iterator last) -> iterator
- IntVector_front(...)
- IntVector_front(IntVector self) -> value_type
- IntVector_get_allocator(...)
- IntVector_get_allocator(IntVector self) -> allocator_type
- IntVector_insert(...)
- insert(iterator pos, value_type x) -> iterator
IntVector_insert(IntVector self, iterator pos, size_type n, value_type x)
- IntVector_iterator(...)
- IntVector_iterator(IntVector self) -> SwigPyIterator
- IntVector_pop(...)
- IntVector_pop(IntVector self) -> value_type
- IntVector_pop_back(...)
- IntVector_pop_back(IntVector self)
- IntVector_push_back(...)
- IntVector_push_back(IntVector self, value_type x)
- IntVector_rbegin(...)
- IntVector_rbegin(IntVector self) -> reverse_iterator
- IntVector_rend(...)
- IntVector_rend(IntVector self) -> reverse_iterator
- IntVector_reserve(...)
- IntVector_reserve(IntVector self, size_type n)
- IntVector_resize(...)
- resize(size_type new_size)
IntVector_resize(IntVector self, size_type new_size, value_type x)
- IntVector_size(...)
- IntVector_size(IntVector self) -> size_type
- IntVector_swap(...)
- IntVector_swap(IntVector self, IntVector v)
- IntVector_swigregister(...)
- ListVector___bool__(...)
- ListVector___bool__(ListVector self) -> bool
- ListVector___delitem__(...)
- __delitem__(difference_type i)
ListVector___delitem__(ListVector self, PySliceObject slice)
- ListVector___delslice__(...)
- ListVector___delslice__(ListVector self, difference_type i, difference_type j)
- ListVector___getitem__(...)
- __getitem__(PySliceObject slice) -> ListVector
ListVector___getitem__(ListVector self, difference_type i) -> value_type
- ListVector___getslice__(...)
- ListVector___getslice__(ListVector self, difference_type i, difference_type j) -> ListVector
- ListVector___len__(...)
- ListVector___len__(ListVector self) -> size_type
- ListVector___nonzero__(...)
- ListVector___nonzero__(ListVector self) -> bool
- ListVector___setitem__(...)
- __setitem__(PySliceObject slice, ListVector v)
__setitem__(PySliceObject slice)
ListVector___setitem__(ListVector self, difference_type i, value_type x)
- ListVector___setslice__(...)
- __setslice__(difference_type i, difference_type j, ListVector v = std::vector< std::vector< sb::FieldValue,std::allocator< sb::FieldValue > >,std::allocator< std::vector< sb::FieldValue,std::allocator< sb::FieldValue > > > >())
ListVector___setslice__(ListVector self, difference_type i, difference_type j)
- ListVector_append(...)
- ListVector_append(ListVector self, value_type x)
- ListVector_assign(...)
- ListVector_assign(ListVector self, size_type n, value_type x)
- ListVector_back(...)
- ListVector_back(ListVector self) -> value_type
- ListVector_begin(...)
- ListVector_begin(ListVector self) -> iterator
- ListVector_capacity(...)
- ListVector_capacity(ListVector self) -> size_type
- ListVector_clear(...)
- ListVector_clear(ListVector self)
- ListVector_empty(...)
- ListVector_empty(ListVector self) -> bool
- ListVector_end(...)
- ListVector_end(ListVector self) -> iterator
- ListVector_erase(...)
- erase(iterator pos) -> iterator
ListVector_erase(ListVector self, iterator first, iterator last) -> iterator
- ListVector_front(...)
- ListVector_front(ListVector self) -> value_type
- ListVector_get_allocator(...)
- ListVector_get_allocator(ListVector self) -> allocator_type
- ListVector_insert(...)
- insert(iterator pos, value_type x) -> iterator
ListVector_insert(ListVector self, iterator pos, size_type n, value_type x)
- ListVector_iterator(...)
- ListVector_iterator(ListVector self) -> SwigPyIterator
- ListVector_pop(...)
- ListVector_pop(ListVector self) -> value_type
- ListVector_pop_back(...)
- ListVector_pop_back(ListVector self)
- ListVector_push_back(...)
- ListVector_push_back(ListVector self, value_type x)
- ListVector_rbegin(...)
- ListVector_rbegin(ListVector self) -> reverse_iterator
- ListVector_rend(...)
- ListVector_rend(ListVector self) -> reverse_iterator
- ListVector_reserve(...)
- ListVector_reserve(ListVector self, size_type n)
- ListVector_resize(...)
- resize(size_type new_size)
ListVector_resize(ListVector self, size_type new_size, value_type x)
- ListVector_size(...)
- ListVector_size(ListVector self) -> size_type
- ListVector_swap(...)
- ListVector_swap(ListVector self, ListVector v)
- ListVector_swigregister(...)
- LongVector___bool__(...)
- LongVector___bool__(LongVector self) -> bool
- LongVector___delitem__(...)
- __delitem__(difference_type i)
LongVector___delitem__(LongVector self, PySliceObject slice)
- LongVector___delslice__(...)
- LongVector___delslice__(LongVector self, difference_type i, difference_type j)
- LongVector___getitem__(...)
- __getitem__(PySliceObject slice) -> LongVector
LongVector___getitem__(LongVector self, difference_type i) -> value_type
- LongVector___getslice__(...)
- LongVector___getslice__(LongVector self, difference_type i, difference_type j) -> LongVector
- LongVector___len__(...)
- LongVector___len__(LongVector self) -> size_type
- LongVector___nonzero__(...)
- LongVector___nonzero__(LongVector self) -> bool
- LongVector___setitem__(...)
- __setitem__(PySliceObject slice, LongVector v)
__setitem__(PySliceObject slice)
LongVector___setitem__(LongVector self, difference_type i, value_type x)
- LongVector___setslice__(...)
- __setslice__(difference_type i, difference_type j, LongVector v = std::vector< long long,std::allocator< long long > >())
LongVector___setslice__(LongVector self, difference_type i, difference_type j)
- LongVector_append(...)
- LongVector_append(LongVector self, value_type x)
- LongVector_assign(...)
- LongVector_assign(LongVector self, size_type n, value_type x)
- LongVector_back(...)
- LongVector_back(LongVector self) -> value_type
- LongVector_begin(...)
- LongVector_begin(LongVector self) -> iterator
- LongVector_capacity(...)
- LongVector_capacity(LongVector self) -> size_type
- LongVector_clear(...)
- LongVector_clear(LongVector self)
- LongVector_empty(...)
- LongVector_empty(LongVector self) -> bool
- LongVector_end(...)
- LongVector_end(LongVector self) -> iterator
- LongVector_erase(...)
- erase(iterator pos) -> iterator
LongVector_erase(LongVector self, iterator first, iterator last) -> iterator
- LongVector_front(...)
- LongVector_front(LongVector self) -> value_type
- LongVector_get_allocator(...)
- LongVector_get_allocator(LongVector self) -> allocator_type
- LongVector_insert(...)
- insert(iterator pos, value_type x) -> iterator
LongVector_insert(LongVector self, iterator pos, size_type n, value_type x)
- LongVector_iterator(...)
- LongVector_iterator(LongVector self) -> SwigPyIterator
- LongVector_pop(...)
- LongVector_pop(LongVector self) -> value_type
- LongVector_pop_back(...)
- LongVector_pop_back(LongVector self)
- LongVector_push_back(...)
- LongVector_push_back(LongVector self, value_type x)
- LongVector_rbegin(...)
- LongVector_rbegin(LongVector self) -> reverse_iterator
- LongVector_rend(...)
- LongVector_rend(LongVector self) -> reverse_iterator
- LongVector_reserve(...)
- LongVector_reserve(LongVector self, size_type n)
- LongVector_resize(...)
- resize(size_type new_size)
LongVector_resize(LongVector self, size_type new_size, value_type x)
- LongVector_size(...)
- LongVector_size(LongVector self) -> size_type
- LongVector_swap(...)
- LongVector_swap(LongVector self, LongVector v)
- LongVector_swigregister(...)
- SWIG_PyInstanceMethod_New(...)
- SchemaRep_swigregister(...)
- Schema___eq__(...)
- x.__eq__(y) <==> x==y
- Schema___ne__(...)
- x.__ne__(y) <==> x!=y
- Schema___nonzero__(...)
- x.__nonzero__() <==> x != 0
- Schema___str__(...)
- x.__str__() <==> str(x)
sb::Schema::as_string
Returns a string representation of the schema.
- Schema_as_xml(...)
- as_xml(string name = std::string(), bool aAddUUID = True) -> string
as_xml(string name = std::string()) -> string
Schema_as_xml(Schema self) -> string
- Schema_fromXml(...)
- fromXml(string input, Flags flags = sb::Schema::Flags()) -> Schema
Schema_fromXml(string input) -> Schema
sb::Schema::fromXml
Parse and return a schema from an XML string.
The root tag must be <schema>.
- Schema_getField(...)
- getField(size_t field_num) -> Field
Schema_getField(Schema self, string pathName) -> Field
sb::Schema::getField
Return the Fields object description of a field in the schema.
Parameters
----------
* `pathName` :
the path name of the field to fetch.
Exceptions
----------
* `NoSuchFieldException` :
if field is not found.
- Schema_getFields(...)
- Schema_getFields(Schema self) -> std::vector<(sb::Schema::Field,std::allocator<(sb::Schema::Field)>)>
sb::Schema::getFields
Returns a reference to a vector of all fields in the schema.
- Schema_getHeaderSize(...)
- Schema_getHeaderSize(Schema self) -> size_t
sb::Schema::getHeaderSize
Return the size of the header.
- Schema_getName(...)
- Schema_getName(Schema self) -> string
sb::Schema::getName
Returns the name of the schema or empty string at runtime.
- Schema_getNullMaskOffset(...)
- Schema_getNullMaskOffset(Schema self) -> size_t
- Schema_getNullMaskSize(...)
- Schema_getNullMaskSize(Schema self) -> size_t
- Schema_getNumFields(...)
- Schema_getNumFields(Schema self) -> size_t
sb::Schema::getNumFields
Returns the number of fields in the schema.
- Schema_hasField(...)
- Schema_hasField(Schema self, string pathName) -> bool
sb::Schema::hasField
Returns true if a field of a given path name is present, otherwise it returns
false.
Parameters
----------
* `pathName` :
the path name of the field to fetch.
- Schema_hasHeader(...)
- Schema_hasHeader(Schema self) -> bool
sb::Schema::hasHeader
Return true if the schema has space for a header, false otherwise.
Deprecated
- Schema_indexOfField(...)
- Schema_indexOfField(Schema self, string name) -> int
sb::Schema::indexOfField
Returns the index of the field with a particular name (note: **not** path name),
or -1 if there is no such field.
- Schema_sameFieldTypes(...)
- Schema_sameFieldTypes(Schema self, Schema other) -> bool
sb::Schema::sameFieldTypes
Returns true if this schema has the same field types in the same order as
another Schema.
- Schema_sameFields(...)
- Schema_sameFields(Schema self, Schema other) -> bool
sb::Schema::sameFields
Returns true if this schema has the same field Names and Types in the same order
as another Schema.
- Schema_swigregister(...)
- StreamBaseException___str__(...)
- x.__str__() <==> str(x)
- StreamBaseException_asXmlString(...)
- StreamBaseException_asXmlString(StreamBaseException self) -> string
- StreamBaseException_asXmlStringSingle(...)
- StreamBaseException_asXmlStringSingle(StreamBaseException self) -> string
- StreamBaseException_boxname(...)
- StreamBaseException_boxname(StreamBaseException self, string name) -> StreamBaseException
- StreamBaseException_boxparam(...)
- StreamBaseException_boxparam(StreamBaseException self, string name) -> StreamBaseException
- StreamBaseException_cause(...)
- StreamBaseException_cause(StreamBaseException self, StreamBaseException val) -> StreamBaseException
- StreamBaseException_chainAsString(...)
- StreamBaseException_chainAsString(StreamBaseException self) -> string
- StreamBaseException_code(...)
- code(string val) -> StreamBaseException
StreamBaseException_code(StreamBaseException self, int val) -> StreamBaseException
- StreamBaseException_fieldname(...)
- StreamBaseException_fieldname(StreamBaseException self, string name) -> StreamBaseException
- StreamBaseException_file(...)
- file(char val) -> StreamBaseException
StreamBaseException_file(StreamBaseException self, string val) -> StreamBaseException
- StreamBaseException_findByType(...)
- StreamBaseException_findByType(StreamBaseException self, string type) -> StreamBaseException
- StreamBaseException_fromXmlString(...)
- fromXmlString(string xmlstring, std::shared_ptr<(sb::StreamBaseException)> cause = std::shared_ptr< StreamBaseException >()) -> StreamBaseException
StreamBaseException_fromXmlString(string xmlstring) -> StreamBaseException
- StreamBaseException_function(...)
- function(char val) -> StreamBaseException
StreamBaseException_function(StreamBaseException self, string val) -> StreamBaseException
- StreamBaseException_getBoxName(...)
- StreamBaseException_getBoxName(StreamBaseException self) -> string
- StreamBaseException_getBoxParam(...)
- StreamBaseException_getBoxParam(StreamBaseException self) -> string
- StreamBaseException_getCause(...)
- StreamBaseException_getCause(StreamBaseException self) -> StreamBaseException
- StreamBaseException_getChainOfMessages(...)
- StreamBaseException_getChainOfMessages(StreamBaseException self) -> string
- StreamBaseException_getCode(...)
- StreamBaseException_getCode(StreamBaseException self) -> string
- StreamBaseException_getDeepest(...)
- StreamBaseException_getDeepest(StreamBaseException self) -> StreamBaseException
- StreamBaseException_getErrorType(...)
- StreamBaseException_getErrorType(StreamBaseException self) -> Type
- StreamBaseException_getFieldName(...)
- StreamBaseException_getFieldName(StreamBaseException self) -> string
- StreamBaseException_getFile(...)
- StreamBaseException_getFile(StreamBaseException self) -> string
- StreamBaseException_getFunction(...)
- StreamBaseException_getFunction(StreamBaseException self) -> string
- StreamBaseException_getLine(...)
- StreamBaseException_getLine(StreamBaseException self) -> unsigned int
- StreamBaseException_getMessage(...)
- StreamBaseException_getMessage(StreamBaseException self) -> string
- StreamBaseException_getParam(...)
- StreamBaseException_getParam(StreamBaseException self, string name) -> string
- StreamBaseException_getStackTrace(...)
- StreamBaseException_getStackTrace(StreamBaseException self) -> string
- StreamBaseException_getSummary(...)
- StreamBaseException_getSummary(StreamBaseException self) -> string
- StreamBaseException_getType(...)
- StreamBaseException_getType(StreamBaseException self) -> string
- StreamBaseException_hasCause(...)
- StreamBaseException_hasCause(StreamBaseException self) -> bool
- StreamBaseException_line(...)
- StreamBaseException_line(StreamBaseException self, int val) -> StreamBaseException
- StreamBaseException_linkAsString(...)
- StreamBaseException_linkAsString(StreamBaseException self) -> string
- StreamBaseException_message(...)
- StreamBaseException_message(StreamBaseException self, string val) -> StreamBaseException
- StreamBaseException_param(...)
- param(string name, string val) -> StreamBaseException
StreamBaseException_param(StreamBaseException self, string name, int val) -> StreamBaseException
- StreamBaseException_summary(...)
- StreamBaseException_summary(StreamBaseException self, string val) -> StreamBaseException
- StreamBaseException_swigregister(...)
- StreamBaseException_throwMyself(...)
- StreamBaseException_throwMyself(StreamBaseException self)
- StreamBaseException_type(...)
- StreamBaseException_type(StreamBaseException self, string val) -> StreamBaseException
- StreamBaseException_what(...)
- StreamBaseException_what(StreamBaseException self) -> char
sb::StreamBaseException::what
Returns the message as a C string.
The string is owned by this object, so the pointer becomes invalid upon
destruction of the StreamBaseException.
- StreamBaseXmlRpcFault_swigregister(...)
- StreamBaseXmlRpcFault_throwMyself(...)
- StreamBaseXmlRpcFault_throwMyself(StreamBaseXmlRpcFault self)
- StreamProperties___eq__(...)
- x.__eq__(y) <==> x==y
- StreamProperties___lt__(...)
- x.__lt__(y) <==> x<y
- StreamProperties___ne__(...)
- x.__ne__(y) <==> x!=y
- StreamProperties_fromXml(...)
- StreamProperties_fromXml(string input) -> StreamProperties
sb::StreamProperties::fromXml
Parse and return a StreamProperties from an XML String.
The root tag must be <stream>.
- StreamProperties_getCaptureTransformStrategy(...)
- StreamProperties_getCaptureTransformStrategy(StreamProperties self) -> CaptureTransformStrategy
sb::StreamProperties::getCaptureTransformStrategy
- StreamProperties_getContainerName(...)
- StreamProperties_getContainerName(StreamProperties self) -> string
sb::StreamProperties::getContainerName
Returns the container part of the stream.
- StreamProperties_getName(...)
- StreamProperties_getName(StreamProperties self) -> string
sb::StreamProperties::getName
Returns the name part of the stream.
- StreamProperties_getQualifiedName(...)
- StreamProperties_getQualifiedName(StreamProperties self) -> string
sb::StreamProperties::getQualifiedName
Returns the fully qualified name of the stream.
- StreamProperties_getSchema(...)
- StreamProperties_getSchema(StreamProperties self) -> Schema
Returns the schema of the stream.
- StreamProperties_hashString(...)
- StreamProperties_hashString(StreamProperties self) -> string
sb::StreamProperties::hashString
Returns the hash of the stream in binary.
- StreamProperties_hashValue(...)
- StreamProperties_hashValue(StreamProperties self) -> size_t
sb::StreamProperties::hashValue
- StreamProperties_hexString(...)
- StreamProperties_hexString(StreamProperties self) -> string
sb::StreamProperties::hexString
- StreamProperties_swigregister(...)
- StringHashFunc___call__(...)
- StringHashFunc___call__(StringHashFunc self, string str) -> size_t
- StringHashFunc_swigregister(...)
- StringVector___bool__(...)
- StringVector___bool__(StringVector self) -> bool
- StringVector___delitem__(...)
- __delitem__(difference_type i)
StringVector___delitem__(StringVector self, PySliceObject slice)
- StringVector___delslice__(...)
- StringVector___delslice__(StringVector self, difference_type i, difference_type j)
- StringVector___getitem__(...)
- __getitem__(PySliceObject slice) -> StringVector
StringVector___getitem__(StringVector self, difference_type i) -> value_type
- StringVector___getslice__(...)
- StringVector___getslice__(StringVector self, difference_type i, difference_type j) -> StringVector
- StringVector___len__(...)
- StringVector___len__(StringVector self) -> size_type
- StringVector___nonzero__(...)
- StringVector___nonzero__(StringVector self) -> bool
- StringVector___setitem__(...)
- __setitem__(PySliceObject slice, StringVector v)
__setitem__(PySliceObject slice)
StringVector___setitem__(StringVector self, difference_type i, value_type x)
- StringVector___setslice__(...)
- __setslice__(difference_type i, difference_type j, StringVector v = std::vector< std::string,std::allocator< std::string > >())
StringVector___setslice__(StringVector self, difference_type i, difference_type j)
- StringVector_append(...)
- StringVector_append(StringVector self, value_type x)
- StringVector_assign(...)
- StringVector_assign(StringVector self, size_type n, value_type x)
- StringVector_back(...)
- StringVector_back(StringVector self) -> value_type
- StringVector_begin(...)
- StringVector_begin(StringVector self) -> iterator
- StringVector_capacity(...)
- StringVector_capacity(StringVector self) -> size_type
- StringVector_clear(...)
- StringVector_clear(StringVector self)
- StringVector_empty(...)
- StringVector_empty(StringVector self) -> bool
- StringVector_end(...)
- StringVector_end(StringVector self) -> iterator
- StringVector_erase(...)
- erase(iterator pos) -> iterator
StringVector_erase(StringVector self, iterator first, iterator last) -> iterator
- StringVector_front(...)
- StringVector_front(StringVector self) -> value_type
- StringVector_get_allocator(...)
- StringVector_get_allocator(StringVector self) -> allocator_type
- StringVector_insert(...)
- insert(iterator pos, value_type x) -> iterator
StringVector_insert(StringVector self, iterator pos, size_type n, value_type x)
- StringVector_iterator(...)
- StringVector_iterator(StringVector self) -> SwigPyIterator
- StringVector_pop(...)
- StringVector_pop(StringVector self) -> value_type
- StringVector_pop_back(...)
- StringVector_pop_back(StringVector self)
- StringVector_push_back(...)
- StringVector_push_back(StringVector self, value_type x)
- StringVector_rbegin(...)
- StringVector_rbegin(StringVector self) -> reverse_iterator
- StringVector_rend(...)
- StringVector_rend(StringVector self) -> reverse_iterator
- StringVector_reserve(...)
- StringVector_reserve(StringVector self, size_type n)
- StringVector_resize(...)
- resize(size_type new_size)
StringVector_resize(StringVector self, size_type new_size, value_type x)
- StringVector_size(...)
- StringVector_size(StringVector self) -> size_type
- StringVector_swap(...)
- StringVector_swap(StringVector self, StringVector v)
- StringVector_swigregister(...)
- SwigPyIterator___add__(...)
- SwigPyIterator___add__(SwigPyIterator self, ptrdiff_t n) -> SwigPyIterator
- SwigPyIterator___eq__(...)
- SwigPyIterator___eq__(SwigPyIterator self, SwigPyIterator x) -> bool
- SwigPyIterator___iadd__(...)
- SwigPyIterator___iadd__(SwigPyIterator self, ptrdiff_t n) -> SwigPyIterator
- SwigPyIterator___isub__(...)
- SwigPyIterator___isub__(SwigPyIterator self, ptrdiff_t n) -> SwigPyIterator
- SwigPyIterator___ne__(...)
- SwigPyIterator___ne__(SwigPyIterator self, SwigPyIterator x) -> bool
- SwigPyIterator___next__(...)
- SwigPyIterator___next__(SwigPyIterator self) -> PyObject
- SwigPyIterator___sub__(...)
- __sub__(ptrdiff_t n) -> SwigPyIterator
SwigPyIterator___sub__(SwigPyIterator self, SwigPyIterator x) -> ptrdiff_t
- SwigPyIterator_advance(...)
- SwigPyIterator_advance(SwigPyIterator self, ptrdiff_t n) -> SwigPyIterator
- SwigPyIterator_copy(...)
- SwigPyIterator_copy(SwigPyIterator self) -> SwigPyIterator
- SwigPyIterator_decr(...)
- decr(size_t n = 1) -> SwigPyIterator
SwigPyIterator_decr(SwigPyIterator self) -> SwigPyIterator
- SwigPyIterator_distance(...)
- SwigPyIterator_distance(SwigPyIterator self, SwigPyIterator x) -> ptrdiff_t
- SwigPyIterator_equal(...)
- SwigPyIterator_equal(SwigPyIterator self, SwigPyIterator x) -> bool
- SwigPyIterator_incr(...)
- incr(size_t n = 1) -> SwigPyIterator
SwigPyIterator_incr(SwigPyIterator self) -> SwigPyIterator
- SwigPyIterator_next(...)
- SwigPyIterator_next(SwigPyIterator self) -> PyObject
- SwigPyIterator_previous(...)
- SwigPyIterator_previous(SwigPyIterator self) -> PyObject
- SwigPyIterator_swigregister(...)
- SwigPyIterator_value(...)
- SwigPyIterator_value(SwigPyIterator self) -> PyObject
- TimestampVector___bool__(...)
- TimestampVector___bool__(TimestampVector self) -> bool
- TimestampVector___delitem__(...)
- __delitem__(difference_type i)
TimestampVector___delitem__(TimestampVector self, PySliceObject slice)
- TimestampVector___delslice__(...)
- TimestampVector___delslice__(TimestampVector self, difference_type i, difference_type j)
- TimestampVector___getitem__(...)
- __getitem__(PySliceObject slice) -> TimestampVector
TimestampVector___getitem__(TimestampVector self, difference_type i) -> value_type
- TimestampVector___getslice__(...)
- TimestampVector___getslice__(TimestampVector self, difference_type i, difference_type j) -> TimestampVector
- TimestampVector___len__(...)
- TimestampVector___len__(TimestampVector self) -> size_type
- TimestampVector___nonzero__(...)
- TimestampVector___nonzero__(TimestampVector self) -> bool
- TimestampVector___setitem__(...)
- __setitem__(PySliceObject slice, TimestampVector v)
__setitem__(PySliceObject slice)
TimestampVector___setitem__(TimestampVector self, difference_type i, value_type x)
- TimestampVector___setslice__(...)
- __setslice__(difference_type i, difference_type j, TimestampVector v = std::vector< sb::Timestamp,std::allocator< sb::Timestamp > >())
TimestampVector___setslice__(TimestampVector self, difference_type i, difference_type j)
- TimestampVector_append(...)
- TimestampVector_append(TimestampVector self, value_type x)
- TimestampVector_assign(...)
- TimestampVector_assign(TimestampVector self, size_type n, value_type x)
- TimestampVector_back(...)
- TimestampVector_back(TimestampVector self) -> value_type
- TimestampVector_begin(...)
- TimestampVector_begin(TimestampVector self) -> iterator
- TimestampVector_capacity(...)
- TimestampVector_capacity(TimestampVector self) -> size_type
- TimestampVector_clear(...)
- TimestampVector_clear(TimestampVector self)
- TimestampVector_empty(...)
- TimestampVector_empty(TimestampVector self) -> bool
- TimestampVector_end(...)
- TimestampVector_end(TimestampVector self) -> iterator
- TimestampVector_erase(...)
- erase(iterator pos) -> iterator
TimestampVector_erase(TimestampVector self, iterator first, iterator last) -> iterator
- TimestampVector_front(...)
- TimestampVector_front(TimestampVector self) -> value_type
- TimestampVector_get_allocator(...)
- TimestampVector_get_allocator(TimestampVector self) -> allocator_type
- TimestampVector_insert(...)
- insert(iterator pos, value_type x) -> iterator
TimestampVector_insert(TimestampVector self, iterator pos, size_type n, value_type x)
- TimestampVector_iterator(...)
- TimestampVector_iterator(TimestampVector self) -> SwigPyIterator
- TimestampVector_pop(...)
- TimestampVector_pop(TimestampVector self) -> value_type
- TimestampVector_pop_back(...)
- TimestampVector_pop_back(TimestampVector self)
- TimestampVector_push_back(...)
- TimestampVector_push_back(TimestampVector self, value_type x)
- TimestampVector_rbegin(...)
- TimestampVector_rbegin(TimestampVector self) -> reverse_iterator
- TimestampVector_rend(...)
- TimestampVector_rend(TimestampVector self) -> reverse_iterator
- TimestampVector_reserve(...)
- TimestampVector_reserve(TimestampVector self, size_type n)
- TimestampVector_resize(...)
- resize(size_type new_size)
TimestampVector_resize(TimestampVector self, size_type new_size, value_type x)
- TimestampVector_size(...)
- TimestampVector_size(TimestampVector self) -> size_type
- TimestampVector_swap(...)
- TimestampVector_swap(TimestampVector self, TimestampVector v)
- TimestampVector_swigregister(...)
- Timestamp___add__(...)
- Timestamp___add__(Timestamp self, Timestamp rhs) -> Timestamp
- Timestamp___div__(...)
- Timestamp___div__(Timestamp self, Timestamp rhs) -> double
- Timestamp___eq__(...)
- x.__eq__(y) <==> x==y
- Timestamp___ge__(...)
- x.__ge__(y) <==> x>=y
- Timestamp___gt__(...)
- x.__gt__(y) <==> x>y
- Timestamp___iadd__(...)
- Timestamp___iadd__(Timestamp self, Timestamp rhs) -> Timestamp
- Timestamp___imod__(...)
- Timestamp___imod__(Timestamp self, Timestamp rhs) -> Timestamp
- Timestamp___isub__(...)
- Timestamp___isub__(Timestamp self, Timestamp rhs) -> Timestamp
- Timestamp___le__(...)
- x.__le__(y) <==> x<=y
- Timestamp___lt__(...)
- x.__lt__(y) <==> x<y
- Timestamp___mod__(...)
- Timestamp___mod__(Timestamp self, Timestamp rhs) -> Timestamp
- Timestamp___ne__(...)
- x.__ne__(y) <==> x!=y
- Timestamp___neg__(...)
- Timestamp___neg__(Timestamp self) -> Timestamp
- Timestamp___str__(...)
- x.__str__() <==> str(x)
x.__str__() <==> str(x)
sb::Timestamp::as_string
Return a human readable string rep of this Timestamp.
- Timestamp___sub__(...)
- Timestamp___sub__(Timestamp self, Timestamp rhs) -> Timestamp
- Timestamp_compare(...)
- Timestamp_compare(Timestamp self, Timestamp other) -> int
sb::Timestamp::compare
compare 2 timestamps return less than zero this < other return greater than zero
this > other return 0 if they are the same
- Timestamp_days(...)
- Timestamp_days(double days) -> Timestamp
sb::Timestamp::days
Construct an interval from days.
- Timestamp_getDayOfMonth(...)
- Timestamp_getDayOfMonth(Timestamp self) -> int
sb::Timestamp::getDayOfMonth
Return day of month.
- Timestamp_getDayOfWeek(...)
- Timestamp_getDayOfWeek(Timestamp self) -> int
sb::Timestamp::getDayOfWeek
Return day since Sunday.
- Timestamp_getHour(...)
- Timestamp_getHour(Timestamp self) -> int
sb::Timestamp::getHour
Return hours since midnight.
- Timestamp_getMillisecond(...)
- Timestamp_getMillisecond(Timestamp self) -> double
sb::Timestamp::getMillisecond
Return milliseconds after the second.
- Timestamp_getMinute(...)
- Timestamp_getMinute(Timestamp self) -> int
sb::Timestamp::getMinute
Return minutes after hour.
- Timestamp_getMonth(...)
- Timestamp_getMonth(Timestamp self) -> int
sb::Timestamp::getMonth
Return month since January.
- Timestamp_getSecond(...)
- Timestamp_getSecond(Timestamp self) -> double
sb::Timestamp::getSecond
Return seconds after the minute.
- Timestamp_getYear(...)
- Timestamp_getYear(Timestamp self) -> int
sb::Timestamp::getYear
Return year.
- Timestamp_hours(...)
- Timestamp_hours(double hours) -> Timestamp
sb::Timestamp::hours
Construct an interval from hours.
- Timestamp_isInterval(...)
- Timestamp_isInterval(Timestamp self) -> bool
sb::Timestamp::isInterval
Return true if this Timestamp is an interval.
- Timestamp_milliseconds(...)
- Timestamp_milliseconds(long long milliseconds) -> Timestamp
sb::Timestamp::milliseconds
Create a time from a count of milliseconds.
- Timestamp_minutes(...)
- Timestamp_minutes(double minutes) -> Timestamp
sb::Timestamp::minutes
Construct an interval from minutes.
- Timestamp_now(...)
- Timestamp_now() -> Timestamp
sb::Timestamp::now
Return a Timestamp representing the current moment in time.
- Timestamp_seconds(...)
- Timestamp_seconds(double seconds) -> Timestamp
sb::Timestamp::seconds
Create a time from a count of seconds.
- Timestamp_setDayOfMonth(...)
- Timestamp_setDayOfMonth(Timestamp self, int day_of_month)
sb::Timestamp::setDayOfMonth
Set day of month.
- Timestamp_setHour(...)
- Timestamp_setHour(Timestamp self, int hours)
sb::Timestamp::setHour
Set hours since midnight.
- Timestamp_setMinute(...)
- Timestamp_setMinute(Timestamp self, int minutes)
sb::Timestamp::setMinute
Set minutes after the hour.
- Timestamp_setMonth(...)
- Timestamp_setMonth(Timestamp self, int month)
sb::Timestamp::setMonth
Set month since January.
- Timestamp_setSecond(...)
- Timestamp_setSecond(Timestamp self, double seconds)
sb::Timestamp::setSecond
Set seconds after the minute.
- Timestamp_setYear(...)
- Timestamp_setYear(Timestamp self, int year)
sb::Timestamp::setYear
Set year.
- Timestamp_swigregister(...)
- Timestamp_toMsecs(...)
- Timestamp_toMsecs(Timestamp self) -> long long
sb::Timestamp::toMsecs
Return the time as milliseconds.
- Timestamp_toSecs(...)
- Timestamp_toSecs(Timestamp self) -> long long
sb::Timestamp::toSecs
Return the time as seconds.
- Timestamp_weeks(...)
- Timestamp_weeks(double weeks) -> Timestamp
sb::Timestamp::weeks
Construct an interval from weeks.
- TupleList___getitem__(...)
- x.__getitem__(y) <==> x[y]
- TupleList___iter__(...)
- x.__iter__() <==> iter(x)
- TupleList___len__(...)
- x.__len__() <==> len(x)
- TupleList___setitem__(...)
- x.__setitem__(y, i) <==> x[y]=i
- TupleList___str__(...)
- x.__str__() <==> str(x)
sb::TupleList::as_string
Return a human-readable string value representing this list in its entirety
(including all header values, if applicable).
Returns
-------
the string value.
- TupleList_back(...)
- back() -> Tuple
TupleList_back(TupleList self) -> Tuple
sb::TupleList::back
- TupleList_begin(...)
- begin() -> iterator
TupleList_begin(TupleList self) -> const_iterator
sb::TupleList::begin
- TupleList_clear(...)
- TupleList_clear(TupleList self)
sb::TupleList::clear
clear the list
- TupleList_copyIntoBuffer(...)
- TupleList_copyIntoBuffer(TupleList self, char buf, size_t len, bool byteswap) -> size_t
- TupleList_createFromPackedBuffer(...)
- createFromPackedBuffer(size_t size_used, char buf, size_t buf_len, bool byteswap,
Schema s, size_t expect_num_tuples = (size_t) -1) -> TupleList
TupleList_createFromPackedBuffer(size_t size_used, char buf, size_t buf_len, bool byteswap,
Schema s) -> TupleList
- TupleList_createRawFromPackedBuffer(...)
- createRawFromPackedBuffer(size_t size_used, char buf, size_t buf_len, bool byteswap,
Schema s, size_t expect_num_tuples = (size_t) -1) -> TupleList
TupleList_createRawFromPackedBuffer(size_t size_used, char buf, size_t buf_len, bool byteswap,
Schema s) -> TupleList
- TupleList_empty(...)
- TupleList_empty(TupleList self) -> bool
sb::TupleList::empty
Is the list empty?
- TupleList_end(...)
- end() -> iterator
TupleList_end(TupleList self) -> const_iterator
sb::TupleList::end
- TupleList_getRawBits(...)
- TupleList_getRawBits(TupleList self) -> string
- TupleList_getSchema(...)
- TupleList_getSchema(TupleList self) -> Schema
sb::TupleList::getSchema
Get the schema.
- TupleList_getSize(...)
- TupleList_getSize(TupleList self) -> size_t
sb::TupleList::getSize
Get the number of tuples in the list.
- TupleList_push_back(...)
- TupleList_push_back(TupleList self, Tuple r)
sb::TupleList::push_back
append a tuple to the list
- TupleList_resize(...)
- TupleList_resize(TupleList self, size_t size)
sb::TupleList::resize
Change the size of the list any new tuples will be entirely null.
- TupleList_setRawBits(...)
- TupleList_setRawBits(TupleList self, char bits, size_t len)
- TupleList_setSchema(...)
- TupleList_setSchema(TupleList self, Schema schema)
sb::TupleList::setSchema
set the schema for this list (also setting the schema for any tuples in the
list)
- TupleList_setSize(...)
- TupleList_setSize(TupleList self, size_t size)
sb::TupleList::setSize
- TupleList_size(...)
- TupleList_size(TupleList self) -> size_t
sb::TupleList::size
- TupleList_swigregister(...)
- TuplePrivateImpl___eq__(...)
- x.__eq__(y) <==> x==y
- TuplePrivateImpl_copyFieldValueIntoBuffer(...)
- TuplePrivateImpl_copyFieldValueIntoBuffer(char buf, size_t buf_len, Field f, FieldValue fv, bool byteswap) -> size_t
- TuplePrivateImpl_extractBlob(...)
- TuplePrivateImpl_extractBlob(char buf, size_t size, Field field, FieldValue fv,
bool byteswap) -> size_t
- TuplePrivateImpl_extractBool(...)
- TuplePrivateImpl_extractBool(char buf, size_t size, Field field, FieldValue fv,
bool byteswap) -> size_t
- TuplePrivateImpl_extractDouble(...)
- TuplePrivateImpl_extractDouble(char buf, size_t size, Field field, FieldValue fv,
bool byteswap) -> size_t
- TuplePrivateImpl_extractFunction(...)
- TuplePrivateImpl_extractFunction(char buf, size_t size, Field field, FieldValue fv,
bool byteswap) -> size_t
- TuplePrivateImpl_extractInt(...)
- TuplePrivateImpl_extractInt(char buf, size_t size, Field field, FieldValue fv,
bool byteswap) -> size_t
- TuplePrivateImpl_extractList(...)
- TuplePrivateImpl_extractList(char buf, size_t size, Field field, FieldValue fv,
bool byteswap) -> size_t
- TuplePrivateImpl_extractLong(...)
- TuplePrivateImpl_extractLong(char buf, size_t size, Field field, FieldValue fv,
bool byteswap) -> size_t
- TuplePrivateImpl_extractString(...)
- TuplePrivateImpl_extractString(char buf, size_t size, Field field, FieldValue fv,
bool byteswap) -> size_t
- TuplePrivateImpl_extractTimestamp(...)
- TuplePrivateImpl_extractTimestamp(char buf, size_t size, Field field, FieldValue fv,
bool byteswap) -> size_t
- TuplePrivateImpl_extractTuple(...)
- TuplePrivateImpl_extractTuple(char buf, size_t size, Field field, FieldValue fv,
bool byteswap) -> size_t
- TuplePrivateImpl_extractVarLength(...)
- TuplePrivateImpl_extractVarLength(char buf, size_t size, Field field, FieldValue fv,
bool byteswap) -> size_t
- TuplePrivateImpl_field_values_get(...)
- TuplePrivateImpl_field_values_get(TuplePrivateImpl self) -> FieldValueVector
- TuplePrivateImpl_field_values_set(...)
- TuplePrivateImpl_field_values_set(TuplePrivateImpl self, FieldValueVector field_values)
- TuplePrivateImpl_get(...)
- get(Field f) -> FieldValue
TuplePrivateImpl_get(TuplePrivateImpl self, Field f) -> FieldValue
- TuplePrivateImpl_getBlobFromFieldValue(...)
- TuplePrivateImpl_getBlobFromFieldValue(Field f, FieldValue fv) -> string
- TuplePrivateImpl_getBoolFromFieldValue(...)
- TuplePrivateImpl_getBoolFromFieldValue(Field f, FieldValue fv) -> bool
- TuplePrivateImpl_getDoubleFromFieldValue(...)
- TuplePrivateImpl_getDoubleFromFieldValue(Field f, FieldValue fv) -> double
- TuplePrivateImpl_getFunctionFromFieldValue(...)
- TuplePrivateImpl_getFunctionFromFieldValue(Field f, FieldValue fv) -> Function
- TuplePrivateImpl_getIntFromFieldValue(...)
- TuplePrivateImpl_getIntFromFieldValue(Field f, FieldValue fv) -> int
- TuplePrivateImpl_getListFromFieldValue(...)
- TuplePrivateImpl_getListFromFieldValue(Field f, FieldValue fv) -> FieldValueVector
- TuplePrivateImpl_getLongFromFieldValue(...)
- TuplePrivateImpl_getLongFromFieldValue(Field f, FieldValue fv) -> long long
- TuplePrivateImpl_getStringFromFieldValue(...)
- TuplePrivateImpl_getStringFromFieldValue(Field f, FieldValue fv) -> string
- TuplePrivateImpl_getTimestampFromFieldValue(...)
- TuplePrivateImpl_getTimestampFromFieldValue(Field f, FieldValue fv) -> Timestamp
- TuplePrivateImpl_getTimestampLongFromFieldValue(...)
- TuplePrivateImpl_getTimestampLongFromFieldValue(Field f, FieldValue fv) -> long long
- TuplePrivateImpl_getTupleFromFieldValue(...)
- TuplePrivateImpl_getTupleFromFieldValue(Field f, FieldValue fv) -> Tuple
- TuplePrivateImpl_getTupleMutableFromFieldValue(...)
- TuplePrivateImpl_getTupleMutableFromFieldValue(Field f, FieldValue fv) -> Tuple
- TuplePrivateImpl_getVarLengthFromFieldValue(...)
- TuplePrivateImpl_getVarLengthFromFieldValue(CompleteDataType cdt, Field f, FieldValue fv) -> string
- TuplePrivateImpl_id_get(...)
- TuplePrivateImpl_id_get(TuplePrivateImpl self) -> unsigned int
- TuplePrivateImpl_id_set(...)
- TuplePrivateImpl_id_set(TuplePrivateImpl self, unsigned int id)
- TuplePrivateImpl_injectBlob(...)
- TuplePrivateImpl_injectBlob(char buf, size_t size, Field field, FieldValue fv,
bool byteswap) -> size_t
- TuplePrivateImpl_injectBool(...)
- TuplePrivateImpl_injectBool(char buf, size_t size, Field field, FieldValue fv,
bool byteswap) -> size_t
- TuplePrivateImpl_injectDouble(...)
- TuplePrivateImpl_injectDouble(char buf, size_t size, Field field, FieldValue fv,
bool byteswap) -> size_t
- TuplePrivateImpl_injectFunction(...)
- TuplePrivateImpl_injectFunction(char buf, size_t size, Field field, FieldValue fv,
bool byteswap) -> size_t
- TuplePrivateImpl_injectInt(...)
- TuplePrivateImpl_injectInt(char buf, size_t size, Field field, FieldValue fv,
bool byteswap) -> size_t
- TuplePrivateImpl_injectList(...)
- TuplePrivateImpl_injectList(char buf, size_t size, Field field, FieldValue fv,
bool byteswap) -> size_t
- TuplePrivateImpl_injectLong(...)
- TuplePrivateImpl_injectLong(char buf, size_t size, Field field, FieldValue fv,
bool byteswap) -> size_t
- TuplePrivateImpl_injectString(...)
- TuplePrivateImpl_injectString(char buf, size_t size, Field field, FieldValue fv,
bool byteswap) -> size_t
- TuplePrivateImpl_injectTimestamp(...)
- TuplePrivateImpl_injectTimestamp(char buf, size_t size, Field field, FieldValue fv,
bool byteswap) -> size_t
- TuplePrivateImpl_injectTuple(...)
- TuplePrivateImpl_injectTuple(char buf, size_t size, Field field, FieldValue fv,
bool byteswap) -> size_t
- TuplePrivateImpl_injectVarLength(...)
- TuplePrivateImpl_injectVarLength(char buf, size_t size, Field field, FieldValue fv,
bool byteswap) -> size_t
- TuplePrivateImpl_schema_get(...)
- TuplePrivateImpl_schema_get(TuplePrivateImpl self) -> Schema
- TuplePrivateImpl_schema_set(...)
- TuplePrivateImpl_schema_set(TuplePrivateImpl self, Schema schema)
- TuplePrivateImpl_setBlobFieldValue(...)
- TuplePrivateImpl_setBlobFieldValue(string value, Field f, FieldValue fv)
- TuplePrivateImpl_setBoolFieldValue(...)
- TuplePrivateImpl_setBoolFieldValue(bool value, Field f, FieldValue fv)
- TuplePrivateImpl_setDoubleFieldValue(...)
- TuplePrivateImpl_setDoubleFieldValue(double value, Field f, FieldValue fv)
- TuplePrivateImpl_setFieldValue(...)
- TuplePrivateImpl_setFieldValue(FieldValue value, Field f, FieldValue lhs)
- TuplePrivateImpl_setFieldValueFromPackedBuffer(...)
- TuplePrivateImpl_setFieldValueFromPackedBuffer(char buf, size_t buf_len, Field f, FieldValue fv, bool byteswap) -> size_t
- TuplePrivateImpl_setFunctionFieldValue(...)
- TuplePrivateImpl_setFunctionFieldValue(Function value, Field f, FieldValue fv)
- TuplePrivateImpl_setIntFieldValue(...)
- TuplePrivateImpl_setIntFieldValue(int value, Field f, FieldValue fv)
- TuplePrivateImpl_setListFieldValue(...)
- TuplePrivateImpl_setListFieldValue(FieldValueVector value, Field f, FieldValue fv)
- TuplePrivateImpl_setLongFieldValue(...)
- TuplePrivateImpl_setLongFieldValue(long long value, Field f, FieldValue fv)
- TuplePrivateImpl_setStringFieldValue(...)
- TuplePrivateImpl_setStringFieldValue(string value, Field f, FieldValue fv)
- TuplePrivateImpl_setTimestampFieldValue(...)
- TuplePrivateImpl_setTimestampFieldValue(Timestamp value, Field f, FieldValue fv)
- TuplePrivateImpl_setTimestampLongFieldValue(...)
- TuplePrivateImpl_setTimestampLongFieldValue(long long value, Field f, FieldValue fv)
- TuplePrivateImpl_setTupleFieldValue(...)
- TuplePrivateImpl_setTupleFieldValue(Tuple value, Field f, FieldValue fv)
- TuplePrivateImpl_setVarLengthFieldValue(...)
- TuplePrivateImpl_setVarLengthFieldValue(CompleteDataType cdt, string value, Field f, FieldValue fv)
- TuplePrivateImpl_swigregister(...)
- TupleVector___bool__(...)
- TupleVector___bool__(TupleVector self) -> bool
- TupleVector___delitem__(...)
- __delitem__(difference_type i)
TupleVector___delitem__(TupleVector self, PySliceObject slice)
- TupleVector___delslice__(...)
- TupleVector___delslice__(TupleVector self, difference_type i, difference_type j)
- TupleVector___getitem__(...)
- __getitem__(PySliceObject slice) -> TupleVector
TupleVector___getitem__(TupleVector self, difference_type i) -> value_type
- TupleVector___getslice__(...)
- TupleVector___getslice__(TupleVector self, difference_type i, difference_type j) -> TupleVector
- TupleVector___len__(...)
- TupleVector___len__(TupleVector self) -> size_type
- TupleVector___nonzero__(...)
- TupleVector___nonzero__(TupleVector self) -> bool
- TupleVector___setitem__(...)
- __setitem__(PySliceObject slice, TupleVector v)
__setitem__(PySliceObject slice)
TupleVector___setitem__(TupleVector self, difference_type i, value_type x)
- TupleVector___setslice__(...)
- __setslice__(difference_type i, difference_type j, TupleVector v = std::vector< sb::Tuple,std::allocator< sb::Tuple > >())
TupleVector___setslice__(TupleVector self, difference_type i, difference_type j)
- TupleVector_append(...)
- TupleVector_append(TupleVector self, value_type x)
- TupleVector_assign(...)
- TupleVector_assign(TupleVector self, size_type n, value_type x)
- TupleVector_back(...)
- TupleVector_back(TupleVector self) -> value_type
- TupleVector_begin(...)
- TupleVector_begin(TupleVector self) -> iterator
- TupleVector_capacity(...)
- TupleVector_capacity(TupleVector self) -> size_type
- TupleVector_clear(...)
- TupleVector_clear(TupleVector self)
- TupleVector_empty(...)
- TupleVector_empty(TupleVector self) -> bool
- TupleVector_end(...)
- TupleVector_end(TupleVector self) -> iterator
- TupleVector_erase(...)
- erase(iterator pos) -> iterator
TupleVector_erase(TupleVector self, iterator first, iterator last) -> iterator
- TupleVector_front(...)
- TupleVector_front(TupleVector self) -> value_type
- TupleVector_get_allocator(...)
- TupleVector_get_allocator(TupleVector self) -> allocator_type
- TupleVector_insert(...)
- insert(iterator pos, value_type x) -> iterator
TupleVector_insert(TupleVector self, iterator pos, size_type n, value_type x)
- TupleVector_iterator(...)
- TupleVector_iterator(TupleVector self) -> SwigPyIterator
- TupleVector_pop(...)
- TupleVector_pop(TupleVector self) -> value_type
- TupleVector_pop_back(...)
- TupleVector_pop_back(TupleVector self)
- TupleVector_push_back(...)
- TupleVector_push_back(TupleVector self, value_type x)
- TupleVector_rbegin(...)
- TupleVector_rbegin(TupleVector self) -> reverse_iterator
- TupleVector_rend(...)
- TupleVector_rend(TupleVector self) -> reverse_iterator
- TupleVector_reserve(...)
- TupleVector_reserve(TupleVector self, size_type n)
- TupleVector_resize(...)
- resize(size_type new_size)
TupleVector_resize(TupleVector self, size_type new_size, value_type x)
- TupleVector_size(...)
- TupleVector_size(TupleVector self) -> size_type
- TupleVector_swap(...)
- TupleVector_swap(TupleVector self, TupleVector v)
- TupleVector_swigregister(...)
- Tuple___eq__(...)
- x.__eq__(y) <==> x==y
If y is a Python tuple, before comparison it will be converted to a Tuple
with x's Schema.
- Tuple___getitem__(...)
- __getitem__(size_t field_num) -> FieldValue
__getitem__(string field_name) -> FieldValue
Tuple___getitem__(Tuple self, Field field) -> FieldValue
- Tuple___len__(...)
- x.__len__() <==> len(x)
- Tuple___setitem__(...)
- __setitem__(size_t field_num, FieldValue fv)
__setitem__(string field_name, FieldValue fv)
Tuple___setitem__(Tuple self, Field field, FieldValue fv)
- Tuple___str__(...)
- x.__str__() <==> str(x)
sb::Tuple::as_string
Return a human-readable string value representing this tuple in its entirety
(including all header values, if applicable).
Returns
-------
the string value.
- Tuple_as_string_external(...)
- as_string_external(char delimiter = ',', string null_string = getNullString()) -> string
as_string_external(char delimiter = ',') -> string
Tuple_as_string_external(Tuple self) -> string
sb::Tuple::as_string_external
Return a human-readable string value representing this tuple.
It compares to as_string by allowing a user-specified delimiter between fields,
making the header timestamp stand out, and omitting the TupleId header field.
null_string is written out for any null field.
Returns
-------
the string value
- Tuple_clear(...)
- Tuple_clear(Tuple self)
sb::Tuple::clear
null all fields in the tuple
- Tuple_copyIntoBuffer(...)
- Tuple_copyIntoBuffer(Tuple self, void buf, size_t len, bool byteswap) -> size_t
- Tuple_createFromPackedBuffer(...)
- Tuple_createFromPackedBuffer(size_t size_used, void buf, size_t buf_len, bool byteswap,
Schema s) -> Tuple
- Tuple_getBlobBuffer(...)
- getBlobBuffer(Field f) -> string
getBlobBuffer(size_t i) -> string
Tuple_getBlobBuffer(Tuple self, string n) -> string
sb::Tuple::getBlobBuffer
- Tuple_getBool(...)
- getBool(Field f) -> bool
getBool(size_t i) -> bool
Tuple_getBool(Tuple self, string n) -> bool
sb::Tuple::getBool
- Tuple_getDouble(...)
- getDouble(Field f) -> double
getDouble(size_t i) -> double
Tuple_getDouble(Tuple self, string n) -> double
sb::Tuple::getDouble
- Tuple_getFieldValue(...)
- getFieldValue(Field f) -> FieldValue
getFieldValue(Field f) -> FieldValue
getFieldValue(size_t field_num) -> FieldValue
getFieldValue(size_t field_num) -> FieldValue
getFieldValue(string field_name) -> FieldValue
Tuple_getFieldValue(Tuple self, string field_name) -> FieldValue
sb::Tuple::getFieldValue
Takes the name of a field in this tuple's schema, returns the corresponding
field value.
- Tuple_getFunction(...)
- getFunction(Field f) -> Function
getFunction(size_t i) -> Function
Tuple_getFunction(Tuple self, string n) -> Function
sb::Tuple::getFunction
- Tuple_getId(...)
- Tuple_getId(Tuple self) -> unsigned int
sb::Tuple::getId
Returns
-------
The id for this tuple
- Tuple_getInt(...)
- getInt(Field f) -> int
getInt(size_t i) -> int
Tuple_getInt(Tuple self, string n) -> int
sb::Tuple::getInt
- Tuple_getList(...)
- getList(Field f) -> FieldValueVector
getList(size_t i) -> FieldValueVector
Tuple_getList(Tuple self, string n) -> FieldValueVector
sb::Tuple::getList
- Tuple_getLong(...)
- getLong(Field f) -> long long
getLong(size_t i) -> long long
Tuple_getLong(Tuple self, string n) -> long long
sb::Tuple::getLong
- Tuple_getNullString(...)
- Tuple_getNullString() -> string
sb::Tuple::getNullString
Return the default string used to represent null, i.e., null.
- Tuple_getNumFields(...)
- Tuple_getNumFields(Tuple self) -> size_t
sb::Tuple::getNumFields
Returns
-------
the number of fields in the tuple's schema
- Tuple_getSchema(...)
- Tuple_getSchema(Tuple self) -> Schema
Returns the schema of the stream.
- Tuple_getSize(...)
- Tuple_getSize(Tuple self) -> size_t
sb::Tuple::getSize
Returns
-------
the serialized size of this tuple
- Tuple_getString(...)
- getString(Field f) -> string
getString(size_t i) -> string
Tuple_getString(Tuple self, string n) -> string
sb::Tuple::getString
- Tuple_getTimestamp(...)
- getTimestamp(Field f) -> Timestamp
getTimestamp(size_t i) -> Timestamp
Tuple_getTimestamp(Tuple self, string n) -> Timestamp
sb::Tuple::getTimestamp
- Tuple_getTuple(...)
- getTuple(Field f) -> Tuple
getTuple(size_t i) -> Tuple
Tuple_getTuple(Tuple self, string n) -> Tuple
sb::Tuple::getTuple
- Tuple_hasHeader(...)
- Tuple_hasHeader(Tuple self) -> bool
sb::Tuple::hasHeader
Returns
-------
true if tuple has a header, false otherwise
- Tuple_isNull(...)
- isNull(Field f) -> bool
isNull(size_t i) -> bool
Tuple_isNull(Tuple self, string n) -> bool
sb::Tuple::isNull
- Tuple_setBlobBuffer(...)
- setBlobBuffer(Field f, string v)
setBlobBuffer(size_t i, string v)
Tuple_setBlobBuffer(Tuple self, string n, string v)
sb::Tuple::setBlobBuffer
- Tuple_setBool(...)
- setBool(Field f, bool v)
setBool(size_t i, bool v)
Tuple_setBool(Tuple self, string n, bool v)
sb::Tuple::setBool
- Tuple_setDouble(...)
- setDouble(Field f, double v)
setDouble(size_t i, double v)
Tuple_setDouble(Tuple self, string n, double v)
sb::Tuple::setDouble
- Tuple_setFieldValue(...)
- setFieldValue(Field f, FieldValue fv)
setFieldValue(size_t field_num, FieldValue fv)
Tuple_setFieldValue(Tuple self, string field_name, FieldValue fv)
sb::Tuple::setFieldValue
Takes the name of a field in this tuple's schema and sets the corresponding
field value.
- Tuple_setFromPackedBuffer(...)
- Tuple_setFromPackedBuffer(Tuple self, void buf, size_t buf_len, bool byteswap,
Schema s) -> size_t
- Tuple_setFunction(...)
- setFunction(Field f, Function v)
setFunction(size_t i, Function v)
Tuple_setFunction(Tuple self, string n, Function v)
sb::Tuple::setFunction
- Tuple_setId(...)
- Tuple_setId(Tuple self, unsigned int tid)
sb::Tuple::setId
set the id
- Tuple_setInt(...)
- setInt(Field f, int v)
setInt(size_t i, int v)
Tuple_setInt(Tuple self, string n, int v)
sb::Tuple::setInt
- Tuple_setList(...)
- setList(Field f, FieldValueVector v)
setList(size_t i, FieldValueVector v)
Tuple_setList(Tuple self, string n, FieldValueVector v)
sb::Tuple::setList
- Tuple_setLong(...)
- setLong(Field f, long long v)
setLong(size_t i, long long v)
Tuple_setLong(Tuple self, string n, long long v)
sb::Tuple::setLong
- Tuple_setNull(...)
- setNull(Field f)
setNull(size_t i)
Tuple_setNull(Tuple self, string n)
sb::Tuple::setNull
- Tuple_setSchema(...)
- Tuple_setSchema(Tuple self, Schema arg1)
sb::Tuple::setSchema
set the schema
- Tuple_setString(...)
- setString(Field field, string value, Flags flags = NONE)
setString(Field field, string value)
setString(size_t field, char data, size_t len, Flags flags = NONE)
setString(size_t field, char data, size_t len)
setString(string field, char data, size_t len, Flags flags = NONE)
setString(string field, char data, size_t len)
setString(Field field, char data, size_t len, Flags flags = NONE)
setString(Field field, char data, size_t len)
setString(size_t field_index, string value, Flags flags = NONE)
setString(size_t field_index, string value)
setString(string field_name, string value, Flags flags = NONE)
Tuple_setString(Tuple self, string field_name, string value)
sb::Tuple::setString
- Tuple_setTimestamp(...)
- setTimestamp(Field f, Timestamp v)
setTimestamp(size_t i, Timestamp v)
Tuple_setTimestamp(Tuple self, string n, Timestamp v)
sb::Tuple::setTimestamp
- Tuple_setTuple(...)
- setTuple(Field f, Tuple v)
setTuple(size_t i, Tuple v)
Tuple_setTuple(Tuple self, string n, Tuple v)
sb::Tuple::setTuple
- Tuple_swigregister(...)
- Tuple_toDelimitedString(...)
- toDelimitedString(string delimiter, string null_string = getNullString(),
bool include_names = False, bool quote_all_strings = False) -> string
toDelimitedString(string delimiter, string null_string = getNullString(),
bool include_names = False) -> string
toDelimitedString(string delimiter, string null_string = getNullString()) -> string
Tuple_toDelimitedString(Tuple self, string delimiter) -> string
sb::Tuple::toDelimitedString
Return a string value representing this tuple, separated by the given delimiter.
Parameters
----------
* `delimiter` :
the string to put between fields
* `null_string` :
the string used to represent null values
* `include_names` :
whether to preface each field with "<name>="
* `quote_all_strings` :
whether to put quotes around all strings, regardless of need
Returns
-------
the result string
- Tuple_verify(...)
- Tuple_verify(Tuple self)
sb::Tuple::verify
verify that the tuple is valid Throws StreamBaseException on invalid tuple
- Tuple_writeCSVString(...)
- writeCSVString(std::ostream out, char delim, char quote, string null_string = getNullString())
Tuple_writeCSVString(Tuple self, std::ostream out, char delim, char quote)
- URIVector___bool__(...)
- URIVector___bool__(URIVector self) -> bool
- URIVector___delitem__(...)
- __delitem__(difference_type i)
URIVector___delitem__(URIVector self, PySliceObject slice)
- URIVector___delslice__(...)
- URIVector___delslice__(URIVector self, difference_type i, difference_type j)
- URIVector___getitem__(...)
- __getitem__(PySliceObject slice) -> URIVector
URIVector___getitem__(URIVector self, difference_type i) -> value_type
- URIVector___getslice__(...)
- URIVector___getslice__(URIVector self, difference_type i, difference_type j) -> URIVector
- URIVector___len__(...)
- URIVector___len__(URIVector self) -> size_type
- URIVector___nonzero__(...)
- URIVector___nonzero__(URIVector self) -> bool
- URIVector___setitem__(...)
- __setitem__(PySliceObject slice, URIVector v)
__setitem__(PySliceObject slice)
URIVector___setitem__(URIVector self, difference_type i, value_type x)
- URIVector___setslice__(...)
- __setslice__(difference_type i, difference_type j, URIVector v = std::vector< sb::StreamBaseURI,std::allocator< sb::StreamBaseURI > >())
URIVector___setslice__(URIVector self, difference_type i, difference_type j)
- URIVector_append(...)
- URIVector_append(URIVector self, value_type x)
- URIVector_assign(...)
- URIVector_assign(URIVector self, size_type n, value_type x)
- URIVector_back(...)
- URIVector_back(URIVector self) -> value_type
- URIVector_begin(...)
- URIVector_begin(URIVector self) -> iterator
- URIVector_capacity(...)
- URIVector_capacity(URIVector self) -> size_type
- URIVector_clear(...)
- URIVector_clear(URIVector self)
- URIVector_empty(...)
- URIVector_empty(URIVector self) -> bool
- URIVector_end(...)
- URIVector_end(URIVector self) -> iterator
- URIVector_erase(...)
- erase(iterator pos) -> iterator
URIVector_erase(URIVector self, iterator first, iterator last) -> iterator
- URIVector_front(...)
- URIVector_front(URIVector self) -> value_type
- URIVector_get_allocator(...)
- URIVector_get_allocator(URIVector self) -> allocator_type
- URIVector_insert(...)
- insert(iterator pos, value_type x) -> iterator
URIVector_insert(URIVector self, iterator pos, size_type n, value_type x)
- URIVector_iterator(...)
- URIVector_iterator(URIVector self) -> SwigPyIterator
- URIVector_pop(...)
- URIVector_pop(URIVector self) -> value_type
- URIVector_pop_back(...)
- URIVector_pop_back(URIVector self)
- URIVector_push_back(...)
- URIVector_push_back(URIVector self, value_type x)
- URIVector_rbegin(...)
- URIVector_rbegin(URIVector self) -> reverse_iterator
- URIVector_rend(...)
- URIVector_rend(URIVector self) -> reverse_iterator
- URIVector_reserve(...)
- URIVector_reserve(URIVector self, size_type n)
- URIVector_resize(...)
- resize(size_type new_size)
URIVector_resize(URIVector self, size_type new_size, value_type x)
- URIVector_size(...)
- URIVector_size(URIVector self) -> size_type
- URIVector_swap(...)
- URIVector_swap(URIVector self, URIVector v)
- URIVector_swigregister(...)
- URI___nonzero__(...)
- x.__nonzero__() <==> x != 0
- URI___str__(...)
- x.__str__() <==> str(x)
x.__str__() <==> str(x)
sb::StreamBaseURI::as_string
Return a string representation of a list of uris.
- URI_addParameter(...)
- URI_addParameter(URI self, string key, string value)
sb::StreamBaseURI::addParameter
Add a parameter.
- URI_fromEnvironment(...)
- URI_fromEnvironment() -> URI
sb::StreamBaseURI::fromEnvironment
Create from the environment variable.
- URI_getBaseURI(...)
- URI_getBaseURI(URI self) -> URI
sb::StreamBaseURI::getBaseURI
return a StreamBaseURI without Parameters
- URI_getContainer(...)
- URI_getContainer(URI self) -> string
sb::StreamBaseURI::getContainer
Returns the container name component of the URI.
May return an empty string if no container was specified.
- URI_getHost(...)
- URI_getHost(URI self) -> string
sb::StreamBaseURI::getHost
Return the host component of the URI.
- URI_getNumParameters(...)
- URI_getNumParameters(URI self) -> size_t
sb::StreamBaseURI::getNumParameters
return the number of parameters
- URI_getParam(...)
- URI_getParam(URI self, string key) -> string
sb::StreamBaseURI::getParam
Return a parameter, or empty string if undefined.
- URI_getParameter(...)
- getParameter(string key) -> string
URI_getParameter(URI self, string key, string value) -> bool
sb::StreamBaseURI::getParameter
Return a parameter into value (returning true if one was found).
Useful to distinguish an undefined parameter from an empty one.
- URI_getPassword(...)
- URI_getPassword(URI self) -> string
sb::StreamBaseURI::getPassword
Return the password component of the URI.
- URI_getPort(...)
- URI_getPort(URI self) -> unsigned int
sb::StreamBaseURI::getPort
Return the port component of the URI.
- URI_getUser(...)
- URI_getUser(URI self) -> string
sb::StreamBaseURI::getUser
Return the user name component of the URI.
- URI_removeParameter(...)
- URI_removeParameter(URI self, string key)
sb::StreamBaseURI::removeParameter
Add a parameter.
- URI_swigregister(...)
- URI_vectorFromEnvironment(...)
- URI_vectorFromEnvironment() -> URIVector
sb::StreamBaseURI::vectorFromEnvironment
Create from the environment variable and return a vector of StreamBaseURIs.
- URI_vectorFromString(...)
- URI_vectorFromString(string uris) -> URIVector
sb::StreamBaseURI::vectorFromString
Return a StreamBaseURI vector from a string of comma sepearted URIs.
The string of URIs supplied must conform to a valid HA URI list, for example
they must all reference the same container.
- Version_checkPrintVersion(...)
- Version_checkPrintVersion(int argc, char argv) -> bool
- Version_swigregister(...)
- assert_unreachable(...)
- assert_unreachable()
- delete_ArgumentOutOfRange(...)
- delete_ArgumentOutOfRange(ArgumentOutOfRange self)
- delete_BoolVector(...)
- delete_BoolVector(BoolVector self)
- delete_Client(...)
- delete_Client(Client self)
sb::StreamBaseClient::~StreamBaseClient
Destroys a session.
- delete_ClientSettings(...)
- delete_ClientSettings(ClientSettings self)
- delete_CompleteDataType(...)
- delete_CompleteDataType(CompleteDataType self)
sb::CompleteDataType::~CompleteDataType
Destructor.
- delete_DataType(...)
- delete_DataType(DataType self)
- delete_DequeueResult(...)
- delete_DequeueResult(DequeueResult self)
sb::DequeueResult::~DequeueResult
- delete_DoubleVector(...)
- delete_DoubleVector(DoubleVector self)
- delete_Errors(...)
- delete_Errors(Errors self)
- delete_Field(...)
- delete_Field(Field self)
sb::Field::~Field
- delete_FieldValue(...)
- delete_FieldValue(FieldValue self)
sb::FieldValue::~FieldValue
Destructor.
- delete_FieldValueVector(...)
- delete_FieldValueVector(FieldValueVector self)
- delete_FieldVector(...)
- delete_FieldVector(FieldVector self)
- delete_Function(...)
- delete_Function(Function self)
- delete_IntVector(...)
- delete_IntVector(IntVector self)
- delete_ListVector(...)
- delete_ListVector(ListVector self)
- delete_LongVector(...)
- delete_LongVector(LongVector self)
- delete_Schema(...)
- delete_Schema(Schema self)
sb::Schema::~Schema
- delete_SchemaRep(...)
- delete_SchemaRep(SchemaRep self)
- delete_StreamBaseException(...)
- delete_StreamBaseException(StreamBaseException self)
sb::StreamBaseException::~StreamBaseException
Destructor.
- delete_StreamBaseXmlRpcFault(...)
- delete_StreamBaseXmlRpcFault(StreamBaseXmlRpcFault self)
- delete_StreamProperties(...)
- delete_StreamProperties(StreamProperties self)
- delete_StringHashFunc(...)
- delete_StringHashFunc(StringHashFunc self)
- delete_StringVector(...)
- delete_StringVector(StringVector self)
- delete_SwigPyIterator(...)
- delete_SwigPyIterator(SwigPyIterator self)
- delete_Timestamp(...)
- delete_Timestamp(Timestamp self)
- delete_TimestampVector(...)
- delete_TimestampVector(TimestampVector self)
- delete_Tuple(...)
- delete_Tuple(Tuple self)
sb::Tuple::~Tuple
Destructor.
- delete_TupleList(...)
- delete_TupleList(TupleList self)
sb::TupleList::~TupleList
- delete_TuplePrivateImpl(...)
- delete_TuplePrivateImpl(TuplePrivateImpl self)
- delete_TupleVector(...)
- delete_TupleVector(TupleVector self)
- delete_URI(...)
- delete_URI(URI self)
- delete_URIVector(...)
- delete_URIVector(URIVector self)
- delete_Version(...)
- delete_Version(Version self)
- demangle(...)
- demangle(char type) -> string
demangle(string type) -> string
- dummyFunctionToMakeSureStreamBaseExceptionsGetProperlyWrapped(...)
- dummyFunctionToMakeSureStreamBaseExceptionsGetProperlyWrapped()
- fvvFromBlobVector(...)
- fvvFromBlobVector(StringVector arg) -> FieldValueVector
- fvvFromBoolVector(...)
- fvvFromBoolVector(BoolVector arg) -> FieldValueVector
- fvvFromDoubleVector(...)
- fvvFromDoubleVector(DoubleVector arg) -> FieldValueVector
- fvvFromFieldValueVector(...)
- fvvFromFieldValueVector(FieldValueVector arg) -> FieldValueVector
- fvvFromIntVector(...)
- fvvFromIntVector(IntVector arg) -> FieldValueVector
- fvvFromListVector(...)
- fvvFromListVector(ListVector arg) -> FieldValueVector
- fvvFromLongVector(...)
- fvvFromLongVector(LongVector arg) -> FieldValueVector
- fvvFromStringVector(...)
- fvvFromStringVector(StringVector arg) -> FieldValueVector
- fvvFromTimestampVector(...)
- fvvFromTimestampVector(TimestampVector arg) -> FieldValueVector
- fvvFromTupleVector(...)
- fvvFromTupleVector(TupleVector arg) -> FieldValueVector
- getUnaligned(...)
- getUnaligned(Timestamp p) -> Timestamp
- leadershipStatusDecode(...)
- leadershipStatusDecode(string stringStatus) -> LeadershipStatus
leadershipStatusDecode(int intStatus) -> LeadershipStatus
sb::leadershipStatusDecode
convert integer version of leadership status into a valid enum value
Parameters
----------
* `intStatus` :
a integer containing a valid enumeration value
Exceptions
----------
* `StreamBaseException` :
if invalid
- new_ArgumentOutOfRange(...)
- ArgumentOutOfRange(string code, string message, Type a_error_type = NON_FATAL_ERROR,
char type = "ArgumentOutOfRange")
ArgumentOutOfRange(string code, string message, Type a_error_type = NON_FATAL_ERROR)
ArgumentOutOfRange(string code, string message)
ArgumentOutOfRange(string code, string message, StreamBaseException c,
Type a_error_type = NON_FATAL_ERROR, char type = "ArgumentOutOfRange")
ArgumentOutOfRange(string code, string message, StreamBaseException c,
Type a_error_type = NON_FATAL_ERROR)
new_ArgumentOutOfRange(string code, string message, StreamBaseException c) -> ArgumentOutOfRange
- new_BoolVector(...)
- BoolVector()
BoolVector(BoolVector arg0)
BoolVector(size_type size)
new_BoolVector(size_type size, value_type value) -> BoolVector
- new_Client(...)
- StreamBaseClient(URI uri = sb::StreamBaseURI::fromEnvironment(), int buffer_size = 0,
int flush_interval = DEFAULT_FLUSH_INTERVAL)
StreamBaseClient(URI uri = sb::StreamBaseURI::fromEnvironment(), int buffer_size = 0)
StreamBaseClient(URI uri = sb::StreamBaseURI::fromEnvironment())
StreamBaseClient()
StreamBaseClient(string uris, int buffer_size = 0, int flush_interval = DEFAULT_FLUSH_INTERVAL)
StreamBaseClient(string uris, int buffer_size = 0)
StreamBaseClient(string uris)
StreamBaseClient(URIVector uris, int buffer_size = 0, int flush_interval = DEFAULT_FLUSH_INTERVAL)
StreamBaseClient(URIVector uris, int buffer_size = 0)
StreamBaseClient(URIVector uris)
StreamBaseClient(URIVector uris, ClientSettings settings, int buffer_size = 0,
int flush_interval = DEFAULT_FLUSH_INTERVAL)
StreamBaseClient(URIVector uris, ClientSettings settings, int buffer_size = 0)
new_Client(URIVector uris, ClientSettings settings) -> Client
sb::StreamBaseClient::StreamBaseClient
- new_ClientSettings(...)
- new_ClientSettings(bool haModeOn) -> ClientSettings
sb::ClientSettings::ClientSettings
Loads all the client settings.
- new_CompleteDataType(...)
- CompleteDataType()
new_CompleteDataType(CompleteDataType cdt) -> CompleteDataType
sb::CompleteDataType::CompleteDataType
Copy constructor.
- new_DataType(...)
- DataType()
new_DataType(Rep type) -> DataType
sb::DataType::DataType
Construct a DataType equal to DataType::NONE.
- new_DequeueResult(...)
- DequeueResult()
new_DequeueResult(StreamProperties props, TupleList tuples, URI serverURI,
LeadershipStatus _leadershipStatus) -> DequeueResult
sb::DequeueResult::DequeueResult
Create a Dequeue Result with a list of tuples, with the given LeadershipStatus.
- new_DoubleVector(...)
- DoubleVector()
DoubleVector(DoubleVector arg0)
DoubleVector(size_type size)
new_DoubleVector(size_type size, value_type value) -> DoubleVector
- new_Errors(...)
- new_Errors() -> Errors
- new_Field(...)
- Field()
Field(string name, DataType type, size_t size = (size_t) -1)
Field(string name, DataType type)
Field(string name, DataType type, Schema schema)
Field(string name, CompleteDataType cdt)
new_Field(Field f) -> Field
sb::Field::Field
Copy constructor.
- new_FieldValue(...)
- FieldValue()
FieldValue(CompleteDataType cdt)
FieldValue(bool value)
FieldValue(int value)
FieldValue(double value)
FieldValue(long long value)
FieldValue(Timestamp value)
FieldValue(char value)
FieldValue(string value)
FieldValue(DataType type, string value)
FieldValue(Tuple value)
FieldValue(Function value)
FieldValue(FieldValueVector value)
FieldValue(DataType type, CompleteDataType elemType)
new_FieldValue(FieldValue fv) -> FieldValue
sb::FieldValue::FieldValue
Copy constructor.
- new_FieldValueVector(...)
- FieldValueVector()
FieldValueVector(FieldValueVector arg0)
FieldValueVector(size_type size)
new_FieldValueVector(size_type size, value_type value) -> FieldValueVector
- new_FieldVector(...)
- FieldVector()
FieldVector(FieldVector arg0)
FieldVector(size_type size)
new_FieldVector(size_type size, value_type value) -> FieldVector
- new_Function(...)
- Function(string name, string functionDefinition, string body,
Tuple environment, CompleteDataType type)
Function(string name, string functionDefinition, CompleteDataType type)
Function(Function f)
new_Function(Function f, string inFT, string outFT, CompleteDataType type) -> Function
- new_IntVector(...)
- IntVector()
IntVector(IntVector arg0)
IntVector(size_type size)
new_IntVector(size_type size, value_type value) -> IntVector
- new_ListVector(...)
- ListVector()
ListVector(ListVector arg0)
ListVector(size_type size)
new_ListVector(size_type size, value_type value) -> ListVector
- new_LongVector(...)
- LongVector()
LongVector(LongVector arg0)
LongVector(size_type size)
new_LongVector(size_type size, value_type value) -> LongVector
- new_Schema(...)
- Schema()
Schema(Schema schema)
Schema(string name, std::vector<(sb::Schema::Field,std::allocator<(sb::Schema::Field)>)> fields,
Flags flags = sb::Schema::Flags())
Schema(string name, std::vector<(sb::Schema::Field,std::allocator<(sb::Schema::Field)>)> fields)
Schema(std::vector<(sb::Schema::Field,std::allocator<(sb::Schema::Field)>)> fields,
Flags flags = sb::Schema::Flags())
new_Schema(std::vector<(sb::Schema::Field,std::allocator<(sb::Schema::Field)>)> fields) -> Schema
sb::Schema::Schema
Constructs a Schema from a vector of Field objects.
If the vector is empty the Schema will contain no fields.
- new_StreamBaseException(...)
- StreamBaseException(string code, string message, Type error_type = UNKNOWNTYPE,
string type = "StreamBaseException")
StreamBaseException(string code, string message, Type error_type = UNKNOWNTYPE)
StreamBaseException(string code, string message)
StreamBaseException(string code, string message, StreamBaseException c,
Type error_type = UNKNOWNTYPE, string type = "StreamBaseException")
StreamBaseException(string code, string message, StreamBaseException c,
Type error_type = UNKNOWNTYPE)
new_StreamBaseException(string code, string message, StreamBaseException c) -> StreamBaseException
sb::StreamBaseException::StreamBaseException
Constructor.
Parameters
----------
* `code` :
see ExceptionsCodes.hpp; use SB_NEW_MESSAGE_CODE if in doubt
* `message` :
the exception message
* `c` :
an exception that is the "cause" of this exception
* `error_type` :
the class of error, for server runtime error handling
* `type` :
the type of the exception
- new_StreamBaseXmlRpcFault(...)
- StreamBaseXmlRpcFault(int fault_code, string fault_string)
StreamBaseXmlRpcFault(string code, string message, Type error_type = UNKNOWNTYPE,
string type = "StreamBaseXmlRpcFault")
StreamBaseXmlRpcFault(string code, string message, Type error_type = UNKNOWNTYPE)
StreamBaseXmlRpcFault(string code, string message)
StreamBaseXmlRpcFault(string code, string message, StreamBaseException c,
Type error_type = UNKNOWNTYPE, string type = "StreamBaseXmlRpcFault")
StreamBaseXmlRpcFault(string code, string message, StreamBaseException c,
Type error_type = UNKNOWNTYPE)
new_StreamBaseXmlRpcFault(string code, string message, StreamBaseException c) -> StreamBaseXmlRpcFault
sb::StreamBaseXmlRpcFault::StreamBaseXmlRpcFault
- new_StreamProperties(...)
- new_StreamProperties() -> StreamProperties
sb::StreamProperties::StreamProperties
Null constructor. Object will have no name and no schema.
- new_StringHashFunc(...)
- new_StringHashFunc() -> StringHashFunc
- new_StringVector(...)
- StringVector()
StringVector(StringVector arg0)
StringVector(size_type size)
new_StringVector(size_type size, value_type value) -> StringVector
- new_Timestamp(...)
- new_Timestamp() -> Timestamp
sb::Timestamp::Timestamp
Create a default Timestamp.
Will initialized to 00:00:00 1 Jan 1970.
- new_TimestampVector(...)
- TimestampVector()
TimestampVector(TimestampVector arg0)
TimestampVector(size_type size)
new_TimestampVector(size_type size, value_type value) -> TimestampVector
- new_Tuple(...)
- Tuple()
Tuple(Tuple t)
new_Tuple(Schema s) -> Tuple
sb::Tuple::Tuple
Construct a tuple of the specified schema.
- new_TupleList(...)
- TupleList()
TupleList(Tuple tuple)
TupleList(TupleList list)
TupleList(Schema schema, size_t size = 0)
new_TupleList(Schema schema) -> TupleList
sb::TupleList::TupleList
Create tuple list with an initial size of *size*
- new_TuplePrivateImpl(...)
- TuplePrivateImpl()
new_TuplePrivateImpl(TuplePrivateImpl t) -> TuplePrivateImpl
- new_TupleVector(...)
- TupleVector()
TupleVector(TupleVector arg0)
TupleVector(size_type size)
new_TupleVector(size_type size, value_type value) -> TupleVector
- new_URI(...)
- StreamBaseURI()
StreamBaseURI(string uri)
StreamBaseURI(string host, unsigned int port, string user = "", string password = "")
StreamBaseURI(string host, unsigned int port, string user = "")
StreamBaseURI(string host, unsigned int port)
StreamBaseURI(string host, string container, unsigned int port, string user = "",
string password = "")
StreamBaseURI(string host, string container, unsigned int port, string user = "")
StreamBaseURI(string host, string container, unsigned int port)
StreamBaseURI(string host, unsigned int port, ParamMap paramMap)
new_URI(string host, string container, unsigned int port, ParamMap paramMap) -> URI
sb::StreamBaseURI::StreamBaseURI
Create explicitly from host/port with container, including a map of parameters.
- new_URIVector(...)
- URIVector()
URIVector(URIVector arg0)
URIVector(size_type size)
new_URIVector(size_type size, value_type value) -> URIVector
- new_Version(...)
- new_Version() -> Version
- nmstl_memcpy(...)
- nmstl_memcpy(void dest, void src, size_t n) -> void
- setUnaligned(...)
- setUnaligned(Timestamp p, Timestamp value)
- to_escaped_string(...)
- to_escaped_string(void data, size_t length) -> string
to_escaped_string(string s) -> string
- to_hex_string(...)
- to_hex_string(void data, size_t length) -> string
to_hex_string(string s) -> string
- to_human_readable(...)
- to_human_readable(void data, size_t length) -> string
to_human_readable(string s) -> string
- to_lower(...)
- to_lower(string a_input) -> string
- to_string(...)
- to_string(char ch) -> string
to_string(string s) -> string
to_string(void t) -> string
to_string(bool i) -> string
to_string(type_info i) -> string
to_string(char t) -> string
to_string(unsigned char t) -> string
to_string(short t) -> string
to_string(unsigned short t) -> string
to_string(int t) -> string
to_string(unsigned int t) -> string
to_string(long t) -> string
to_string(unsigned long t) -> string
to_string(long long t) -> string
to_string(unsigned long long t) -> string
to_string(float t) -> string
to_string(double t) -> string
- to_upper(...)
- to_upper(string a_input) -> string
|