gigl.common.beam.sharded_read#
Attributes#
Classes#
| A transform object used to modify one or more PCollections. | 
Module Contents#
- class gigl.common.beam.sharded_read.ShardedExportRead(table_name, sharded_read_info, **kwargs)[source]#
- Bases: - apache_beam.PTransform- A transform object used to modify one or more PCollections. - Subclasses must define an expand() method that will be used when the transform is applied to some arguments. Typical usage pattern will be: - input | CustomTransform(…) - The expand() method of the CustomTransform object passed in will be called with input as an argument. - Parameters:
- table_name (str) 
- sharded_read_info (BigQueryShardedReadConfig) 
 
 
