Function writeToParquet

  • Parameters

    • filePathPrefix: string
    • options: {
          schema?: Schema;
      } = {}
      • Optional schema?: Schema

    Returns ((toWrite: PCollection<Object>) => Promise<{
        filesWritten: PCollection<string>;
    }>)

Generated using TypeDoc