@Override
  public Connection connect(String url, Properties info) throws SQLException {
    if (!acceptsURL(url)) {
      return null;
    }
    final String prefix = getConnectStringPrefix();
    assert url.startsWith(prefix);
    final String urlSuffix = url.substring(prefix.length());
    final Properties info2 = ConnectStringParser.parse(urlSuffix, info);
    final AvaticaConnection connection =
        ((CalciteFactory) factory).newConnection(this, factory, url, info2, null, typeFactory);
    handler.onConnectionInit(connection);
    return connection;
  }
Calcite JDBC driver for SamzaSQL which takes in a {@link JavaTypeFactory}
samza-sql/src/main/java/org/apache/samza/sql/interfaces/SamzaSqlDriver.java