creates a com.google.cloud.dataflow.sdk.util.common.worker.reader from the given dataflow source api definition and reads all elements from it . concode_field_sep PlaceHolder placeHolder concode_field_sep Source flattenBaseSpecs
List < T > function ( PipelineOptions arg0 , Source arg1 ) { try { return ReaderUtils . readElemsFromReader ( ReaderFactory . < T > create ( arg0 , arg1 , null ) ) ; } catch ( Exception loc0 ) { throw new RuntimeException ( "srini_string" + arg1 . toString ( ) , loc0 ) ; } }