Class TaggedUnion<T1,​T2>


  • @Internal
    public class TaggedUnion<T1,​T2>
    extends Object
    Utility class for implementing CoGroupedStream in DataStream V1, as well as two-input window operations in DataStream V2.
    • Method Detail

      • isOne

        public boolean isOne()
      • isTwo

        public boolean isTwo()
      • getOne

        public T1 getOne()
      • getTwo

        public T2 getTwo()
      • one

        public static <T1,​T2> TaggedUnion<T1,​T2> one​(T1 one)
      • two

        public static <T1,​T2> TaggedUnion<T1,​T2> two​(T2 two)