Function partition

partition<T>(partitionFn: ((element: T, numPartitions: number) => number), numPartitions: number): PTransform<PCollection<T>, PCollection<T>[]>
Type Parameters
- T
Parameters
- partitionFn: ((element: T, numPartitions: number) => number)
  - - (element: T, numPartitions: number): number
    - Parameters
      
      element: T
      
      numPartitions: number
      
      Returns number
- numPartitions: number
Returns PTransform<PCollection<T>, PCollection<T>[]>
- Defined in src/apache_beam/transforms/pardo.ts:246

Generated using TypeDoc