DStream::haKeyedSink
Syntax
DStream::haKeyedSink(name, keyColumn, raftGroup, cacheLimit,
[retentionMinutes=1440])
Parameters
name A string specifying the name of the target stream table.
keyColumn A string scalar or vector specifying the primary key column(s).
raftGroup can be either an integer greater than 1 or a string.
- Integer: represents the raft group ID.
- String: represents a raft group alias, which must be preconfigured via streamingRaftGroupAliases.
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.