Hi Darshan, Accumulators are not exposed to UDFs of the Table API / SQL. What's your use case for these? Would metrics do the job as well?
Best, Fabian 2018-04-04 21:31 GMT+02:00 Darshan Singh <darshan.m...@gmail.com>: > Hi, > > I would like to use accumulators with table /scalar functions. However, I > am not able to figure out how to get the runtime context from inside of > scalar function open method. > Only thing i see is function context which can not provide the runtime > context. > > I tried using AbstractRichFunction.getRuntimeContext() > <https://ci.apache.org/projects/flink/flink-docs-release-1.3/api/java/org/apache/flink/api/common/functions/AbstractRichFunction.html#getRuntimeContext--> > . which I guess is not allowed from open of scalar or table functions. > > Any help will be appreciated. > > Thanks >
