public static OperationType getOperationType()

in src/main/java/com/aliyun/dts/subscribe/clients/record/AvroRecordParser.java [24:45]

• 22 lines of code
• 9 McCabe index (conditional complexity)

    public static OperationType getOperationType(Record avroRecord) {
        switch (avroRecord.getOperation()) {
            case INSERT:
                return OperationType.INSERT;
            case UPDATE:
                return OperationType.UPDATE;
            case DELETE:
                return OperationType.DELETE;
            case DDL:
                return OperationType.DDL;
            case HEARTBEAT:
                return OperationType.HEARTBEAT;
            case CHECKPOINT:
                return OperationType.CHECKPOINT;
            case BEGIN:
                return OperationType.BEGIN;
            case COMMIT:
                return OperationType.COMMIT;
            default:
                return OperationType.UNKNOWN;
        }
    }