Как сделать преобразование DateTime в Query Record Processor

Question

Я новичок в Apache NiFi, я преобразовал данные типа Date в метку времени в Query Record Processor, используя следующий запрос

select ${fn Convert(<ColumnName>,<Datatype as 'timestamp'>) as ColumnName from flowfile}

Но я столкнулся с проблемой, когда пытался с приведенным ниже запросом преобразовать метку времени в дату и время

select {fn CONVERT(CAST(CurrentDate as BIGINT),date)} as CurrentDate from flowfile

Детали ошибки:

QueryRecord[id=0e0d33b4-0165-1000-9db1-e7d0dad2240d] Unable to query StandardFlowFileRecord[uuid=b04e508b-675e-444b-8a87-d77b77b802cd,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1533555234293-23, container=default, section=23], offset=3200, length=134],offset=0,name=AdventureWorks.csv,size=134] due to null: java.lang.NullPointerException

Как преобразовать значение метки времени в DateTime с помощью обработчика записей запросов?

Answer 1

Не уверен, что это решает проблему, но выделяется то, что первое выражение начинается со знака доллара, а второе - нет.