DStream::haSink
Syntax
DStream::haSink(name, raftGroup, cacheLimit,
[retentionMinutes=1440])
Arguments
name A string specifying the name of the target stream table.
raftGroup is an integer greater than 1 indicating Raft group ID.
cacheLimit is an integer representing the maximum number of rows of the high-availability stream table to be kept in memory. If cacheLimit>1000, it is automatically adjusted to 1000.
retentionMinutes (optional) is an integer indicating for how long (in terms of minutes) a log file larger than 1GB will be kept after last update. The default value is 1440, which means the log file only keeps data in the past 24 hours.
Details
Outputs the stream data to a high-availability stream table.
For more information on HA stream tables, refer to the haStreamTable documentation.
Return value: A DStream object.