Repository: flink Updated Branches: refs/heads/master 91f9bfc78 -> 0ab9d4665
[scala api] Minor code cleanup for compiler warnings Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0ab9d466 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0ab9d466 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0ab9d466 Branch: refs/heads/master Commit: 0ab9d4665de11f31e34766463b65602cf6d55e84 Parents: 56b7f85 Author: Stephan Ewen <[email protected]> Authored: Thu Feb 5 11:16:57 2015 +0100 Committer: Stephan Ewen <[email protected]> Committed: Thu Feb 5 12:17:15 2015 +0100 ---------------------------------------------------------------------- .../apache/flink/api/scala/typeutils/EitherSerializer.scala | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/0ab9d466/flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/EitherSerializer.scala ---------------------------------------------------------------------- diff --git a/flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/EitherSerializer.scala b/flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/EitherSerializer.scala index dcab0b8..cb72486 100644 --- a/flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/EitherSerializer.scala +++ b/flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/EitherSerializer.scala @@ -42,8 +42,8 @@ class EitherSerializer[A, B, T <: Either[A, B]]( override def getLength: Int = -1 override def copy(from: T): T = from match { - case Left(a: A) => Left(leftSerializer.copy(a)).asInstanceOf[T] - case Right(b: B) => Right(rightSerializer.copy(b)).asInstanceOf[T] + case Left(a) => Left(leftSerializer.copy(a)).asInstanceOf[T] + case Right(b) => Right(rightSerializer.copy(b)).asInstanceOf[T] } override def copy(from: T, reuse: T): T = copy(from) @@ -59,10 +59,10 @@ class EitherSerializer[A, B, T <: Either[A, B]]( } override def serialize(either: T, target: DataOutputView): Unit = either match { - case Left(a: A) => + case Left(a) => target.writeBoolean(true) leftSerializer.serialize(a, target) - case Right(b: B) => + case Right(b) => target.writeBoolean(false) rightSerializer.serialize(b, target) }
