public interface DataStreamManager
Modifier and Type | Method and Description |
---|---|
void |
addData(HubContext ctx,
java.lang.String dataStreamId,
long now,
java.util.Map<java.lang.String,java.lang.Object> data)
Adds data to a data stream.
|
java.lang.String |
createDataStream(HubContext ctx,
java.lang.String name,
java.util.Collection<DataStreamField> fields,
java.util.Set<java.lang.String> tags)
Creates a new data stream.
|
void |
deleteDataStream(HubContext ctx,
java.lang.String dataStreamId)
Deletes an existing data stream.
|
java.util.Collection<DataStreamValueSet> |
getData(HubContext ctx,
java.lang.String dataStreamId,
long endTime,
DataStreamInterval interval)
Returns data from a data stream.
|
DataStream |
getDataStream(HubContext ctx,
java.lang.String dataStreamId)
Returns a specific data stream.
|
java.util.Collection<DataStream> |
getDataStreams(HubContext ctx)
Returns the list of created data streams.
|
boolean |
isStub()
Indicates if this manager is a stub (NO-OP) implementation.
|
boolean isStub()
java.lang.String createDataStream(HubContext ctx, java.lang.String name, java.util.Collection<DataStreamField> fields, java.util.Set<java.lang.String> tags)
ctx
- the hub contextname
- the stream namefields
- the fields that comprise the data streamtags
- the tags associated with the data streamvoid deleteDataStream(HubContext ctx, java.lang.String dataStreamId)
ctx
- the hub contextdataStreamId
- the ID of the stream to deletejava.util.Collection<DataStream> getDataStreams(HubContext ctx)
ctx
- the hub contextDataStream getDataStream(HubContext ctx, java.lang.String dataStreamId)
ctx
- the hub contextdataStreamId
- the data stream IDHobsonNotFoundException
- if the data stream does not existvoid addData(HubContext ctx, java.lang.String dataStreamId, long now, java.util.Map<java.lang.String,java.lang.Object> data)
ctx
- the hub contextdataStreamId
- the data stream IDnow
- the time the data point occurreddata
- the data values (a map of fieldId to value)java.util.Collection<DataStreamValueSet> getData(HubContext ctx, java.lang.String dataStreamId, long endTime, DataStreamInterval interval)
ctx
- the hub contextdataStreamId
- the data stream IDendTime
- the end time desiredinterval
- the interval size of the dataCopyright © 2015 Whizzo Software LLC. All rights reserved.