static

in core/src/main/java/org/apache/accumulo/core/metadata/schema/TabletMetadata.java [231:359]

• 126 lines of code
• 51 McCabe index (conditional complexity)

    static {
      ImmutableMap.Builder<ColumnType,Set<Text>> colsToFamilies = ImmutableMap.builder();
      ImmutableMap.Builder<ColumnType,ColumnFQ> colsToQualifiers = ImmutableMap.builder();

      for (ColumnType column : EnumSet.allOf(ColumnType.class)) {
        switch (column) {
          case CLONED:
            colsToFamilies.put(column, Set.of(ClonedColumnFamily.NAME));
            break;
          case DIR:
          case FLUSH_ID:
          case TIME:
          case OPID:
          case SELECTED:
          case FLUSH_NONCE:
          case MIGRATION:
            colsToFamilies.put(column, Set.of(ServerColumnFamily.NAME));
            break;
          case FILES:
            colsToFamilies.put(column, Set.of(DataFileColumnFamily.NAME));
            break;
          case AVAILABILITY:
          case HOSTING_REQUESTED:
          case PREV_ROW:
          case MERGEABILITY:
            colsToFamilies.put(column, Set.of(TabletColumnFamily.NAME));
            break;
          case LAST:
            colsToFamilies.put(column, Set.of(LastLocationColumnFamily.NAME));
            break;
          case LOADED:
            colsToFamilies.put(column, Set.of(BulkFileColumnFamily.NAME));
            break;
          case LOCATION:
            colsToFamilies.put(column,
                Set.of(CurrentLocationColumnFamily.NAME, FutureLocationColumnFamily.NAME));
            break;
          case LOGS:
            colsToFamilies.put(column, Set.of(LogColumnFamily.NAME));
            break;
          case SCANS:
            colsToFamilies.put(column, Set.of(ScanFileColumnFamily.NAME));
            break;
          case SUSPEND:
            colsToFamilies.put(column, Set.of(SuspendLocationColumn.NAME));
            break;
          case ECOMP:
            colsToFamilies.put(column, Set.of(ExternalCompactionColumnFamily.NAME));
            break;
          case MERGED:
            colsToFamilies.put(column, Set.of(MergedColumnFamily.NAME));
            break;
          case COMPACTED:
            colsToFamilies.put(column, Set.of(CompactedColumnFamily.NAME));
            break;
          case USER_COMPACTION_REQUESTED:
            colsToFamilies.put(column, Set.of(UserCompactionRequestedColumnFamily.NAME));
            break;
          case UNSPLITTABLE:
            colsToFamilies.put(column, Set.of(SplitColumnFamily.NAME));
            break;
          default:
            throw new IllegalArgumentException("Unknown col type " + column);
        }
      }

      for (ColumnType column : EnumSet.allOf(ColumnType.class)) {
        switch (column) {
          case CLONED:
          case COMPACTED:
          case ECOMP:
          case FILES:
          case LAST:
          case LOADED:
          case LOCATION:
          case LOGS:
          case SCANS:
          case USER_COMPACTION_REQUESTED:
            break;
          case DIR:
            colsToQualifiers.put(column, DIRECTORY_COLUMN);
            break;
          case FLUSH_ID:
            colsToQualifiers.put(column, FLUSH_COLUMN);
            break;
          case TIME:
            colsToQualifiers.put(column, TIME_COLUMN);
            break;
          case OPID:
            colsToQualifiers.put(column, OPID_COLUMN);
            break;
          case SELECTED:
            colsToQualifiers.put(column, SELECTED_COLUMN);
            break;
          case FLUSH_NONCE:
            colsToQualifiers.put(column, FLUSH_NONCE_COLUMN);
            break;
          case AVAILABILITY:
            colsToQualifiers.put(column, AVAILABILITY_COLUMN);
            break;
          case HOSTING_REQUESTED:
            colsToQualifiers.put(column, REQUESTED_COLUMN);
            break;
          case PREV_ROW:
            colsToQualifiers.put(column, PREV_ROW_COLUMN);
            break;
          case MERGEABILITY:
            colsToQualifiers.put(column, MERGEABILITY_COLUMN);
            break;
          case SUSPEND:
            colsToQualifiers.put(column, SUSPEND_COLUMN);
            break;
          case MERGED:
            colsToQualifiers.put(column, MERGED_COLUMN);
            break;
          case UNSPLITTABLE:
            colsToQualifiers.put(column, UNSPLITTABLE_COLUMN);
            break;
          case MIGRATION:
            colsToQualifiers.put(column, MIGRATION_COLUMN);
            break;
          default:
            throw new IllegalArgumentException("Unknown col type " + column);
        }
      }

      COLUMNS_TO_FAMILIES = colsToFamilies.build();
      COLUMNS_TO_QUALIFIERS = colsToQualifiers.build();
    }