Repository: flink Updated Branches: refs/heads/release-0.9 012dd0503 -> 0186a979f
Revert API-breaking change: "[FLINK-2238][api] Generalized fromCollection(Seq) to fromCollection(Iterable)" This reverts commit 3e31ea647c76c85cd2371427b5735cb2d9a84266. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0186a979 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0186a979 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0186a979 Branch: refs/heads/release-0.9 Commit: 0186a979fbb01a5e17cfaa9b1f128cae2015889d Parents: 012dd05 Author: Fabian Hueske <fhue...@apache.org> Authored: Mon Aug 3 12:04:06 2015 +0200 Committer: Fabian Hueske <fhue...@apache.org> Committed: Mon Aug 3 12:05:06 2015 +0200 ---------------------------------------------------------------------- .../scala/org/apache/flink/api/scala/ExecutionEnvironment.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/0186a979/flink-scala/src/main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala ---------------------------------------------------------------------- diff --git a/flink-scala/src/main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala b/flink-scala/src/main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala index d53c54c..28e8458 100644 --- a/flink-scala/src/main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala +++ b/flink-scala/src/main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala @@ -455,13 +455,13 @@ class ExecutionEnvironment(javaEnv: JavaEnv) { } /** - * Creates a DataSet from the given non-empty [[Iterable]]. + * Creates a DataSet from the given non-empty [[Seq]]. * * Note that this operation will result in a non-parallel data source, i.e. a data source with * a parallelism of one. */ def fromCollection[T: ClassTag : TypeInformation]( - data: Iterable[T]): DataSet[T] = { + data: Seq[T]): DataSet[T] = { require(data != null, "Data must not be null.") val typeInfo = implicitly[TypeInformation[T]]
