基于Flink和Netty制作的Restful Server

所有堆外的REST接口逻辑都在AbstractRestHandler�子类中实现。
一个Session对应一个Flink的TableEnv

语句支持

SELECT 语句 是把结果写入临时表

JDBC-driver

AtomicRowData类

  • currentResultSet存当前批次拉去的多行
  • currentRow本次迭代的行

�