Package org.apache.nifi.processors.standard.calcite

Class RecordPathFunctions.ObjectRecordPath

java.lang.Object

org.apache.nifi.processors.standard.calcite.RecordPathFunction

org.apache.nifi.processors.standard.calcite.RecordPathFunctions.ObjectRecordPath

Enclosing class:

RecordPathFunctions

public static class RecordPathFunctions.ObjectRecordPath
extends RecordPathFunction

Field Summary

Fields

Modifier and Type	Field	Description
private static final RecordField	PARENT_RECORD_FIELD
private static final RecordField	ROOT_RECORD_FIELD
private static final RecordSchema	ROOT_RECORD_SCHEMA

Fields inherited from class org.apache.nifi.processors.standard.calcite.RecordPathFunction

RECORD_PATH_CACHE

Constructor Summary

Constructors

Constructor	Description
ObjectRecordPath()

Method Summary

Modifier and Type	Method	Description
private Object	eval(Iterable<Record> records, String recordPath)
Object	eval(Object record, String recordPath)
private Object	eval(Map<?,?> map, String recordPath)
private Object	eval(Record[] records, String recordPath)
private Object	eval(Record record, String recordPath)
private Object	evalResults(List<FieldValue> selectedFields)

Methods inherited from class org.apache.nifi.processors.standard.calcite.RecordPathFunction

eval

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

ROOT_RECORD_FIELD

private static final RecordField ROOT_RECORD_FIELD

ROOT_RECORD_SCHEMA

private static final RecordSchema ROOT_RECORD_SCHEMA

PARENT_RECORD_FIELD

private static final RecordField PARENT_RECORD_FIELD

Constructor Details

ObjectRecordPath

public ObjectRecordPath()

Method Details

eval

public Object eval(Object record,
 String recordPath)

eval

private Object eval(Map<?,?> map,
 String recordPath)

eval

private Object eval(Record record,
 String recordPath)

eval

private Object eval(Iterable<Record> records,
 String recordPath)

eval

private Object eval(Record[] records,
 String recordPath)

evalResults

private Object evalResults(List<FieldValue> selectedFields)