From b950d5b499278b4213a540d1e41478aaffebe714 Mon Sep 17 00:00:00 2001 From: mbalassi Date: Sun, 26 Apr 2015 08:41:13 +0200 Subject: [PATCH] [streaming] Serializable no longer needed for examples Due to the recent serialization changes. --- .../flink/streaming/examples/windowing/StockPrices.java | 5 ++--- .../scala/examples/windowing/TopSpeedWindowing.scala | 2 +- 2 files changed, 3 insertions(+), 4 deletions(-) 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 4fba8986df5..ab29d3c3f60 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; 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 76f4d2d408b..9102ed77a1f 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)) { -- GitLab