[FLINK-14068][streaming] Remove unrelated scala APIs

Author: XComp

flink-runtime/src/main/java/org/apache/flink/streaming/api/windowing/time/Time.java

@@ -38,10 +38,11 @@ import org.apache.flink.streaming.api.functions.sink.SinkFunction
 import org.apache.flink.streaming.api.functions.timestamps.{AscendingTimestampExtractor, BoundedOutOfOrdernessTimestampExtractor}
 import org.apache.flink.streaming.api.operators.OneInputStreamOperator
 import org.apache.flink.streaming.api.windowing.assigners._
-import org.apache.flink.streaming.api.windowing.time.Time
 import org.apache.flink.streaming.api.windowing.windows.{GlobalWindow, TimeWindow, Window}
 import org.apache.flink.util.{CloseableIterator, Collector}
 
+import java.time.Duration
+
 import scala.collection.JavaConverters._
 
 /**
@@ -740,55 +741,6 @@ class DataStream[T](stream: JavaStream[T]) {
     filter(filterFun)
   }
 
-  /**
-   * Windows this DataStream into tumbling time windows.
-   *
-   * This is a shortcut for either `.window(TumblingEventTimeWindows.of(size))` or
-   * `.window(TumblingProcessingTimeWindows.of(size))` depending on the time characteristic set
-   * using [[StreamExecutionEnvironment.setStreamTimeCharacteristic]].
-   *
-   * Note: This operation can be inherently non-parallel since all elements have to pass through the
-   * same operator instance. (Only for special cases, such as aligned time windows is it possible to
-   * perform this operation in parallel).
-   *
-   * @param size
-   *   The size of the window.
-   *
-   * @deprecated
-   *   Please use [[windowAll()]] with either [[TumblingEventTimeWindows]] or
-   *   [[TumblingProcessingTimeWindows]]. For more information, see the deprecation notice on
-   *   [[org.apache.flink.streaming.api.TimeCharacteristic]].
-   */
-  @deprecated
-  def timeWindowAll(size: Time): AllWindowedStream[T, TimeWindow] = {
-    new AllWindowedStream(javaStream.timeWindowAll(size))
-  }
-
-  /**
-   * Windows this DataStream into sliding time windows.
-   *
-   * This is a shortcut for either `.window(SlidingEventTimeWindows.of(size, slide))` or
-   * `.window(SlidingProcessingTimeWindows.of(size, slide))` depending on the time characteristic
-   * set using [[StreamExecutionEnvironment.setStreamTimeCharacteristic]].
-   *
-   * Note: This operation can be inherently non-parallel since all elements have to pass through the
-   * same operator instance. (Only for special cases, such as aligned time windows is it possible to
-   * perform this operation in parallel).
-   *
-   * @param size
-   *   The size of the window.
-   *
-   * @deprecated
-   *   Please use [[windowAll()]] with either [[SlidingEventTimeWindows]] or
-   *   [[SlidingProcessingTimeWindows]]. For more information, see the deprecation notice on
-   *   [[org.apache.flink.streaming.api.TimeCharacteristic]].
-   */
-  @deprecated
-  def timeWindowAll(size: Time, slide: Time): AllWindowedStream[T, TimeWindow] = {
-    new AllWindowedStream(javaStream.timeWindowAll(size, slide))
-
-  }
-
   /**
    * Windows this [[DataStream]] into sliding count windows.
    *

flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala

@@ -30,10 +30,11 @@ import org.apache.flink.streaming.api.functions.co.ProcessJoinFunction
 import org.apache.flink.streaming.api.functions.query.{QueryableAppendingStateOperator, QueryableValueStateOperator}
 import org.apache.flink.streaming.api.scala.function.StatefulFunction
 import org.apache.flink.streaming.api.windowing.assigners._
-import org.apache.flink.streaming.api.windowing.time.Time
-import org.apache.flink.streaming.api.windowing.windows.{GlobalWindow, TimeWindow, Window}
+import org.apache.flink.streaming.api.windowing.windows.{GlobalWindow, Window}
 import org.apache.flink.util.Collector
 
+import java.time.Duration
+
 /**
  * @deprecated
  *   All Flink Scala APIs are deprecated and will be removed in a future Flink major version. You
@@ -162,9 +163,9 @@ class KeyedStream[T, K](javaStream: KeyedJavaStream[T, K]) extends DataStream[T]
      *   The upper bound. Needs to be bigger than or equal to the lowerBound
      */
     @PublicEvolving
-    def between(lowerBound: Time, upperBound: Time): IntervalJoined[IN1, IN2, KEY] = {
-      val lowerMillis = lowerBound.toMilliseconds
-      val upperMillis = upperBound.toMilliseconds
+    def between(lowerBound: Duration, upperBound: Duration): IntervalJoined[IN1, IN2, KEY] = {
+      val lowerMillis = lowerBound.toMillis
+      val upperMillis = upperBound.toMillis
       new IntervalJoined[IN1, IN2, KEY](streamOne, streamTwo, lowerMillis, upperMillis)
     }
   }
@@ -236,46 +237,6 @@ class KeyedStream[T, K](javaStream: KeyedJavaStream[T, K]) extends DataStream[T]
   //  Windowing
   // ------------------------------------------------------------------------
 
-  /**
-   * Windows this [[KeyedStream]] into tumbling time windows.
-   *
-   * This is a shortcut for either `.window(TumblingEventTimeWindows.of(size))` or
-   * `.window(TumblingProcessingTimeWindows.of(size))` depending on the time characteristic set
-   * using [[StreamExecutionEnvironment.setStreamTimeCharacteristic()]]
-   *
-   * @param size
-   *   The size of the window.
-   *
-   * @deprecated
-   *   Please use [[window()]] with either [[TumblingEventTimeWindows]] or
-   *   [[TumblingProcessingTimeWindows]]. For more information, see the deprecation notice on
-   *   [[org.apache.flink.streaming.api.TimeCharacteristic]].
-   */
-  @deprecated
-  def timeWindow(size: Time): WindowedStream[T, K, TimeWindow] = {
-    new WindowedStream(javaStream.timeWindow(size))
-  }
-
-  /**
-   * Windows this [[KeyedStream]] into sliding time windows.
-   *
-   * This is a shortcut for either `.window(SlidingEventTimeWindows.of(size))` or
-   * `.window(SlidingProcessingTimeWindows.of(size))` depending on the time characteristic set using
-   * [[StreamExecutionEnvironment.setStreamTimeCharacteristic()]]
-   *
-   * @param size
-   *   The size of the window.
-   *
-   * @deprecated
-   *   Please use [[window()]] with either [[SlidingEventTimeWindows]] or
-   *   [[SlidingProcessingTimeWindows]]. For more information, see the deprecation notice on
-   *   [[org.apache.flink.streaming.api.TimeCharacteristic]].
-   */
-  @deprecated
-  def timeWindow(size: Time, slide: Time): WindowedStream[T, K, TimeWindow] = {
-    new WindowedStream(javaStream.timeWindow(size, slide))
-  }
-
   /**
    * Windows this [[KeyedStream]] into sliding count windows.
    *