io.prediction.data.storage.hbase
:: DeveloperApi :: Close this Event Store interface object, e.
Default timeout for asynchronous operations that is set to 1 minute
Default timeout for asynchronous operations that is set to 1 minute
:: DeveloperApi :: Delete an Event in a non-blocking fashion.
:: DeveloperApi :: Delete an Event in a non-blocking fashion.
:: DeveloperApi :: Reads from database and returns a Future of Iterator of Events.
:: DeveloperApi :: Reads from database and returns a Future of Iterator of Events.
return events of this app ID
return events of this channel ID (default channel if it's None)
return events with eventTime >= startTime
return events with eventTime < untilTime
return events of this entityType
return events of this entityId
return events with any of these event names.
return events of this targetEntityType:
return events of this targetEntityId
Limit number of events. Get all events if None or Some(-1)
Reverse the order.
ExecutionContext
Future[Iterator[Event]]
:: DeveloperApi :: Get an Event in a non-blocking fashion.
:: DeveloperApi :: Get an Event in a non-blocking fashion.
:: DeveloperApi :: Insert an Event in a non-blocking fashion.
:: DeveloperApi :: Insert an Event in a non-blocking fashion.
:: DeveloperApi :: Initialize Event Store for an app ID and optionally a channel ID.
:: DeveloperApi :: Remove Event Store for an app ID and optional channel ID.
reads events of the specified entity.
reads events of the specified entity.
return events of this app ID
return events of this channel ID (default channel if it's None)
return events of this entityType
return events of this entityId
return events with any of these event names.
return events of this targetEntityType:
return events of this targetEntityId
return events with eventTime >= startTime
return events with eventTime < untilTime
Limit number of events. Get all events if None or Some(-1)
Return latest event first (default true)
ExecutionContext
Either[StorageError, Iterator[Event]]
(Since version 0.9.2) Use LEventStore.findByEntity() instead.