coral-beam/src/main/java/com/linkedin/beam/utils/RexToBeamConverter.java
public ParameterExpression registerSchema(String schemaName, RelDataType relType) {
    final RelDataType existingType = registeredSchemas.get(schemaName);
    String registeredName = schemaName;
    if (existingType != null && !existingType.equals(relType)) {
        registeredName = schemaName + (registeredSchemas.size() + 1);
    }
    registeredSchemas.put(registeredName, relType);
    return RexBeamUtils.getSchemaParam(registeredName);
  }
/**
   * Registers avro schema for record or array types.
   *
   * @param schemaName local variable name for the schema
   * @param relType Rel type of the schema
   * @return Parameter expression for the registered schema
   */
Registers avro schema for record or array types.
@param schemaName local variable name for the schema
@param relType Rel type of the schema
@return Parameter expression for the registered schema
Registers avro schema for record or array types . @param schemaName local variable name for the schema @param relType Rel type of the schema @return Parameter expression for the registered schema
public ParameterExpression registerSchema(String schemaName, RelDataType relType) {
    final RelDataType existingType = registeredSchemas.get(schemaName);
    String registeredName = schemaName;
    if (existingType != null && !existingType.equals(relType)) {
        registeredName = schemaName + (registeredSchemas.size() + 1);
    }
    registeredSchemas.put(registeredName, relType);
    return RexBeamUtils.getSchemaParam(registeredName);
  }
public ParameterExpression registerSchema ( String schemaName , RelDataType relType ) { final RelDataType existingType = registeredSchemas . get ( schemaName ) ; String registeredName = schemaName ; if ( existingType != null && ! existingType . equals ( relType ) ) { registeredName = schemaName + ( registeredSchemas . size ( ) + 1 ) ; } registeredSchemas . put ( registeredName , relType ) ; return RexBeamUtils . getSchemaParam ( registeredName ) ; }
Registers avro schema for record or array types.
Registers avro schema for record or array types .