IEP has a SaveStream operator which can be used to store a stream of events to a database table.
SaveStream is initially supported only on StreamInput. So a StreamInput can be connected to SaveStream operator
to save it to a database table. Save and Replay Stream are explained in detail here
Now we have enabled SaveStream to be able to save data from any operator whose output is a stream. For example SaveStream now can be added to StreamProjectionAndFilter, InsertStream etc.
Following is the admin command
to dynamically add SaveStream operator to any operator whose output is a stream:
addss ,addSaveStream {plan_name operator_name jndi_name tableName isGlobal<Optional>}: Add a save stream to an input stream operator.
rss ,removeSaveStream {plan_name save_operator_name}: Removes the save stream operator.