apache/incubator-flink — pull request #63 by uce (2014-07-07 14:51:27+00:00)
Title: [FLINK-758] Add count operator to DataSet

- Adds a count operator to DataSet:

```java
DataSet text = env.fromElements(
"Who's there?",
"I think I hear them. Stand, ho! Who's there?");
DataSet count = text.count(); // 2
```
- Adds an all (ungrouped) reduce variant, which allows to specify an initial value to the reduce function
- Adds an utility method to InstantiationUtil to serialize a record to a byte array
- Fixes some javadocs warnings in DataSet

I've tested the count operator on a cluster with DOP 1, 200 and verified the results with `cat | wc -l`.