Package org.apache.flink.streaming.api.datastream

Class JoinedStreams.WithWindow<T1,​T2,​KEY,​W extends Window>

  • Type Parameters:
    T1 - Type of the elements from the first input
    T2 - Type of the elements from the second input
    KEY - Type of the key. This must be the same for both inputs
    W - Type of Window on which the join operation works.
    Enclosing class:
    JoinedStreams<T1,​T2>
    @Public
public static class JoinedStreams.WithWindow<T1,​T2,​KEY,​W extends Window>
extends Object
    A join operation that has KeySelectors defined for both inputs as well as a WindowAssigner.

    • Method Detail

      • evictor

        @PublicEvolving
public JoinedStreams.WithWindow<T1,​T2,​KEY,​W> evictor​(Evictor<? super CoGroupedStreams.TaggedUnion<T1,​T2>,​? super W> newEvictor)
        Sets the Evictor that should be used to evict elements from a window before emission.

        Note: When using an evictor window performance will degrade significantly, since pre-aggregation of window results cannot be used.

      • apply

        public <T> DataStream<T> apply​(org.apache.flink.api.common.functions.JoinFunction<T1,​T2,​T> function)
        Completes the join operation with the user function that is executed for each combination of elements with the same key in a window.

        Note: This method's return type does not support setting an operator-specific parallelism. Due to binary backwards compatibility, this cannot be altered. Use the with(JoinFunction) method to set an operator-specific parallelism.

      • with

        @PublicEvolving
@Deprecated
public <T> SingleOutputStreamOperator<T> with​(org.apache.flink.api.common.functions.JoinFunction<T1,​T2,​T> function)
        Deprecated.
        This method will be removed once the apply(JoinFunction) method is fixed in the next major version of Flink (2.0).
        Completes the join operation with the user function that is executed for each combination of elements with the same key in a window.

        Note: This is a temporary workaround while the apply(JoinFunction) method has the wrong return type and hence does not allow one to set an operator-specific parallelism

      • apply

        public <T> DataStream<T> apply​(org.apache.flink.api.common.functions.FlatJoinFunction<T1,​T2,​T> function,
                               org.apache.flink.api.common.typeinfo.TypeInformation<T> resultType)
        Completes the join operation with the user function that is executed for each combination of elements with the same key in a window.

        Note: This method's return type does not support setting an operator-specific parallelism. Due to binary backwards compatibility, this cannot be altered. Use the with(JoinFunction, TypeInformation), method to set an operator-specific parallelism.

      • apply

        public <T> DataStream<T> apply​(org.apache.flink.api.common.functions.FlatJoinFunction<T1,​T2,​T> function)
        Completes the join operation with the user function that is executed for each combination of elements with the same key in a window.

        Note: This method's return type does not support setting an operator-specific parallelism. Due to binary backwards compatibility, this cannot be altered. Use the with(FlatJoinFunction), method to set an operator-specific parallelism.

      • with

        @PublicEvolving
@Deprecated
public <T> SingleOutputStreamOperator<T> with​(org.apache.flink.api.common.functions.FlatJoinFunction<T1,​T2,​T> function)
        Deprecated.
        This method will be removed once the apply(FlatJoinFunction) method is fixed in the next major version of Flink (2.0).
        Completes the join operation with the user function that is executed for each combination of elements with the same key in a window.

        Note: This is a temporary workaround while the apply(FlatJoinFunction) method has the wrong return type and hence does not allow one to set an operator-specific parallelism.

      • apply

        public <T> DataStream<T> apply​(org.apache.flink.api.common.functions.JoinFunction<T1,​T2,​T> function,
                               org.apache.flink.api.common.typeinfo.TypeInformation<T> resultType)
        Completes the join operation with the user function that is executed for each combination of elements with the same key in a window.

        Note: This method's return type does not support setting an operator-specific parallelism. Due to binary backwards compatibility, this cannot be altered. Use the with(JoinFunction, TypeInformation), method to set an operator-specific parallelism.

      • with

        @PublicEvolving
@Deprecated
public <T> SingleOutputStreamOperator<T> with​(org.apache.flink.api.common.functions.JoinFunction<T1,​T2,​T> function,
                                              org.apache.flink.api.common.typeinfo.TypeInformation<T> resultType)
        Deprecated.
        This method will be removed once the apply(JoinFunction, TypeInformation) method is fixed in the next major version of Flink (2.0).
        Completes the join operation with the user function that is executed for each combination of elements with the same key in a window.

        Note: This is a temporary workaround while the apply(FlatJoinFunction, TypeInformation) method has the wrong return type and hence does not allow one to set an operator-specific parallelism