提交 b950d5b4 编写于 作者: M mbalassi 提交者: Gyula Fora

[streaming] Serializable no longer needed for examples

Due to the recent serialization changes.
上级 9689ca8f
...@@ -17,7 +17,6 @@ ...@@ -17,7 +17,6 @@
package org.apache.flink.streaming.examples.windowing; package org.apache.flink.streaming.examples.windowing;
import java.io.Serializable;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays; import java.util.Arrays;
import java.util.Random; import java.util.Random;
...@@ -204,7 +203,7 @@ public class StockPrices { ...@@ -204,7 +203,7 @@ public class StockPrices {
// DATA TYPES // DATA TYPES
// ************************************************************************* // *************************************************************************
public static class StockPrice implements Serializable { public static class StockPrice {
private static final long serialVersionUID = 1L; private static final long serialVersionUID = 1L;
public String symbol; public String symbol;
...@@ -227,7 +226,7 @@ public class StockPrices { ...@@ -227,7 +226,7 @@ public class StockPrices {
} }
} }
public static class Count implements Serializable { public static class Count {
private static final long serialVersionUID = 1L; private static final long serialVersionUID = 1L;
public String symbol; public String symbol;
......
...@@ -38,7 +38,7 @@ import scala.util.Random ...@@ -38,7 +38,7 @@ import scala.util.Random
*/ */
object TopSpeedWindowing { 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]) { def main(args: Array[String]) {
if (!parseParameters(args)) { if (!parseParameters(args)) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册