flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From u..@apache.org
Subject incubator-flink git commit: [scala] Add withParameters() support for sinks/sources
Date Thu, 11 Dec 2014 18:16:41 GMT
Repository: incubator-flink
Updated Branches:
  refs/heads/master 1a2bbebcf -> 099b9fda1


[scala] Add withParameters() support for sinks/sources

This closes #261.


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

Branch: refs/heads/master
Commit: 099b9fda181c49243639db51b001e4fdd5826575
Parents: 1a2bbeb
Author: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Authored: Thu Dec 11 10:44:25 2014 +0100
Committer: Ufuk Celebi <uce@apache.org>
Committed: Thu Dec 11 19:16:18 2014 +0100

----------------------------------------------------------------------
 .../src/main/scala/org/apache/flink/api/scala/DataSet.scala        | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/099b9fda/flink-scala/src/main/scala/org/apache/flink/api/scala/DataSet.scala
----------------------------------------------------------------------
diff --git a/flink-scala/src/main/scala/org/apache/flink/api/scala/DataSet.scala b/flink-scala/src/main/scala/org/apache/flink/api/scala/DataSet.scala
index e16a6e6..2edf65e 100644
--- a/flink-scala/src/main/scala/org/apache/flink/api/scala/DataSet.scala
+++ b/flink-scala/src/main/scala/org/apache/flink/api/scala/DataSet.scala
@@ -250,6 +250,8 @@ class DataSet[T: ClassTag](set: JavaDataSet[T]) {
   def withParameters(parameters: Configuration): DataSet[T] = {
     javaSet match {
       case udfOp: UdfOperator[_] => udfOp.withParameters(parameters)
+      case source: DataSource[_] => source.withParameters(parameters)
+      case sink: DataSink[_] => sink.withParameters(parameters)
       case _ =>
         throw new UnsupportedOperationException("Operator " + javaSet.toString + " cannot
have " +
           "parameters")


Mime
View raw message