class BeamTextCSVTable extends BeamTextTable {

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

  public  BeamTextCSVTable(Schema beamSchema, String filePattern);
  public  BeamTextCSVTable(Schema schema, String filePattern, CSVFormat csvFormat);

}