You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by uc...@apache.org on 2014/12/11 19:16:41 UTC
incubator-flink git commit: [scala] Add withParameters() support for
sinks/sources
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 <al...@gmail.com>
Authored: Thu Dec 11 10:44:25 2014 +0100
Committer: Ufuk Celebi <uc...@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")