Function writeToPubSub

writeToPubSub(topic: string, options?: WriteOptions): ((dataPColl: PCollection<Uint8Array>) => Promise<any>)
Parameters
- topic: string
- options: WriteOptions = {}
Returns ((dataPColl: PCollection<Uint8Array>) => Promise<any>)
- - (dataPColl: PCollection<Uint8Array>): Promise<any>
  - Parameters
    - dataPColl: PCollection<Uint8Array>
    Returns Promise<any>
- Defined in src/apache_beam/io/pubsub.ts:124

Generated using TypeDoc