private Row convertAvroRecordToRow(Schema schema, RowTypeInfo typeInfo, IndexedRecord record) {
		final List<Schema.Field> fields = schema.getFields();
		final TypeInformation<?>[] fieldInfo = typeInfo.getFieldTypes();
		final int length = fields.size();
		final Row row = new Row(length);
		for (int i = 0; i < length; i++) {
			final Schema.Field field = fields.get(i);
			row.setField(i, convertAvroType(field.schema(), fieldInfo[i], record.get(i)));
		}
		return row;
	}
private Row convertAvroRecordToRow ( Schema schema , RowTypeInfo typeInfo , IndexedRecord record ) { final List < Schema . Field > fields = schema . getFields ( ) ; final TypeInformation < ? > [ ] fieldInfo = typeInfo . getFieldTypes ( ) ; final int length = fields . size ( ) ; final Row row = new Row ( length ) ; for ( int i = 0 ; i < length ; i ++ ) { final Schema . Field field = fields . get ( i ) ; row . setField ( i , convertAvroType ( field . schema ( ) , fieldInfo [ i ] , record . get ( i ) ) ) ; } return row ; }
--------------------------------------------------------------------------------------------