public static IndexGenerator createIndexGenerator()

in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/IndexGeneratorFactory.java [66:82]

17 lines of code
2 McCabe index (conditional complexity)


    public static IndexGenerator createIndexGenerator(
            String index,
            List<String> fieldNames,
            List<DataType> dataTypes,
            ZoneId localTimeZoneId) {
        final IndexHelper indexHelper = new IndexHelper();
        if (indexHelper.checkIsDynamicIndex(index)) {
            return createRuntimeIndexGenerator(
                    index,
                    fieldNames.toArray(new String[0]),
                    dataTypes.toArray(new DataType[0]),
                    indexHelper,
                    localTimeZoneId);
        } else {
            return new StaticIndexGenerator(index);
        }
    }