METHOD_0 ( ) { int IDENT_0 = 4 ; java . util . List < org . apache . flink . streaming . IDENT_1 . kafka . IDENT_2 . IDENT_3 > IDENT_4 = java . util . Arrays . asList ( new org . apache . flink . streaming . IDENT_1 . kafka . IDENT_2 . METHOD_1 ( STRING_0 , 0 ) , new org . apache . flink . streaming . IDENT_1 . kafka . IDENT_2 . METHOD_1 ( STRING_0 , 1 ) , new org . apache . flink . streaming . IDENT_1 . kafka . IDENT_2 . METHOD_1 ( STRING_0 , 2 ) , new org . apache . flink . streaming . IDENT_1 . kafka . IDENT_2 . METHOD_1 ( STRING_0 , 3 ) , new org . apache . flink . streaming . IDENT_1 . kafka . IDENT_2 . METHOD_1 ( STRING_1 , 0 ) , new org . apache . flink . streaming . IDENT_1 . kafka . IDENT_2 . METHOD_1 ( STRING_1 , 1 ) ) ; java . util . List < org . apache . flink . streaming . IDENT_1 . kafka . IDENT_2 . METHOD_1 > IDENT_5 = java . util . Arrays . asList ( new org . apache . flink . streaming . IDENT_1 . kafka . IDENT_2 . METHOD_1 ( STRING_0 , 3 ) , new org . apache . flink . streaming . IDENT_1 . kafka . IDENT_2 . METHOD_1 ( STRING_0 , 1 ) , new org . apache . flink . streaming . IDENT_1 . kafka . IDENT_2 . METHOD_1 ( STRING_1 , 1 ) , new org . apache . flink . streaming . IDENT_1 . kafka . IDENT_2 . METHOD_1 ( STRING_0 , 0 ) , new org . apache . flink . streaming . IDENT_1 . kafka . IDENT_2 . METHOD_1 ( STRING_1 , 0 ) , new org . apache . flink . streaming . IDENT_1 . kafka . IDENT_2 . METHOD_1 ( STRING_0 , 2 ) ) ; for ( int IDENT_6 = 0 ; IDENT_6 < IDENT_0 ; IDENT_6 ++ ) { org . apache . flink . streaming . IDENT_1 . kafka . IDENT_7 . IDENT_8 IDENT_9 = new org . apache . flink . streaming . IDENT_1 . kafka . IDENT_7 . METHOD_2 ( IDENT_10 , IDENT_6 , IDENT_0 , org . apache . flink . streaming . IDENT_1 . kafka . IDENT_7 . METHOD_2 . METHOD_3 ( java . util . Arrays . asList ( STRING_0 , STRING_1 ) ) , org . apache . flink . streaming . IDENT_1 . kafka . IDENT_7 . METHOD_2 . METHOD_4 ( IDENT_4 ) ) ; IDENT_9 . METHOD_5 ( ) ; org . apache . flink . streaming . IDENT_1 . kafka . IDENT_7 . METHOD_2 IDENT_11 = new org . apache . flink . streaming . IDENT_1 . kafka . IDENT_7 . METHOD_2 ( IDENT_10 , IDENT_6 , IDENT_0 , org . apache . flink . streaming . IDENT_1 . kafka . IDENT_7 . METHOD_2 . METHOD_3 ( java . util . Arrays . asList ( STRING_0 , STRING_1 ) ) , org . apache . flink . streaming . IDENT_1 . kafka . IDENT_7 . METHOD_2 . METHOD_4 ( IDENT_5 ) ) ; IDENT_11 . METHOD_5 ( ) ; java . util . List < org . apache . flink . streaming . IDENT_1 . kafka . IDENT_2 . METHOD_1 > IDENT_12 = IDENT_9 . METHOD_6 ( ) ; java . util . List < org . apache . flink . streaming . IDENT_1 . kafka . IDENT_2 . METHOD_1 > IDENT_13 = IDENT_11 . METHOD_6 ( ) ; java . util . Collections . METHOD_7 ( IDENT_12 , new org . apache . flink . streaming . IDENT_1 . kafka . IDENT_2 . METHOD_1 . METHOD_8 ( ) ) ; java . util . Collections . METHOD_7 ( IDENT_13 , new org . apache . flink . streaming . IDENT_1 . kafka . IDENT_2 . METHOD_1 . METHOD_8 ( ) ) ; "<AssertPlaceHolder>" ; } } METHOD_6 ( ) { if ( ( ! ( IDENT_14 ) ) && ( ! ( IDENT_15 ) ) ) { try { java . util . List < org . apache . flink . streaming . IDENT_1 . kafka . IDENT_2 . METHOD_1 > IDENT_16 ; if ( IDENT_10 . METHOD_9 ( ) ) { IDENT_16 = METHOD_10 ( IDENT_10 . METHOD_11 ( ) ) ; } else { java . util . List < java . lang . String > IDENT_17 = METHOD_12 ( ) ; java . util . Iterator < java . lang . String > IDENT_18 = IDENT_17 . iterator ( ) ; while ( IDENT_18 . hasNext ( ) ) { if ( ! ( IDENT_10 . METHOD_13 ( IDENT_18 . next ( ) ) ) ) { IDENT_18 . remove ( ) ; } } if ( ( IDENT_17 . size ( ) ) != 0 ) { IDENT_16 = METHOD_10 ( IDENT_17 ) ; } else { IDENT_16 = null ; } } if ( ( IDENT_16 == null ) || ( IDENT_16 . isEmpty ( ) ) ) { throw new java . lang . RuntimeException ( ( STRING_2 + ( IDENT_10 ) ) ) ; } else { java . util . Iterator < org . apache . flink . streaming . IDENT_1 . kafka . IDENT_2 . METHOD_1 > IDENT_18 = IDENT_16 . iterator ( ) ; org . apache . flink . streaming . IDENT_1 . kafka . IDENT_2 . METHOD_1 IDENT_19 ; while ( IDENT_18 . hasNext ( ) ) { IDENT_19 = IDENT_18 . next ( ) ; if ( ! ( METHOD_14 ( IDENT_19 ) ) ) { IDENT_18 . remove ( ) ; } } } return IDENT_16 ; } catch ( org . apache . flink . streaming . IDENT_1 . kafka . IDENT_2 . IDENT_20 . IDENT_21 e ) { IDENT_15 = false ; throw e ; } } else if ( ( ! ( IDENT_14 ) ) && ( IDENT_15 ) ) { IDENT_15 = false ; throw new org . apache . flink . streaming . IDENT_1 . kafka . IDENT_2 . IDENT_20 . METHOD_15 ( ) ; } else { throw new org . apache . flink . streaming . IDENT_1 . kafka . IDENT_2 . IDENT_20 . METHOD_16 ( ) ; } }
org . junit . Assert . assertEquals ( IDENT_12 , IDENT_13 )