public Object deserialize()

in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarPrimitiveSchemaHandler.java [45:57]

• 13 lines of code
• 4 McCabe index (conditional complexity)

    public Object deserialize(ByteBuf payload) {
        Object currentRecord = schema.decode(payload);
        switch (schemaInfo.getType()) {
            case DATE:
                return ((Date) currentRecord).getTime();
            case TIME:
                return ((Time) currentRecord).getTime();
            case TIMESTAMP:
                return ((Timestamp) currentRecord).getTime();
            default:
                return currentRecord;
        }
    }