coral-beam/src/main/java/com/linkedin/beam/utils/RexToBeamConverter.java
private Expression toAvroRecord(Expression expr, ParameterExpression schemaExpr) {
    if (expr.getType() == GenericRecord.class) {
      return expr;
    }
    return Expressions.call(BeamExecUtil.class, MethodNames.TO_AVRO_RECORD, ImmutableList.of(expr, schemaExpr));
  }
/**
   * Converts an expression to avro record if required.
   *
   * @param expr input expression
   * @param schemaExpr schema for the input expression
   * @return Expression with avro record type
   */
Converts an expression to avro record if required.
@param expr input expression
@param schemaExpr schema for the input expression
@return Expression with avro record type
Converts an expression to avro record if required . @param expr input expression @param schemaExpr schema for the input expression @return Expression with avro record type
private Expression toAvroRecord(Expression expr, ParameterExpression schemaExpr) {
    if (expr.getType() == GenericRecord.class) {
      return expr;
    }
    return Expressions.call(BeamExecUtil.class, MethodNames.TO_AVRO_RECORD, ImmutableList.of(expr, schemaExpr));
  }
private Expression toAvroRecord ( Expression expr , ParameterExpression schemaExpr ) { if ( expr . getType ( ) == GenericRecord . class ) { return expr ; } return Expressions . call ( BeamExecUtil . class , MethodNames . TO_AVRO_RECORD , ImmutableList . of ( expr , schemaExpr ) ) ; }
Converts an expression to avro record if required.
Converts an expression to avro record if required .