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

Class RecordPathFunction

java.lang.Object

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

Direct Known Subclasses:

RecordPathFunctions.DateRecordPath, RecordPathFunctions.DoubleRecordPath, RecordPathFunctions.FloatRecordPath, RecordPathFunctions.IntegerRecordPath, RecordPathFunctions.LongRecordPath, RecordPathFunctions.ObjectRecordPath, RecordPathFunctions.StringRecordPath

public class RecordPathFunction
extends Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
RecordPathFunction()

Method Summary

Modifier and Type	Method	Description
private <T> T	eval(Iterable<Record> records, String recordPath, Function<Object,T> transform)
protected <T> T	eval(Object record, String recordPath, Function<Object,T> transform)
private <T> T	eval(Map<?,?> map, String recordPath, Function<Object,T> transform)
private <T> T	eval(Record[] records, String recordPath, Function<Object,T> transform)
private <T> T	eval(Record record, String recordPath, Function<Object,T> transform)
private <T> T	evalResults(Stream<FieldValue> fields, Function<Object,T> transform, Supplier<String> multipleReturnValueErrorSupplier)

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

RECORD_PATH_CACHE

protected static final RecordPathCache RECORD_PATH_CACHE

Constructor Details

RecordPathFunction

public RecordPathFunction()

Method Details

eval

protected <T> T eval(Object record,
 String recordPath,
 Function<Object,T> transform)

eval

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

eval

private <T> T eval(Record record,
 String recordPath,
 Function<Object,T> transform)

eval

private <T> T eval(Record[] records,
 String recordPath,
 Function<Object,T> transform)

eval

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

evalResults

private <T> T evalResults(Stream<FieldValue> fields,
 Function<Object,T> transform,
 Supplier<String> multipleReturnValueErrorSupplier)