flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gyf...@apache.org
Subject [2/2] flink git commit: [streaming] Serializable no longer needed for examples
Date Sun, 26 Apr 2015 12:58:50 GMT
[streaming] Serializable no longer needed for examples

Due to the recent serialization changes.


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

Branch: refs/heads/master
Commit: b950d5b499278b4213a540d1e41478aaffebe714
Parents: 9689ca8
Author: mbalassi <mbalassi@apache.org>
Authored: Sun Apr 26 08:41:13 2015 +0200
Committer: Gyula Fora <gyfora@apache.org>
Committed: Sun Apr 26 14:57:06 2015 +0200

----------------------------------------------------------------------
 .../apache/flink/streaming/examples/windowing/StockPrices.java  | 5 ++---
 .../streaming/scala/examples/windowing/TopSpeedWindowing.scala  | 2 +-
 2 files changed, 3 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/b950d5b4/flink-staging/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/windowing/StockPrices.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/windowing/StockPrices.java
b/flink-staging/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/windowing/StockPrices.java
index 4fba898..ab29d3c 100644
--- a/flink-staging/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/windowing/StockPrices.java
+++ b/flink-staging/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/windowing/StockPrices.java
@@ -17,7 +17,6 @@
 
 package org.apache.flink.streaming.examples.windowing;
 
-import java.io.Serializable;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Random;
@@ -204,7 +203,7 @@ public class StockPrices {
 	// DATA TYPES
 	// *************************************************************************
 
-	public static class StockPrice implements Serializable {
+	public static class StockPrice {
 
 		private static final long serialVersionUID = 1L;
 		public String symbol;
@@ -227,7 +226,7 @@ public class StockPrices {
 		}
 	}
 
-	public static class Count implements Serializable {
+	public static class Count {
 		
 		private static final long serialVersionUID = 1L;
 		public String symbol;

http://git-wip-us.apache.org/repos/asf/flink/blob/b950d5b4/flink-staging/flink-streaming/flink-streaming-examples/src/main/scala/org/apache/flink/streaming/scala/examples/windowing/TopSpeedWindowing.scala
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-examples/src/main/scala/org/apache/flink/streaming/scala/examples/windowing/TopSpeedWindowing.scala
b/flink-staging/flink-streaming/flink-streaming-examples/src/main/scala/org/apache/flink/streaming/scala/examples/windowing/TopSpeedWindowing.scala
index 76f4d2d..9102ed7 100644
--- a/flink-staging/flink-streaming/flink-streaming-examples/src/main/scala/org/apache/flink/streaming/scala/examples/windowing/TopSpeedWindowing.scala
+++ b/flink-staging/flink-streaming/flink-streaming-examples/src/main/scala/org/apache/flink/streaming/scala/examples/windowing/TopSpeedWindowing.scala
@@ -38,7 +38,7 @@ import scala.util.Random
  */
 object TopSpeedWindowing {
 
-  case class CarEvent(carId: Int, speed: Int, distance: Double, time: Long) extends Serializable
+  case class CarEvent(carId: Int, speed: Int, distance: Double, time: Long)
 
   def main(args: Array[String]) {
     if (!parseParameters(args)) {


Mime
View raw message