class BeamTextCSVTable extends BeamTextTable {

  @Override
  public PCollection<BeamRecord> buildIOReader(Pipeline pipeline) {
    return PBegin.in(pipeline).apply("decodeRecord", TextIO.read().from(filePattern))
        .apply("parseCSVLine",
            new BeamTextCSVTableIOReader(beamSqlRowType, filePattern, csvFormat));
  }

  public  BeamTextCSVTable(BeamRecordSqlType beamSqlRowType, String filePattern);
  public  BeamTextCSVTable(BeamRecordSqlType beamSqlRowType, String filePattern,
      CSVFormat csvFormat);

}