Closes #1071

This closes #1043

This closes #1044

This closes #1070

This closes #1062

[FLINK-2587] [streaming] Make sure that close() is not called while checkpoint methods are in progress.

[FLINK-2584] [java api] Downgrade version of javakaffee kryo serializers, for compatibility with kryo 2.4

  - reworked package structure of utils and wordcount.stormoperators package
  - reword class hierarchy of *FileSpout and *InMemorySpout
  - fixed pom.xml to assembly jars correctly
  - simplified example jar file names
  - replace maven-assembly-plugin with maven-shade-plugin (removed assembly.xml file)
  - extended README and documenation to building and using correct jars

Additional minor changes:
 - comment typo in FlinkSubmitter
 - removed version number in hardcoded jar file name

This closes #1037

  - Extend ValueTypeInfo to check whether the type is basic value or not
  - Extend TupleTypeInfo to support Value types
  - Add three unit tests and an integration test
  - Rename CsvReaderWithPOJOITCase to CsvReaderITCase
  - Refactor CsvReaderITCase to use collect method

This closes #1053

This closes #1065

[FLINK-2386] [kafka connector] Move Kafka connector classes to 'org.apache.flink.streaming.connectors.kafka'

[FLINK-2386] [kafka connector] Remove copied Kafka code again. Implemented our own topic metadata retrieval.

This closes #1039

[FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport'

[streaming] Cleanup de-/serialization schema, add TypeInformationSerializationSchema prominent, add tests.

This closes #996

This closes #991.

This closes #1063.

  - check for memory availability before probing
  - correctly compute memory required for recursive build fast path
  - remove all temp files properly

- also adapt config.sh to use the same cross-platform compatible mechanism

This closes #1049.

This is needed because the Hadoop IF/OF's are using Hadoop's FileSystem stack, which is using
the security credentials passed in the JobConf / Job class in the getSplits() method.

Note that access to secured Hadoop 1.x using Hadoop IF/OF's is not possible with this change.
This limitation is due to missing methods in the old APIs.

- Add some comments & change dependency scope to test

This closes #1056.

- Address PR comments

This closes #1051.

- Address PR comments

This closes #1050.

  - Expand the verification boundary for random sampler test
  - Increase the number of times we sample

This closes #1047

[FLINK-2563] [gelly] extended the run() method of GraphAlgorithm interface to return an arbitrary type

This closes #1042

  - disabled avro-maven-plugin within Eclipse via <pluginManagement> ... <lifecyleMappingMetaData>

This closes #1041