private static Object commonDeserialize()

in src/main/java/org/apache/flink/connector/rocketmq/source/util/ByteSerializer.java [61:84]

• 24 lines of code
• 11 McCabe index (conditional complexity)

    private static Object commonDeserialize(byte[] value, ValueType type) {
        switch (type) {
            case V_ByteArray: // byte[]
                return value;
            case V_Byte: // byte
                return null == value ? (byte) '\0' : value[0];
            case V_Short:
                return ByteUtils.toShort(value);
            case V_Integer:
                return ByteUtils.toInt(value);
            case V_Long:
                return ByteUtils.toLong(value);
            case V_Float:
                return ByteUtils.toFloat(value);
            case V_Double:
                return ByteUtils.toDouble(value);
            case V_Boolean:
                return ByteUtils.toBoolean(value);
            case V_BigInteger:
                return new BigInteger(value);
            default:
                throw new IllegalArgumentException();
        }
    }