Flink SQL - Как проанализировать TIMESTAMP с пользовательским шаблоном?

Question

Из документации видно, что SQL Флинка может анализировать метки времени только в определенном формате, а именно:

Строка TIMESTAMP: анализирует строку метки времени в форме «гг-мм-дд чч: мм: сс.ффф» в метку времени SQL.

Есть ли способ передать пользовательский DateTimeFormatter для анализа другого типа формата отметки времени?

Answer 1

Вы можете реализовать любую логику синтаксического анализа, используя пользовательскую скалярную функцию (UDF).

Это будет выглядеть в Scala следующим образом.

class TsParser extends ScalarFunction {
  def eval(s: String): Timestamp = {
    // your logic
  }
}

После определения функция должна быть зарегистрирована в TableEnvironment:

tableEnv.registerFunction("tsParser", new TsParser())

Теперь вы можете использовать функцию tsParser, как и любую встроенную функцию.

Подробнее см. Документацию .