METHOD_0 ( ) { final org . eclipse . IDENT_0 . model . IDENT_1 IDENT_2 = org . eclipse . IDENT_0 . model . impl . IDENT_3 . getInstance ( ) ; final java . util . Set < org . eclipse . IDENT_0 . model . IDENT_4 > original = com . google . common . collect . IDENT_5 . METHOD_1 ( IDENT_2 . METHOD_2 ( IDENT_2 . METHOD_3 ( STRING_0 ) , IDENT_2 . METHOD_3 ( STRING_1 ) , IDENT_2 . METHOD_3 ( STRING_2 ) , IDENT_2 . METHOD_3 ( STRING_3 ) ) , IDENT_2 . METHOD_2 ( IDENT_2 . METHOD_3 ( STRING_2 ) , IDENT_2 . METHOD_3 ( STRING_1 ) , IDENT_2 . METHOD_3 ( STRING_4 ) , IDENT_2 . METHOD_3 ( STRING_5 ) ) , IDENT_2 . METHOD_2 ( IDENT_2 . METHOD_3 ( STRING_4 ) , IDENT_2 . METHOD_3 ( STRING_1 ) , IDENT_2 . METHOD_3 ( STRING_2 ) , IDENT_2 . METHOD_3 ( STRING_5 ) ) , IDENT_2 . METHOD_2 ( IDENT_2 . METHOD_3 ( STRING_0 ) , IDENT_2 . METHOD_3 ( STRING_6 ) , IDENT_2 . METHOD_3 ( STRING_4 ) , IDENT_2 . METHOD_3 ( STRING_3 ) ) ) ; try ( final org . apache . kafka . common . serialization . IDENT_6 < java . util . Set < org . eclipse . IDENT_0 . model . IDENT_4 > > IDENT_7 = new org . apache . rya . kafka . connect . api . METHOD_4 ( ) ) { final byte [ ] bytes = IDENT_7 . serializer ( ) . serialize ( STRING_7 , original ) ; final java . util . Set < org . eclipse . IDENT_0 . model . IDENT_4 > IDENT_8 = IDENT_7 . METHOD_5 ( ) . METHOD_6 ( STRING_7 , bytes ) ; "<AssertPlaceHolder>" ; } } METHOD_6 ( org . apache . rya . api . IDENT_9 . IDENT_10 , org . apache . rya . api . resolver . IDENT_11 . IDENT_12 ) { try { assert ( IDENT_13 != null ) && ( IDENT_14 != null ) ; final byte [ ] row = IDENT_13 . METHOD_7 ( ) ; final int IDENT_15 = com . google . common . IDENT_16 . IDENT_17 . indexOf ( row , org . apache . rya . api . IDENT_9 . IDENT_18 ) ; final int IDENT_19 = com . google . common . IDENT_16 . IDENT_17 . METHOD_8 ( row , org . apache . rya . api . IDENT_9 . IDENT_18 ) ; final int IDENT_20 = com . google . common . IDENT_16 . IDENT_17 . indexOf ( row , org . apache . rya . api . IDENT_9 . IDENT_21 ) ; final byte [ ] first = java . util . Arrays . METHOD_9 ( row , IDENT_15 ) ; final byte [ ] IDENT_22 = java . util . Arrays . METHOD_10 ( row , ( IDENT_15 + 1 ) , IDENT_19 ) ; final byte [ ] IDENT_23 = java . util . Arrays . METHOD_10 ( row , ( IDENT_19 + 1 ) , IDENT_20 ) ; final byte [ ] type = java . util . Arrays . METHOD_10 ( row , IDENT_20 , row . length ) ; final byte [ ] IDENT_24 = IDENT_13 . METHOD_11 ( ) ; final boolean IDENT_25 = ( IDENT_24 != null ) && ( ( IDENT_24 . length ) > 0 ) ; final org . apache . rya . api . domain . IDENT_26 context = ( IDENT_25 ) ? new org . apache . rya . api . domain . METHOD_12 ( new java . lang . String ( IDENT_24 , java . nio . IDENT_27 . IDENT_28 . UTF_8 ) ) : null ; final byte [ ] IDENT_29 = IDENT_13 . METHOD_13 ( ) ; final java . lang . String IDENT_30 = ( ( IDENT_29 != null ) && ( ( IDENT_29 . length ) > 0 ) ) ? new java . lang . String ( IDENT_29 , java . nio . IDENT_27 . IDENT_28 . UTF_8 ) : null ; final java . lang . Long IDENT_31 = IDENT_13 . METHOD_14 ( ) ; final byte [ ] IDENT_32 = IDENT_13 . METHOD_15 ( ) ; final byte [ ] value = IDENT_13 . getValue ( ) ; switch ( IDENT_14 ) { case IDENT_33 : { final byte [ ] obj = com . google . common . IDENT_16 . IDENT_17 . METHOD_16 ( IDENT_23 , type ) ; return new org . apache . rya . api . domain . METHOD_17 ( new org . apache . rya . api . domain . METHOD_12 ( new java . lang . String ( first , java . nio . IDENT_27 . IDENT_28 . UTF_8 ) ) , new org . apache . rya . api . domain . METHOD_12 ( new java . lang . String ( IDENT_22 , java . nio . IDENT_27 . IDENT_28 . UTF_8 ) ) , org . apache . rya . api . resolver . IDENT_34 . getInstance ( ) . METHOD_6 ( obj ) , context , IDENT_30 , IDENT_32 , value , IDENT_31 ) ; } case IDENT_35 : { final byte [ ] obj = com . google . common . IDENT_16 . IDENT_17 . METHOD_16 ( IDENT_22 , type ) ; return new org . apache . rya . api . domain . METHOD_17 ( new org . apache . rya . api . domain . METHOD_12 ( new java . lang . String ( IDENT_23 , java . nio . IDENT_27 . IDENT_28 . UTF_8 ) ) , new org . apache . rya . api . domain . METHOD_12 ( new java . lang . String ( first , java . nio . IDENT_27 . IDENT_28 . UTF_8 ) ) , org . apache . rya . api . resolver . IDENT_34 . getInstance ( ) . METHOD_6 ( obj ) , context , IDENT_30 , IDENT_32 , value , IDENT_31 ) ; } case IDENT_36 : { final byte [ ] obj = com . google . common . IDENT_16 . IDENT_17 . METHOD_16 ( first , type ) ; return new org . apache . rya . api . domain . METHOD_17 ( new org . apache . rya . api . domain . METHOD_12 ( new java . lang . String ( IDENT_22 , java . nio . IDENT_27 . IDENT_28 . UTF_8 ) ) , new org . apache . rya . api . domain . METHOD_12 ( new java . lang . String ( IDENT_23 , java . nio . IDENT_27 . IDENT_28 . UTF_8 ) ) , org . apache . rya . api . resolver . IDENT_34 . getInstance ( ) . METHOD_6 ( obj ) , context , IDENT_30 , IDENT_32 , value , IDENT_31 ) ; } } } catch ( final org . apache . rya . api . resolver . IDENT_37 e ) { throw new org . apache . rya . api . resolver . IDENT_11 . METHOD_18 ( e ) ; } throw new org . apache . rya . api . resolver . IDENT_11 . METHOD_18 ( ( ( ( ( STRING_8 + IDENT_13 ) + STRING_9 ) + IDENT_14 ) + STRING_10 ) ) ; }
org . junit . Assert . assertEquals ( original , IDENT_8 )