DStream::haKeyedSink

Syntax

DStream::haKeyedSink(name, keyColumn, raftGroup, cacheLimit, [retentionMinutes=1440])

Arguments

name A string specifying the name of the target stream table.

keyColumn A string scalar or vector specifying the primary key column(s).

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 stream data to a high-availability keyed stream table.

For more information on HA stream tables, refer to the haStreamTable documentation.

Return value: A DStream object.