mergeDataStream method

Future<void> mergeDataStream({
  1. required String table,
  2. required String on,
  3. required DatasetRowChunks chunks,
  4. List<String>? namespace,
  5. String? branch,
})

Implementation

Future<void> mergeDataStream({
  required String table,
  required String on,
  required DatasetRowChunks chunks,
  List<String>? namespace,
  String? branch,
}) async {
  final input = _DatasetWriteInputStream(
    start: {"kind": "start", "table": _requireDatasetTableName(table), "on": on, "namespace": namespace, "branch": branch},
    chunks: chunks,
  );
  await _drainWriteStream("merge", input);
}