protected List fetchCatalogObjects()

in thriftserver/session/src/main/java/org/apache/livy/thriftserver/session/GetColumnsJob.java [51:95]
44 lines of code
8 McCabe index (conditional complexity)

  protected List<Row> fetchCatalogObjects(SessionCatalog catalog) {
    List<Row> columnList = new ArrayList<>();
    List<String> databases = seqAsJavaList(catalog.listDatabases(databasePattern));

    for (String db : databases) {
      List<TableIdentifier> tableIdentifiers =
        seqAsJavaList(catalog.listTables(db, tablePattern));
      for (TableIdentifier tableIdentifier : tableIdentifiers) {
        CatalogTable table = catalog.getTempViewOrPermanentTableMetadata(tableIdentifier);
        List<StructField> fields = seqAsJavaList(table.schema());
        int position = 0;
        for (StructField field : fields) {
          if (field.name().matches(columnPattern)) {
            columnList.add(new GenericRow(new Object[] {
              DEFAULT_HIVE_CATALOG,
              table.database(),
              table.identifier().table(),
              field.name(),
              SparkUtils.toJavaSQLType(field.dataType()), // datatype
              field.dataType().typeName(),
              SparkUtils.getColumnSize(field.dataType()), //columnsize,
              null, // BUFFER_LENGTH, unused,
              SparkUtils.getDecimalDigits(field.dataType()),
              SparkUtils.getNumPrecRadix(field.dataType()),
              field.nullable() ? 1 : 0,
              field.getComment().isDefined() ? field.getComment().get() : "",
              null, // COLUMN_DEF
              null, // SQL_DATA_TYPE
              null, // SQL_DATETIME_SUB
              null, // CHAR_OCTET_LENGTH
              position,
              field.nullable() ? "YES" : "NO", // IS_NULLABLE
              null, // SCOPE_CATALOG
              null, // SCOPE_SCHEMA
              null, // SCOPE_TABLE
              null, // SOURCE_DATA_TYPE
              "NO" // IS_AUTO_INCREMENT
            }));
            position += 1;
          }
        }
      }
    }
    return columnList;
  }