Class that represents an individual checkpoint i.e. More...
Public Member Functions |
|
| def | getSequenceId (self) |
| Get the sequence identifier of this Checkpoint. More... |
|
| def | getTimestamp (self) |
| Returns the time at which the checkpoint is created. More... |
|
| def | addChar |
| def | getChar (self) |
| Extract/de-serialize a character from the Checkpoint. More... |
|
| def | addBool |
| def | getBool (self) |
| Extract/de-serialize a boolean from the Checkpoint. More... |
|
| def | addUInt8 |
| def | getUInt8 (self) |
| Extract/de-serialize a uint8_t from the Checkpoint. More... |
|
| def | addInt8 |
| def | getInt8 (self) |
| Extract/de-serialize an int8_t from the Checkpoint. More... |
|
| def | addUInt16 |
| def | getUInt16 (self) |
| Extract/de-serialize a uint16_t from the Checkpoint. More... |
|
| def | addInt16 |
| def | getInt16 (self) |
| Extract/de-serialize an int16_t from the Checkpoint. More... |
|
| def | addUInt32 |
| def | getUInt32 (self) |
| Extract/de-serialize a uint32_t from the Checkpoint. More... |
|
| def | addInt32 |
| def | getInt32 (self) |
| Extract/de-serialize an int32_t from the Checkpoint. More... |
|
| def | addUInt64 |
| def | getUInt64 (self) |
| Extract/de-serialize a uint64_t from the Checkpoint. More... |
|
| def | addInt64 |
| def | getInt64 (self) |
| Extract/de-serialize an int64_t from the Checkpoint. More... |
|
| def | addFloat |
| def | getFloat (self) |
| Extract/de-serialize a float from the Checkpoint. More... |
|
| def | addDouble |
| def | getDouble (self) |
| Extract/de-serialize a double from the Checkpoint. More... |
|
| def | addSTLString |
| def | getSTLString |
| def | getContentSize (self) |
| Obtain the size of the content current in the Checkpoint. More... |
|
| def | getNRemainingBytes (self) |
| Obtain number of serialized bytes remaining from the location pointed by the output cursor till the end of the buffer (Not supported) More... |
|
| def | getOCursor (self) |
| Get the internal buffer output cursor (Not supported) More... |
|
Class that represents an individual checkpoint i.e.
a snapshot of the state of the operator when the checkpoint is created.
| def streams.Checkpoint.getSequenceId | ( | self, | |
| int | |||
| ) |
Get the sequence identifier of this Checkpoint.
| def streams.Checkpoint.getTimestamp | ( | self, | |
| float | |||
| ) |
Returns the time at which the checkpoint is created.
This can only be called at restore time.
| DataStoreException | if the Checkpoint is used for checkpointing |
| def streams.Checkpoint.addChar | ( | self, | |
| value | |||
| ) |
| def streams.Checkpoint.getChar | ( | self, | |
| int | |||
| ) |
Extract/de-serialize a character from the Checkpoint.
| DataStoreException | if the Checkpoint is used for checkpointing or if a character cannot be extracted from Checkpoint |
| def streams.Checkpoint.addBool | ( | self, | |
| value | |||
| ) |
| def streams.Checkpoint.getBool | ( | self, | |
| bool | |||
| ) |
Extract/de-serialize a boolean from the Checkpoint.
| DataStoreException | if the Checkpoint is used for checkpointing or if a boolean cannot be extracted from Checkpoint |
| def streams.Checkpoint.addUInt8 | ( | self, | |
| value | |||
| ) |
| def streams.Checkpoint.getUInt8 | ( | self, | |
| int | |||
| ) |
Extract/de-serialize a uint8_t from the Checkpoint.
| DataStoreException | if the Checkpoint is used for checkpointing or if a uint8_t cannot be extracted from Checkpoint |
| def streams.Checkpoint.addInt8 | ( | self, | |
| value | |||
| ) |
| def streams.Checkpoint.getInt8 | ( | self, | |
| int | |||
| ) |
Extract/de-serialize an int8_t from the Checkpoint.
| DataStoreException | if the Checkpoint is used for checkpointing or if an int8_t cannot be extracted from Checkpoint |
| def streams.Checkpoint.addUInt16 | ( | self, | |
| value | |||
| ) |
| def streams.Checkpoint.getUInt16 | ( | self, | |
| int | |||
| ) |
Extract/de-serialize a uint16_t from the Checkpoint.
| DataStoreException | if the Checkpoint is used for checkpointing or if a uint16_t cannot be extracted from Checkpoint |
| def streams.Checkpoint.addInt16 | ( | self, | |
| value | |||
| ) |
| def streams.Checkpoint.getInt16 | ( | self, | |
| int | |||
| ) |
Extract/de-serialize an int16_t from the Checkpoint.
| DataStoreException | if the Checkpoint is used for checkpointing or if an int16_t cannot be extracted from Checkpoint |
| def streams.Checkpoint.addUInt32 | ( | self, | |
| value | |||
| ) |
| def streams.Checkpoint.getUInt32 | ( | self, | |
| int | |||
| ) |
Extract/de-serialize a uint32_t from the Checkpoint.
| DataStoreException | if the Checkpoint is used for checkpointing or if a uint32_t cannot be extracted from Checkpoint |
| def streams.Checkpoint.addInt32 | ( | self, | |
| value | |||
| ) |
| def streams.Checkpoint.getInt32 | ( | self, | |
| int | |||
| ) |
Extract/de-serialize an int32_t from the Checkpoint.
| DataStoreException | if the Checkpoint is used for checkpointing or if an int32_t cannot be extracted from Checkpoint |
| def streams.Checkpoint.addUInt64 | ( | self, | |
| value | |||
| ) |
| def streams.Checkpoint.getUInt64 | ( | self, | |
| int | |||
| ) |
Extract/de-serialize a uint64_t from the Checkpoint.
| DataStoreException | if the Checkpoint is used for checkpointing or if a uint64_t cannot be extracted from Checkpoint |
| def streams.Checkpoint.addInt64 | ( | self, | |
| value | |||
| ) |
| def streams.Checkpoint.getInt64 | ( | self, | |
| int | |||
| ) |
Extract/de-serialize an int64_t from the Checkpoint.
| DataStoreException | if the Checkpoint is used for checkpointing or if an int64_t cannot be extracted from Checkpoint |
| def streams.Checkpoint.addFloat | ( | self, | |
| value | |||
| ) |
| def streams.Checkpoint.getFloat | ( | self, | |
| float | |||
| ) |
Extract/de-serialize a float from the Checkpoint.
| DataStoreException | if the Checkpoint is used for checkpointing or if a float cannot be extracted from Checkpoint |
| def streams.Checkpoint.addDouble | ( | self, | |
| value | |||
| ) |
| def streams.Checkpoint.getDouble | ( | self, | |
| float | |||
| ) |
Extract/de-serialize a double from the Checkpoint.
| DataStoreException | if the Checkpoint is used for checkpointing or if a double cannot be extracted from Checkpoint |
| def streams.Checkpoint.addSTLString | ( | self, | |
| value | |||
| ) |
| def streams.Checkpoint.getSTLString | ( | self, | |
| value | |||
| ) |
| def streams.Checkpoint.getContentSize | ( | self, | |
| int | |||
| ) |
Obtain the size of the content current in the Checkpoint.
| DataStoreException | if the size cannot be determined is larger than the maximum limit of uint32_t |
| def streams.Checkpoint.getNRemainingBytes | ( | self, | |
| int | |||
| ) |
Obtain number of serialized bytes remaining from the location pointed by the output cursor till the end of the buffer (Not supported)
| DataStoreException |
| def streams.Checkpoint.getOCursor | ( | self, | |
| int | |||
| ) |
Get the internal buffer output cursor (Not supported)
| DataStoreException |