Function writeToAvro

writeToAvro<T>(filePath: string, options: {
schema: Schema;
}): ((pcoll: PCollection<Object>) => Promise<{}>)
Type Parameters
- T
Parameters
- filePath: string
- options: {
  schema: Schema;
  }
  - schema: Schema
Returns ((pcoll: PCollection<Object>) => Promise<{}>)
- - (pcoll: PCollection<Object>): Promise<{}>
  - Parameters
    - pcoll: PCollection<Object>
    Returns Promise<{}>
- Defined in src/apache_beam/io/avroio.ts:37

Generated using TypeDoc