public class StubDataStreamManager extends java.lang.Object implements DataStreamManager
Constructor and Description |
---|
StubDataStreamManager() |
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.List<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.
|
public boolean isStub()
DataStreamManager
isStub
in interface DataStreamManager
public java.lang.String createDataStream(HubContext ctx, java.lang.String name, java.util.Collection<DataStreamField> fields, java.util.Set<java.lang.String> tags)
DataStreamManager
createDataStream
in interface DataStreamManager
ctx
- the hub contextname
- the stream namefields
- the fields that comprise the data streamtags
- the tags associated with the data streampublic void deleteDataStream(HubContext ctx, java.lang.String dataStreamId)
DataStreamManager
deleteDataStream
in interface DataStreamManager
ctx
- the hub contextdataStreamId
- the ID of the stream to deletepublic java.util.Collection<DataStream> getDataStreams(HubContext ctx)
DataStreamManager
getDataStreams
in interface DataStreamManager
ctx
- the hub contextpublic DataStream getDataStream(HubContext ctx, java.lang.String dataStreamId)
DataStreamManager
getDataStream
in interface DataStreamManager
ctx
- the hub contextdataStreamId
- the data stream IDpublic void addData(HubContext ctx, java.lang.String dataStreamId, long now, java.util.Map<java.lang.String,java.lang.Object> data)
DataStreamManager
addData
in interface DataStreamManager
ctx
- the hub contextdataStreamId
- the data stream IDnow
- the time the data point occurreddata
- the data values (a map of fieldId to value)public java.util.List<DataStreamValueSet> getData(HubContext ctx, java.lang.String dataStreamId, long endTime, DataStreamInterval interval)
DataStreamManager
getData
in interface DataStreamManager
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.