sinkParquetSync method

void sinkParquetSync(
  1. String path, {
  2. String? compression,
  3. ParquetWriteOptions parquet = const ParquetWriteOptions(),
  4. LazySinkOptions options = const LazySinkOptions(),
})

Executes a native streaming Parquet sink synchronously.

Implementation

void sinkParquetSync(
  String path, {
  String? compression,
  ParquetWriteOptions parquet = const ParquetWriteOptions(),
  LazySinkOptions options = const LazySinkOptions(),
}) => _sinkLocalSync('lazySinkParquet', path, {
  ..._parquetWriteOptions(parquet, compression: compression, eager: false),
  ...options._toJson(),
});