Documentation

Overview

    Package csvio contains Apache Beam transforms for reading CSV files with https://github.com/gocarina/gocsv.

    TODO: * Create a CSV Writer

    Example
    Output:
    
    

    Index

    Examples

    Constants

    This section is empty.

    Variables

    This section is empty.

    Functions

    func Read

    func Read(s beam.Scope, glob string, t reflect.Type) beam.PCollection

      Read reads a set of CSV files and returns the lines as a PCollection<T>. T is defined by the reflect.TypeOf( YourType{} ) with csv tags as descripted by https://github.com/gocarina/gocsv

      Types

      This section is empty.

      Source Files