public static Object deserialize()

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

• 16 lines of code
• 7 McCabe index (conditional complexity)

    public static Object deserialize(byte[] value, ValueType type, Charset charset) {
        switch (type) {
            case V_String:
                return null == value ? "" : new String(value, charset);
            case V_Timestamp: // sql.Timestamp encoded as long
                return new Timestamp(ByteUtils.toLong(value));
            case V_Date: // sql.Date encoded as long
                return new Date(ByteUtils.toLong(value));
            case V_Time: // sql.Time encoded as long
                return new Time(ByteUtils.toLong(value));
            case V_BigDecimal:
                return ByteUtils.toBigDecimal(value);
            default:
                return commonDeserialize(value, type);
        }
    }