CODEWITHSUNDEEP
scalaaggregateapache-flink
Alejandro Alcalde
Alejandro Alcalde

Reputation: 6220

Aggregate Equivalent of Spark in Flink

Is there any equivalent of Spark's RDD Aggregate for Flink's DataSet?

After a few hours of searching it seems there is nothing.

Flink's DataSet API has an aggregate(agg: Aggregations, field: String): AggregateDataSet[T] but from its documentaion it seems its not similar to Spark.

Do I have to implement a custom Aggregations?

Upvotes: 0

Views: 84

Answers (1)

gcandal
gcandal

Reputation: 957

It's not exactly the same as Spark's but did you take a look at reduce?

Upvotes: 1

Related Questions