ctions.
> This would be a good improvement though. Check the DataSetAggregate class
> to learn how aggregations are translated into Flink Dataset programs.
>
>
>
> Best, Fabian
>
>
>
>
>
> *Von: *Cody Innowhere
> *Gesendet: *Mittwoch, 29. J
ope that helps.
>
> Timo
>
>
> On 29.06.2016 05:24, Cody Innowhere wrote:
>
>> Hi guys,
>> I found that in CodeGenUtils, default values of numeric primitive types
>> are
>> set to -1, what's the consideration of setting the default values to -1
>> ins
Hi guys,
I found that in CodeGenUtils, default values of numeric primitive types are
set to -1, what's the consideration of setting the default values to -1
instead of 0? IMHO 0 would make more sense, although in DB if a field is
null then all operations on this field will return null anyway.
Hi guys,
I'm trying to add a UDF in Flink table API, say, in DataSet table API.
My example code is as follows:
---
object WordCountTable {
case class WC(word: String, num: Int)
def main(args: Array[String]): Unit = {
// set up execution environment
val env = Ex
Counter of dropwizard is thread-safe.
I think dropwizard metrics are implemented fairly well and used quite
widely in open source projects, I personally on the side of using
dropwizard metrics rather than re-implement them, unless for performance
reasons. Still, I'm +1 for adding a wrapper on top o
Yes, it's the name "count" that caused the problem, thanks for your
explanation.
Still, the word-count example uses an embarrassing field name in table API
case that I would naturally use "select word, count" in SQL while
forgetting the keyword...
On Mon, Jun 6, 2016 at 4:31 PM, Ufuk Celebi wrote
Hi guys,
I'm trying to run Table-API in master trunk using the sql/registerDataSet
APIs in TableEnvironment class.
According to the doc in table.md, after registering a table, I should be
able to use a sql query on the tabelEnv, so I made a slight change in
WordCountTable.scala by simply adding tw
