public Object extractField()

in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/KeyValueSchemaHandler.java [94:103]

• 10 lines of code
• 3 McCabe index (conditional complexity)

    public Object extractField(int index, Object currentRecord) {
        PulsarColumnHandle pulsarColumnHandle = this.columnHandles.get(index);
        KeyValue<Object, Object> keyValue = (KeyValue<Object, Object>) currentRecord;
        if (pulsarColumnHandle.isKey()) {
            return keySchemaHandler.extractField(index, keyValue.getKey());
        } else if (pulsarColumnHandle.isValue()) {
            return valueSchemaHandler.extractField(index, keyValue.getValue());
        }
        return null;
    }