flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Darshan Singh <darshan.m...@gmail.com>
Subject Re: Getting runtime context from scalar and table functions
Date Wed, 04 Apr 2018 20:01:02 GMT
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.


On Wed, Apr 4, 2018 at 8:51 PM, Fabian Hueske <fhueske@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.meel@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

View raw message