class SQLIngester extends DataIngester {

    @Override
    public MBStream<Datum> getStream() throws Exception {
        if(!connected) {
            connect();
            connected = true;
        }

        return output;
    }

    public  SQLIngester(MacroBaseConf conf);
    public  SQLIngester(MacroBaseConf conf, Connection connection);

}