Flink 1.4.2 SQL Maps? - PullRequest
Новая
       6

Flink 1.4.2 SQL Maps?

0 голосов
/ 09 февраля 2019

Я сейчас использую Flink V 1.4.2

Если у меня есть POJO: 

class CustomObj{
  public Map<String, String> custTable = new HashMap<>();

  public Map<String, String> getcustTable(){ return custTable; }

  public void setcustTable(Map<String, String> custTable){
      this.custTable = custTable;
  }
}

У меня есть DataStream<POJO> ds = //from some kafka source

Теперь я делаю tableEnv.registerDataStream("tableName", ds);

И я хочу запустить 

tableEnv.sqlQuery("SELECT * FROM tableName WHERE custTable['key'] = 'val'");

Когда я пытаюсь запустить это, я получаю ошибку:

org.apache.flink.table.api.TableException: Type is not supported: ANY

Что я могу с этим сделать и как я могу это исправить?

...