- Everywhere
- @thanandorn
Block or Report
Block or report thanandorn
Report abuse
Contact GitHub support about this user’s behavior. Learn more about reporting abuse.
Report abusePinned Loading
-
ReadGzippedCSVonDF
ReadGzippedCSVonDF 1COLUMNS = [ 'a', 'b', 'c' ]
23with beam.Pipeline(options=PipelineOptions()) as p:
4csv_pc = ( p | 'ReadCSVFromGCS' >> beam.io.ReadFromText(file_pattern='./data/filename.csv.gz', compression_type='gzip')
5| 'SplitData' >> beam.Map(lambda x: x.split(','))
Something went wrong, please refresh the page to try again.
If the problem persists, check the GitHub status page or contact support.
If the problem persists, check the GitHub status page or contact support.