private void connectToTable()

in flink-connector-hbase-2.2/src/main/java/org/apache/flink/connector/hbase2/source/HBaseRowDataInputFormat.java [87:97]

• 11 lines of code
• 3 McCabe index (conditional complexity)

    private void connectToTable() throws IOException {
        if (connection == null) {
            connection = ConnectionFactory.createConnection(getHadoopConfiguration());
        }
        TableName name = TableName.valueOf(tableName);
        if (!connection.getAdmin().tableExists(name)) {
            throw new TableNotFoundException("HBase table '" + tableName + "' not found.");
        }
        table = connection.getTable(name);
        regionLocator = connection.getRegionLocator(name);
    }