METHOD_0 ( ) { METHOD_1 ( ) ; METHOD_2 ( ) ; IDENT_0 . init ( IDENT_1 , IDENT_2 ) ; "<AssertPlaceHolder>" ; } METHOD_3 ( org . pentaho . di . IDENT_3 . IDENT_4 . IDENT_5 , org . pentaho . di . IDENT_3 . IDENT_4 . IDENT_6 ) { java . lang . Object [ ] row = METHOD_4 ( ) ; if ( row == null ) { if ( ( ( IDENT_7 ) != null ) && ( ( IDENT_7 . size ( ) ) > 0 ) ) { try { METHOD_5 ( ) ; } catch ( org . pentaho . IDENT_8 . IDENT_9 e ) { throw new org . pentaho . di . core . exception . METHOD_6 ( e ) ; } } java . util . List < org . pentaho . di . IDENT_3 . IDENT_10 . IDENT_11 . IDENT_12 . IDENT_13 > IDENT_14 = IDENT_15 . METHOD_7 ( ) ; if ( ( IDENT_14 != null ) && ( ( IDENT_14 . size ( ) ) > 0 ) ) { METHOD_8 ( org . pentaho . di . IDENT_16 . IDENT_17 . getString ( org . pentaho . di . IDENT_3 . IDENT_10 . IDENT_11 . IDENT_18 . IDENT_19 , STRING_0 ) ) ; try { IDENT_20 . METHOD_9 ( IDENT_14 , log , IDENT_15 . METHOD_10 ( ) ) ; } catch ( org . pentaho . IDENT_8 . IDENT_9 e ) { throw new org . pentaho . di . core . exception . METHOD_6 ( e ) ; } } METHOD_11 ( ) ; METHOD_12 ( ) ; return false ; } if ( first ) { first = false ; IDENT_21 = 100 ; java . lang . String IDENT_22 = METHOD_13 ( IDENT_15 . METHOD_14 ( ) ) ; if ( ! ( org . pentaho . di . core . IDENT_23 . isEmpty ( IDENT_22 ) ) ) { IDENT_21 = java . lang . Integer . METHOD_15 ( IDENT_22 ) ; } IDENT_7 = new java . util . ArrayList < com . mongodb . IDENT_24 > ( IDENT_21 ) ; IDENT_25 = new java . util . ArrayList < java . lang . Object [ ] > ( ) ; IDENT_20 . METHOD_16 ( METHOD_17 ( ) ) ; IDENT_20 . IDENT_26 = org . pentaho . di . IDENT_3 . IDENT_10 . IDENT_11 . IDENT_27 . METHOD_18 ( IDENT_15 . METHOD_19 ( ) ) ; org . pentaho . di . core . row . IDENT_28 IDENT_29 = METHOD_17 ( ) ; java . util . List < org . pentaho . di . IDENT_3 . IDENT_10 . IDENT_11 . IDENT_12 . IDENT_30 > IDENT_31 = IDENT_15 . METHOD_19 ( ) ; METHOD_20 ( IDENT_29 , IDENT_31 ) ; IDENT_20 . METHOD_21 ( IDENT_15 . METHOD_19 ( ) ) ; IDENT_20 . init ( this ) ; if ( IDENT_15 . METHOD_10 ( ) ) { try { METHOD_8 ( org . pentaho . di . IDENT_16 . IDENT_17 . getString ( org . pentaho . di . IDENT_3 . IDENT_10 . IDENT_11 . IDENT_18 . IDENT_19 , STRING_1 ) ) ; IDENT_20 . METHOD_22 ( ) . remove ( ) ; } catch ( java . lang . Exception m ) { METHOD_11 ( ) ; throw new org . pentaho . di . core . exception . METHOD_6 ( m . getMessage ( ) , m ) ; } } } if ( ! ( METHOD_23 ( ) ) ) { if ( IDENT_15 . METHOD_24 ( ) ) { com . mongodb . IDENT_24 IDENT_32 = org . pentaho . di . IDENT_3 . IDENT_10 . IDENT_11 . IDENT_27 . METHOD_25 ( IDENT_20 . METHOD_19 ( ) , METHOD_17 ( ) , row , this , IDENT_33 ) ; if ( log . METHOD_26 ( ) ) { METHOD_27 ( org . pentaho . di . IDENT_16 . IDENT_17 . getString ( org . pentaho . di . IDENT_3 . IDENT_10 . IDENT_11 . IDENT_18 . IDENT_19 , STRING_2 , IDENT_32 ) ) ; } if ( IDENT_32 != null ) { com . mongodb . IDENT_24 IDENT_34 = null ; if ( ! ( IDENT_15 . METHOD_28 ( ) ) ) { IDENT_34 = org . pentaho . di . IDENT_3 . IDENT_10 . IDENT_11 . IDENT_27 . METHOD_29 ( IDENT_20 . METHOD_19 ( ) , METHOD_17 ( ) , row , this , IDENT_33 , IDENT_20 . IDENT_26 ) ; if ( log . METHOD_26 ( ) ) { METHOD_27 ( org . pentaho . di . IDENT_16 . IDENT_17 . getString ( org . pentaho . di . IDENT_3 . IDENT_10 . IDENT_11 . IDENT_18 . IDENT_19 , STRING_3 , IDENT_34 ) ) ; } } else { try { IDENT_34 = IDENT_20 . METHOD_30 ( IDENT_20 . METHOD_19 ( ) , METHOD_17 ( ) , row , this , IDENT_33 ) ; } catch ( org . pentaho . IDENT_8 . IDENT_9 e ) { throw new org . pentaho . di . core . exception . METHOD_6 ( e ) ; } if ( log . METHOD_26 ( ) ) { METHOD_27 ( org . pentaho . di . IDENT_16 . IDENT_17 . getString ( org . pentaho . di . IDENT_3 . IDENT_10 . IDENT_11 . IDENT_18 . IDENT_19 , STRING_4 , IDENT_34 ) ) ; } } if ( IDENT_34 != null ) { METHOD_31 ( IDENT_32 , IDENT_34 , row ) ; } } } else { com . mongodb . IDENT_24 IDENT_35 = org . pentaho . di . IDENT_3 . IDENT_10 . IDENT_11 . IDENT_27 . METHOD_29 ( IDENT_20 . METHOD_19 ( ) , METHOD_17 ( ) , row , this , IDENT_33 , IDENT_20 . IDENT_26 ) ; if ( IDENT_35 != null ) { IDENT_7 . add ( IDENT_35 ) ; IDENT_25 . add ( row ) ; } if ( ( IDENT_7 . size ( ) ) == ( IDENT_21 ) ) { METHOD_32 ( org . pentaho . di . IDENT_16 . IDENT_17 . getString ( org . pentaho . di . IDENT_3 . IDENT_10 . IDENT_11 . IDENT_18 . IDENT_19 , STRING_5 ) ) ; try { METHOD_5 ( ) ; } catch ( org . pentaho . IDENT_8 . IDENT_9 e ) { throw new org . pentaho . di . core . exception . METHOD_6 ( e ) ; } } } METHOD_33 ( IDENT_20 . METHOD_34 ( ) , row ) ; METHOD_35 ( ) ; } return true ; }
org . junit . Assert . assertTrue ( IDENT_0 . METHOD_3 ( IDENT_1 , IDENT_2 ) )