You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by gy...@apache.org on 2015/04/26 14:58:50 UTC
[2/2] flink git commit: [streaming] Serializable no longer needed for
examples
[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 <mb...@apache.org>
Authored: Sun Apr 26 08:41:13 2015 +0200
Committer: Gyula Fora <gy...@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)) {