METHOD_0 ( ) { final java . lang . String IDENT_0 = STRING_0 ; java . util . List < java . lang . String > records = java . util . Arrays . asList ( STRING_1 , STRING_2 , STRING_3 ) ; java . util . List < org . apache . avro . IDENT_1 . IDENT_2 > IDENT_3 = new java . util . ArrayList ( ) ; for ( java . lang . String record : records ) { IDENT_3 . add ( org . talend . components . adapter . beam . transform . IDENT_4 . METHOD_1 ( record ) ) ; } org . talend . components . elasticsearch . IDENT_5 IDENT_6 = new org . talend . components . elasticsearch . METHOD_2 ( STRING_4 ) ; IDENT_6 . init ( ) ; IDENT_6 . METHOD_3 ( IDENT_7 ) ; IDENT_6 . index . setValue ( org . talend . components . elasticsearch . IDENT_8 . IDENT_9 . IDENT_10 ) ; IDENT_6 . type . setValue ( IDENT_0 ) ; org . talend . components . elasticsearch . output . IDENT_11 IDENT_12 = new org . talend . components . elasticsearch . output . METHOD_4 ( STRING_5 ) ; IDENT_12 . init ( ) ; IDENT_12 . METHOD_5 ( IDENT_6 ) ; org . talend . components . elasticsearch . IDENT_8 . IDENT_13 IDENT_14 = new org . talend . components . elasticsearch . IDENT_8 . METHOD_6 ( ) ; IDENT_14 . METHOD_7 ( null , IDENT_12 ) ; org . apache . beam . sdk . values . IDENT_15 < org . apache . avro . IDENT_1 . IDENT_2 > IDENT_16 = ( ( org . apache . beam . sdk . values . IDENT_15 < org . apache . avro . IDENT_1 . IDENT_2 > ) ( pipeline . apply ( org . apache . beam . sdk . IDENT_17 . IDENT_18 . of ( IDENT_3 ) . METHOD_8 ( org . talend . components . adapter . beam . IDENT_19 . IDENT_20 . of ( ) ) ) ) ) ; IDENT_16 . apply ( IDENT_14 ) ; pipeline . run ( ) ; org . talend . components . elasticsearch . IDENT_8 . IDENT_21 . METHOD_9 ( org . talend . components . elasticsearch . IDENT_8 . IDENT_9 . IDENT_10 , IDENT_0 , client ) ; org . talend . components . elasticsearch . IDENT_8 . IDENT_22 IDENT_23 = new org . talend . components . elasticsearch . IDENT_8 . METHOD_10 ( ) ; IDENT_23 . METHOD_7 ( null , IDENT_6 ) ; final java . util . List < org . apache . avro . IDENT_1 . IDENT_2 > IDENT_24 = new java . util . ArrayList ( ) ; IDENT_23 . METHOD_11 ( 3 , new org . talend . IDENT_25 . IDENT_26 . IDENT_27 < org . apache . avro . IDENT_1 . IDENT_2 > ( ) { @ org . talend . components . elasticsearch . IDENT_8 . Override public void accept ( org . apache . avro . IDENT_1 . IDENT_2 IDENT_28 ) { IDENT_24 . add ( IDENT_28 ) ; } } ) ; METHOD_12 ( IDENT_24 , IDENT_3 ) ; "<AssertPlaceHolder>" ; } size ( ) { if ( ( IDENT_29 . getValue ( ) ) == null ) { return 0 ; } return IDENT_29 . getValue ( ) . size ( ) ; }
org . junit . Assert . assertThat ( IDENT_24 . size ( ) , org . hamcrest . Matchers . is ( 3 ) )