public DefaultRecordSchema()

in src/main/java/com/aliyun/dts/subscribe/clients/record/DefaultRecordSchema.java [35:56]

• 17 lines of code
• 2 McCabe index (conditional complexity)

    public DefaultRecordSchema(String schemaId, String databaseName, String tableName, List<RecordField> recordFields) {
        if (null == recordFields) {
            recordFields = Collections.emptyList();
        }

        this.schemaId = schemaId;
        this.databaseName = databaseName;
        this.tableName = tableName;

        this.recordFields = new ArrayList<>(recordFields.size());
        this.recordFields.addAll(recordFields);

        this.nameIndex = new TreeMap<>();

        this.recordFields.forEach(
                recordField -> this.nameIndex.put(recordField.getFieldName(), recordField));

        this.primaryIndexInfo = null;
        this.uniqueIndexInfo = new ArrayList<>(2);
        this.foreignIndexInfo = new ArrayList<>(1);
        this.normalIndexInfo = new ArrayList<>(2);
    }