Thanks for getting back to me. I was trying to see various options to accumulate(sort of list append) some of my data. The amount of appended data is quite small so I wanted to see if I can use accumulators and once the job is done I can get all the data and then use the way I want to use.
I guess I will try the metrics as well to see how that goes. Thanks On Wed, Apr 4, 2018 at 8:51 PM, Fabian Hueske <fhue...@gmail.com> wrote: > 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 >> > >
