Re: Accumulators in Table API

2020-07-20 Thread Dawid Wysakowicz
Hi Flavio. You don't have access to accumulators in Table API. A few other ways that come to my mind are: 1. Use existing metrics e.g. operator input/output records. 2. Use metrics in a UDF 3. Have a regular count (you can have multiple queries optimized into a single grap

Accumulators in Table API

2020-07-16 Thread Flavio Pompermaier
Hi to all, in my legacy code (using Dataset api) I used to add a map function just after the Source read and keep the count of the rows. In this way I had a very light and unobtrusive way of counting the rows of a dataset. Can I do something similar in table API? Is there a way to use accumulators?