class JdbcPipeline extends AbstractPipeline {

    @Override
    public PipelineResult asTextFile(String clusterPath, String deliminator) {
        ResultSet resultSet = establishStatement();
        return new JdbcPipelineResult.TextPipelineResult(
            new JdbcResultSetIterator<>(resultSet),
            clusterPath, deliminator);
    }

    public  JdbcPipeline(QueryProcedure procedure,
        List<String> tableNames,
        SqlRunner.Builder builder);

}