Modifier and Type | Field and Description |
---|---|
(package private) boolean |
isActive |
Constructor and Description |
---|
StreamInfo(StreamProperties props) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
calculate(Snapshot ms,
SystemInfo si) |
(package private) void |
clear() |
Object |
clone() |
(package private) void |
extractInfo(StatTuple st)
extract stream info from the StatTuple, setting member data as appropriate
|
(package private) void |
extractInfo(StatTuplev3 st) |
long |
getDeltaTuples()
Return the number of tuples since the last snapshot
|
long |
getNumTuples()
Return the total number of tuples on the stream since the stream was created
|
StreamProperties |
getStreamProperties()
Returns the StreamProperties of the stream
|
(package private) void |
prettyPrint()
Pretty-print a StreamInfo object to the standard output.
|
(package private) void |
saveForNextCycle() |
String |
toString()
Returns a string representation of the StreamInfo object.
|
StreamInfo(StreamProperties props)
void extractInfo(StatTuple st)
st
- void extractInfo(StatTuplev3 st)
void saveForNextCycle()
void calculate(Snapshot ms, SystemInfo si)
public StreamProperties getStreamProperties()
public long getNumTuples()
public long getDeltaTuples()
public String toString()
void prettyPrint()
void clear()
Copyright © 2015–2018 Cloud Software Group, Inc.. All rights reserved.