static

in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchValidationUtils.java [38:56]

• 19 lines of code
• 1 McCabe index (conditional complexity)

    static {
        ALLOWED_PRIMARY_KEY_TYPES.add(LogicalTypeRoot.CHAR);
        ALLOWED_PRIMARY_KEY_TYPES.add(LogicalTypeRoot.VARCHAR);
        ALLOWED_PRIMARY_KEY_TYPES.add(LogicalTypeRoot.BOOLEAN);
        ALLOWED_PRIMARY_KEY_TYPES.add(LogicalTypeRoot.DECIMAL);
        ALLOWED_PRIMARY_KEY_TYPES.add(LogicalTypeRoot.TINYINT);
        ALLOWED_PRIMARY_KEY_TYPES.add(LogicalTypeRoot.SMALLINT);
        ALLOWED_PRIMARY_KEY_TYPES.add(LogicalTypeRoot.INTEGER);
        ALLOWED_PRIMARY_KEY_TYPES.add(LogicalTypeRoot.BIGINT);
        ALLOWED_PRIMARY_KEY_TYPES.add(LogicalTypeRoot.FLOAT);
        ALLOWED_PRIMARY_KEY_TYPES.add(LogicalTypeRoot.DOUBLE);
        ALLOWED_PRIMARY_KEY_TYPES.add(LogicalTypeRoot.DATE);
        ALLOWED_PRIMARY_KEY_TYPES.add(LogicalTypeRoot.TIME_WITHOUT_TIME_ZONE);
        ALLOWED_PRIMARY_KEY_TYPES.add(LogicalTypeRoot.TIMESTAMP_WITHOUT_TIME_ZONE);
        ALLOWED_PRIMARY_KEY_TYPES.add(LogicalTypeRoot.TIMESTAMP_WITH_TIME_ZONE);
        ALLOWED_PRIMARY_KEY_TYPES.add(LogicalTypeRoot.TIMESTAMP_WITH_LOCAL_TIME_ZONE);
        ALLOWED_PRIMARY_KEY_TYPES.add(LogicalTypeRoot.INTERVAL_YEAR_MONTH);
        ALLOWED_PRIMARY_KEY_TYPES.add(LogicalTypeRoot.INTERVAL_DAY_TIME);
    }