flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fhue...@apache.org
Subject flink git commit: [FLINK-2238][api] Generalized fromCollection(Seq) to fromCollection(Iterable)
Date Thu, 30 Jul 2015 22:38:45 GMT
Repository: flink
Updated Branches:
  refs/heads/release-0.9 c756fe8eb -> 3e31ea647


[FLINK-2238][api] Generalized fromCollection(Seq) to fromCollection(Iterable)


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3e31ea64
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3e31ea64
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3e31ea64

Branch: refs/heads/release-0.9
Commit: 3e31ea647c76c85cd2371427b5735cb2d9a84266
Parents: c756fe8
Author: Sachin Goel <sachingoel0101@gmail.com>
Authored: Thu Jul 30 13:54:26 2015 +0530
Committer: Fabian Hueske <fhueske@apache.org>
Committed: Fri Jul 31 00:38:09 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/3e31ea64/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 28e8458..d53c54c 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 [[Seq]].
+   * Creates a DataSet from the given non-empty [[Iterable]].
    *
    * 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: Seq[T]): DataSet[T] = {
+      data: Iterable[T]): DataSet[T] = {
     require(data != null, "Data must not be null.")
 
     val typeInfo = implicitly[TypeInformation[T]]


Mime
View raw message