Removed qualified names

Author: XComp

flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Pattern.java

@@ -387,7 +387,7 @@ public Pattern<T, F> oneOrMore() {
      *     applied.
      * @throws MalformedPatternException if the quantifier is not applicable to this pattern.
      */
-    public Pattern<T, F> oneOrMore(@Nullable java.time.Duration windowTime) {
+    public Pattern<T, F> oneOrMore(@Nullable Duration windowTime) {
         checkIfNoNotPattern();
         checkIfQuantifierApplied();
         this.quantifier = Quantifier.looping(quantifier.getConsumingStrategy());
@@ -417,7 +417,7 @@ public Pattern<T, F> greedy() {
      * @throws MalformedPatternException if the quantifier is not applicable to this pattern.
      */
     public Pattern<T, F> times(int times) {
-        return times(times, (java.time.Duration) null);
+        return times(times, null);
     }
 
     /**
@@ -429,7 +429,7 @@ public Pattern<T, F> times(int times) {
      * @return The same pattern with number of times applied
      * @throws MalformedPatternException if the quantifier is not applicable to this pattern.
      */
-    public Pattern<T, F> times(int times, @Nullable java.time.Duration windowTime) {
+    public Pattern<T, F> times(int times, @Nullable Duration windowTime) {
         checkIfNoNotPattern();
         checkIfQuantifierApplied();
         Preconditions.checkArgument(times > 0, "You should give a positive number greater than 0.");
@@ -447,7 +447,7 @@ public Pattern<T, F> times(int times, @Nullable java.time.Duration windowTime) {
      * @throws MalformedPatternException if the quantifier is not applicable to this pattern.
      */
     public Pattern<T, F> times(int from, int to) {
-        return times(from, to, (java.time.Duration) null);
+        return times(from, to, null);
     }
 
     /**
@@ -460,7 +460,7 @@ public Pattern<T, F> times(int from, int to) {
      * @return The same pattern with the number of times range applied
      * @throws MalformedPatternException if the quantifier is not applicable to this pattern.
      */
-    public Pattern<T, F> times(int from, int to, @Nullable java.time.Duration windowTime) {
+    public Pattern<T, F> times(int from, int to, @Nullable Duration windowTime) {
         checkIfNoNotPattern();
         checkIfQuantifierApplied();
         this.quantifier = Quantifier.times(quantifier.getConsumingStrategy());
@@ -481,7 +481,7 @@ public Pattern<T, F> times(int from, int to, @Nullable java.time.Duration window
      * @throws MalformedPatternException if the quantifier is not applicable to this pattern.
      */
     public Pattern<T, F> timesOrMore(int times) {
-        return timesOrMore(times, (java.time.Duration) null);
+        return timesOrMore(times, null);
     }
 
     /**
@@ -496,7 +496,7 @@ public Pattern<T, F> timesOrMore(int times) {
      *     applied.
      * @throws MalformedPatternException if the quantifier is not applicable to this pattern.
      */
-    public Pattern<T, F> timesOrMore(int times, @Nullable java.time.Duration windowTime) {
+    public Pattern<T, F> timesOrMore(int times, @Nullable Duration windowTime) {
         checkIfNoNotPattern();
         checkIfQuantifierApplied();
         this.quantifier = Quantifier.looping(quantifier.getConsumingStrategy());

flink-runtime/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java

@@ -61,6 +61,8 @@
 import org.apache.flink.util.OutputTag;
 import org.apache.flink.util.Preconditions;
 
+import java.time.Duration;
+
 import static org.apache.flink.util.Preconditions.checkArgument;
 import static org.apache.flink.util.Preconditions.checkNotNull;
 
@@ -133,7 +135,7 @@ public AllWindowedStream<T, W> trigger(Trigger<? super T, ? super W> trigger) {
      * <p>Setting an allowed lateness is only valid for event-time windows.
      */
     @PublicEvolving
-    public AllWindowedStream<T, W> allowedLateness(java.time.Duration lateness) {
+    public AllWindowedStream<T, W> allowedLateness(Duration lateness) {
         final long millis = lateness.toMillis();
         checkArgument(millis >= 0, "The allowed lateness cannot be negative.");
 
@@ -144,7 +146,7 @@ public AllWindowedStream<T, W> allowedLateness(java.time.Duration lateness) {
     /**
      * Send late arriving data to the side output identified by the given {@link OutputTag}. Data is
      * considered late after the watermark has passed the end of the window plus the allowed
-     * lateness set using {@link #allowedLateness(java.time.Duration)}.
+     * lateness set using {@link #allowedLateness(Duration)}.
      *
      * <p>You can get the stream of late data using {@link
      * SingleOutputStreamOperator#getSideOutput(OutputTag)} on the {@link

flink-runtime/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java

@@ -45,6 +45,7 @@
 import javax.annotation.Nullable;
 
 import java.io.IOException;
+import java.time.Duration;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Objects;
@@ -204,7 +205,7 @@ public <W extends Window> WithWindow<T1, T2, KEY, W> window(
                         assigner,
                         null,
                         null,
-                        (java.time.Duration) null);
+                        null);
             }
         }
     }
@@ -236,7 +237,7 @@ public static class WithWindow<T1, T2, KEY, W extends Window> {
 
         private final Evictor<? super TaggedUnion<T1, T2>, ? super W> evictor;
 
-        @Nullable private final java.time.Duration allowedLateness;
+        @Nullable private final Duration allowedLateness;
 
         private WindowedStream<TaggedUnion<T1, T2>, KEY, W> windowedStream;
 
@@ -249,7 +250,7 @@ protected WithWindow(
                 WindowAssigner<? super TaggedUnion<T1, T2>, W> windowAssigner,
                 Trigger<? super TaggedUnion<T1, T2>, ? super W> trigger,
                 Evictor<? super TaggedUnion<T1, T2>, ? super W> evictor,
-                @Nullable java.time.Duration allowedLateness) {
+                @Nullable Duration allowedLateness) {
             this.input1 = input1;
             this.input2 = input2;
 
@@ -305,11 +306,10 @@ public WithWindow<T1, T2, KEY, W> evictor(
         /**
          * Sets the time by which elements are allowed to be late.
          *
-         * @see WindowedStream#allowedLateness(java.time.Duration)
+         * @see WindowedStream#allowedLateness(Duration)
          */
         @PublicEvolving
-        public WithWindow<T1, T2, KEY, W> allowedLateness(
-                @Nullable java.time.Duration newLateness) {
+        public WithWindow<T1, T2, KEY, W> allowedLateness(@Nullable Duration newLateness) {
             return new WithWindow<>(
                     input1,
                     input2,
@@ -426,7 +426,7 @@ public <T> SingleOutputStreamOperator<T> with(
         }
 
         @VisibleForTesting
-        Optional<java.time.Duration> getAllowedLatenessDuration() {
+        Optional<Duration> getAllowedLatenessDuration() {
             return Optional.ofNullable(allowedLateness);
         }
 

flink-runtime/src/main/java/org/apache/flink/streaming/api/datastream/JoinedStreams.java

@@ -36,6 +36,7 @@
 
 import javax.annotation.Nullable;
 
+import java.time.Duration;
 import java.util.Optional;
 
 import static java.util.Objects.requireNonNull;
@@ -190,7 +191,7 @@ public <W extends Window> WithWindow<T1, T2, KEY, W> window(
                         assigner,
                         null,
                         null,
-                        (java.time.Duration) null);
+                        null);
             }
         }
     }
@@ -222,7 +223,7 @@ public static class WithWindow<T1, T2, KEY, W extends Window> {
 
         private final Evictor<? super TaggedUnion<T1, T2>, ? super W> evictor;
 
-        @Nullable private final java.time.Duration allowedLateness;
+        @Nullable private final Duration allowedLateness;
 
         private CoGroupedStreams.WithWindow<T1, T2, KEY, W> coGroupedWindowedStream;
 
@@ -236,7 +237,7 @@ protected WithWindow(
                 WindowAssigner<? super TaggedUnion<T1, T2>, W> windowAssigner,
                 Trigger<? super TaggedUnion<T1, T2>, ? super W> trigger,
                 Evictor<? super TaggedUnion<T1, T2>, ? super W> evictor,
-                @Nullable java.time.Duration allowedLateness) {
+                @Nullable Duration allowedLateness) {
 
             this.input1 = requireNonNull(input1);
             this.input2 = requireNonNull(input2);
@@ -294,11 +295,10 @@ public WithWindow<T1, T2, KEY, W> evictor(
         /**
          * Sets the time by which elements are allowed to be late.
          *
-         * @see WindowedStream#allowedLateness(java.time.Duration)
+         * @see WindowedStream#allowedLateness(Duration)
          */
         @PublicEvolving
-        public WithWindow<T1, T2, KEY, W> allowedLateness(
-                @Nullable java.time.Duration newLateness) {
+        public WithWindow<T1, T2, KEY, W> allowedLateness(@Nullable Duration newLateness) {
             return new WithWindow<>(
                     input1,
                     input2,
@@ -486,7 +486,7 @@ public <T> SingleOutputStreamOperator<T> with(
         }
 
         @VisibleForTesting
-        Optional<java.time.Duration> getAllowedLatenessDuration() {
+        Optional<Duration> getAllowedLatenessDuration() {
             return Optional.ofNullable(allowedLateness);
         }
 

flink-runtime/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java

@@ -429,8 +429,7 @@ public <R> SingleOutputStreamOperator<R> process(
 
     /**
      * Join elements of this {@link KeyedStream} with elements of another {@link KeyedStream} over a
-     * time interval that can be specified with {@link IntervalJoin#between(java.time.Duration,
-     * java.time.Duration)}.
+     * time interval that can be specified with {@link IntervalJoin#between(Duration, Duration)}.
      *
      * @param otherStream The other keyed stream to join this keyed stream with
      * @param <T1> Type parameter of elements in the other stream
@@ -500,8 +499,7 @@ public IntervalJoin<T1, T2, KEY> inProcessingTime() {
          * @param upperBound The upper bound. Needs to be bigger than or equal to the lowerBound
          */
         @PublicEvolving
-        public IntervalJoined<T1, T2, KEY> between(
-                java.time.Duration lowerBound, java.time.Duration upperBound) {
+        public IntervalJoined<T1, T2, KEY> between(Duration lowerBound, Duration upperBound) {
             if (timeBehaviour != TimeBehaviour.EventTime) {
                 throw new UnsupportedTimeCharacteristicException(
                         "Time-bounded stream joins are only supported in event time");

flink-runtime/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java

@@ -42,6 +42,8 @@
 import org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorBuilder;
 import org.apache.flink.util.OutputTag;
 
+import java.time.Duration;
+
 import static org.apache.flink.util.Preconditions.checkNotNull;
 
 /**
@@ -104,15 +106,15 @@ public WindowedStream<T, K, W> trigger(Trigger<? super T, ? super W> trigger) {
      * <p>Setting an allowed lateness is only valid for event-time windows.
      */
     @PublicEvolving
-    public WindowedStream<T, K, W> allowedLateness(java.time.Duration lateness) {
+    public WindowedStream<T, K, W> allowedLateness(Duration lateness) {
         builder.allowedLateness(lateness);
         return this;
     }
 
     /**
      * Send late arriving data to the side output identified by the given {@link OutputTag}. Data is
      * considered late after the watermark has passed the end of the window plus the allowed
-     * lateness set using {@link #allowedLateness(java.time.Duration)}.
+     * lateness set using {@link #allowedLateness(Duration)}.
      *
      * <p>You can get the stream of late data using {@link
      * SingleOutputStreamOperator#getSideOutput(OutputTag)} on the {@link

flink-runtime/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingEventTimeWindows.java

@@ -26,6 +26,7 @@
 import org.apache.flink.streaming.api.windowing.triggers.Trigger;
 import org.apache.flink.streaming.api.windowing.windows.TimeWindow;
 
+import java.time.Duration;
 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.List;
@@ -115,7 +116,7 @@ public String toString() {
      * @param slide The slide interval of the generated windows.
      * @return The time policy.
      */
-    public static SlidingEventTimeWindows of(java.time.Duration size, java.time.Duration slide) {
+    public static SlidingEventTimeWindows of(Duration size, Duration slide) {
         return new SlidingEventTimeWindows(size.toMillis(), slide.toMillis(), 0);
     }
 
@@ -138,8 +139,7 @@ public static SlidingEventTimeWindows of(java.time.Duration size, java.time.Dura
      * @param offset The offset which window start would be shifted by.
      * @return The time policy.
      */
-    public static SlidingEventTimeWindows of(
-            java.time.Duration size, java.time.Duration slide, java.time.Duration offset) {
+    public static SlidingEventTimeWindows of(Duration size, Duration slide, Duration offset) {
         return new SlidingEventTimeWindows(size.toMillis(), slide.toMillis(), offset.toMillis());
     }
 

flink-runtime/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingProcessingTimeWindows.java

@@ -26,6 +26,7 @@
 import org.apache.flink.streaming.api.windowing.triggers.Trigger;
 import org.apache.flink.streaming.api.windowing.windows.TimeWindow;
 
+import java.time.Duration;
 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.List;
@@ -109,8 +110,7 @@ public String toString() {
      * @param slide The slide interval of the generated windows.
      * @return The time policy.
      */
-    public static SlidingProcessingTimeWindows of(
-            java.time.Duration size, java.time.Duration slide) {
+    public static SlidingProcessingTimeWindows of(Duration size, Duration slide) {
         return new SlidingProcessingTimeWindows(size.toMillis(), slide.toMillis(), 0);
     }
 
@@ -133,8 +133,7 @@ public static SlidingProcessingTimeWindows of(
      * @param offset The offset which window start would be shifted by.
      * @return The time policy.
      */
-    public static SlidingProcessingTimeWindows of(
-            java.time.Duration size, java.time.Duration slide, java.time.Duration offset) {
+    public static SlidingProcessingTimeWindows of(Duration size, Duration slide, Duration offset) {
         return new SlidingProcessingTimeWindows(
                 size.toMillis(), slide.toMillis(), offset.toMillis());
     }

flink-runtime/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingEventTimeWindows.java

@@ -26,6 +26,7 @@
 import org.apache.flink.streaming.api.windowing.triggers.Trigger;
 import org.apache.flink.streaming.api.windowing.windows.TimeWindow;
 
+import java.time.Duration;
 import java.util.Collection;
 import java.util.Collections;
 
@@ -109,7 +110,7 @@ public String toString() {
      * @param size The size of the generated windows.
      * @return The time policy.
      */
-    public static TumblingEventTimeWindows of(java.time.Duration size) {
+    public static TumblingEventTimeWindows of(Duration size) {
         return new TumblingEventTimeWindows(size.toMillis(), 0, WindowStagger.ALIGNED);
     }
 
@@ -130,7 +131,7 @@ public static TumblingEventTimeWindows of(java.time.Duration size) {
      * @param size The size of the generated windows.
      * @param offset The offset which window start would be shifted by.
      */
-    public static TumblingEventTimeWindows of(java.time.Duration size, java.time.Duration offset) {
+    public static TumblingEventTimeWindows of(Duration size, Duration offset) {
         return new TumblingEventTimeWindows(
                 size.toMillis(), offset.toMillis(), WindowStagger.ALIGNED);
     }
@@ -146,7 +147,7 @@ public static TumblingEventTimeWindows of(java.time.Duration size, java.time.Dur
      */
     @PublicEvolving
     public static TumblingEventTimeWindows of(
-            java.time.Duration size, java.time.Duration offset, WindowStagger windowStagger) {
+            Duration size, Duration offset, WindowStagger windowStagger) {
         return new TumblingEventTimeWindows(size.toMillis(), offset.toMillis(), windowStagger);
     }
 

flink-runtime/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingProcessingTimeWindows.java

@@ -26,6 +26,7 @@
 import org.apache.flink.streaming.api.windowing.triggers.Trigger;
 import org.apache.flink.streaming.api.windowing.windows.TimeWindow;
 
+import java.time.Duration;
 import java.util.Collection;
 import java.util.Collections;
 
@@ -106,7 +107,7 @@ public String toString() {
      * @param size The size of the generated windows.
      * @return The time policy.
      */
-    public static TumblingProcessingTimeWindows of(java.time.Duration size) {
+    public static TumblingProcessingTimeWindows of(Duration size) {
         return new TumblingProcessingTimeWindows(size.toMillis(), 0, WindowStagger.ALIGNED);
     }
 
@@ -128,8 +129,7 @@ public static TumblingProcessingTimeWindows of(java.time.Duration size) {
      * @param offset The offset which window start would be shifted by.
      * @return The time policy.
      */
-    public static TumblingProcessingTimeWindows of(
-            java.time.Duration size, java.time.Duration offset) {
+    public static TumblingProcessingTimeWindows of(Duration size, Duration offset) {
         return new TumblingProcessingTimeWindows(
                 size.toMillis(), offset.toMillis(), WindowStagger.ALIGNED);
     }
@@ -146,7 +146,7 @@ public static TumblingProcessingTimeWindows of(
      */
     @PublicEvolving
     public static TumblingProcessingTimeWindows of(
-            java.time.Duration size, java.time.Duration offset, WindowStagger windowStagger) {
+            Duration size, Duration offset, WindowStagger windowStagger) {
         return new TumblingProcessingTimeWindows(size.toMillis(), offset.toMillis(), windowStagger);
     }