[FLINK-2889] Port LongSerializationSpeedBenchmark to JMH.

This closes #1284
This closes #1283

* implemented algorithm
* implemented integration tests
* updated gelly guide

This closes #1269

This closes #1282

This closes #1274

This enhances the TriggerResult enum with methods isFire() and isPurge()
that simplify the logic in WindowOperator.processTriggerResult().

Also, the operator now keeps track of the current watermark and fires
immediately if a trigger registers an event-time callback for a
timestamp that lies in the past. For this the TriggerResult now as
method merge() that allows to merge to TriggerResultS.

Before these trigger methods had no information about the window that
they are responsible for. This information might be required for
implementing more advanced trigger behaviour.

This fixes the aggregators to make copies of the objects so that it
works with window operators that are not mutable-object safe.

This also disables object copy in WindowOperator and
NonKeyedWindowOperator.

Before, the StreamRecords was not copied, now it is.

Operators defer object creation when object reuse is disabled.

This closes #1288

This closes #1290

Rename config key prefix from 'ha.zookeeper' to 'recovery.zookeeper'
Rename config key from 'state.backend.fs.dir.recovery' => 'state.backend.fs.recoverydir'
Move ZooKeeper file system state backend configuration keys

This closes #1286

Rename Match*Test to Join*Test and MapTaskTest to FlatMapTaskTest

This closes #1294

0.10-SNAPSHOT continues on branch release-0.10

Before it would only trigger if expectedTime < time. Now it is
expectedTime <= time.

This closes #1252

This closes #1279

[FLINK-2206] [webui] Fix incorrect counts of finished, canceled, and failed jobs in new web dashboard

This closes #1287

Before, this was not set, leading to incorrect results if KV-State was
used in the WindowFunction.

This also adds a test.

[FLINK-2887] [gelly] make sendMessageToAllNeighbors respect the EdgeDirection if set in the configuration

This closes #1281

- create Scala 2.11 binaries
- remove Java 6 specific checks
- cleanup

Tested for 0.10.0-rc0

In very rare cases it could happen that a checkpoint would be performed
after the ValidatingSink signaled that it had seen all expected
elements. If this happened the job would be restarted with the already
complete state and we would never finish since no more elements would
arrive.

This adds a check in open() of ValidatingSink that signals success if we
already have the final state.

The HandlerRedirectUtils.getRedirectAddress decides whether the retrieved leader address is equal to the local job manager address. The local job manager address is, however, in the form akka.tcp://flink@url/user/jobmanager whereas the leader address can be akka://flink/user/jobmanager if the local job manager is the current leader. Such a case produced a warning which is not correct. This PR checks for the local job manager address and signals that no redirection has to be done if it receives akka://flink/user/jobmanager.

Add test for HandlerRedirectUtils

This closes #1280.

This was previously reported as FLINK-2625 (commit 8a849372).
The Client class was concurrently refactored with FLINK-2097 (commit 71bf2f57).

This closes #1278

A collection of small documentation and grammar updates.

This closes #1277

This closes #1275

Multiple TaskManager filesystems can be used by configuring multiple temporary directories.
This patch changes the process of spilling files from a per-operator round-robin to a global
round-robin such that each directory is written to in turn across all operators, reducing
unbalanced I/O due to bunching.

This closes #1272

This closes #1260

This closes #1170

This adds Time.milliseconds(), Time.seconds(), and so on.

[FLINK-2872] [Documentation] Update the documentation for Scala part to add ExecutionEnvironment.readFileOfPrimitives.

Add the missing Scala part for ExecutionEnvironment.readFileOfPrimitives API doc in the
programming guide.

Author: Henry Saputra <hsaputra@apache.org>

Closes #1268 from hsaputra/add_readFileOfPrimitives_scala_guide and squashes the following commits:

f543436 [Henry Saputra] Add variant of ExecutionEnvironment.readFileOfPrimitives in Java with additional delimiter.
1209019 [Henry Saputra] [FLINK-2872] [Documentation] Update the documentation for Scala part to add readFileOfPrimitives.