DStream::haSink

Syntax

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

Parameters

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

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 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.