sinkIpcSync method

void sinkIpcSync(
  1. String path, {
  2. IpcWriteOptions ipc = const IpcWriteOptions(),
  3. LazySinkOptions options = const LazySinkOptions(),
})

Executes a native streaming IPC/Feather file sink synchronously.

Implementation

void sinkIpcSync(
  String path, {
  IpcWriteOptions ipc = const IpcWriteOptions(),
  LazySinkOptions options = const LazySinkOptions(),
}) {
  _validatePositive(ipc.recordBatchSize, 'ipc.recordBatchSize');
  _sinkLocalSync('lazySinkIpc', path, {
    ...ipc._toJson(includeParallel: false),
    ...options._toJson(),
  });
}