coral-beam/src/main/java/com/linkedin/beam/planner/CodeGenerator.java
List<MemberDeclaration> declareSchemas(RelNode relNode) {
    final List<MemberDeclaration> results = new ArrayList<>();
    final Map<String, RelDataType> schemaMaps = new LinkedHashMap<>();

    // Get schemas for all required relational operators
    collectRelOpSchemas(relNode, schemaMaps);

    // Get schemas for all required relational expressions
    final RexToBeamConverter rexTranslator = ((BeamPlanner) relNode.getCluster().getPlanner()).getRexTranslator();
    schemaMaps.putAll(rexTranslator.getRegisteredSchemas());

    // Now declare those schemas
    for (Map.Entry<String, RelDataType> schema : schemaMaps.entrySet()) {
      results.add(makeSchemaDeclaration(RexBeamUtils.getSchemaParam(schema.getKey()), schema.getValue()));
    }

    return results;
  }
/**
   * Declares all required schema constants.
   */
Declares all required schema constants.
Declares all required schema constants .
List<MemberDeclaration> declareSchemas(RelNode relNode) {
    final List<MemberDeclaration> results = new ArrayList<>();
    final Map<String, RelDataType> schemaMaps = new LinkedHashMap<>();
    collectRelOpSchemas(relNode, schemaMaps);
    final RexToBeamConverter rexTranslator = ((BeamPlanner) relNode.getCluster().getPlanner()).getRexTranslator();
    schemaMaps.putAll(rexTranslator.getRegisteredSchemas());
    for (Map.Entry<String, RelDataType> schema : schemaMaps.entrySet()) {
      results.add(makeSchemaDeclaration(RexBeamUtils.getSchemaParam(schema.getKey()), schema.getValue()));
    }
    return results;
  }
List < MemberDeclaration > declareSchemas ( RelNode relNode ) { final List < MemberDeclaration > results = new ArrayList < > ( ) ; final Map < String , RelDataType > schemaMaps = new LinkedHashMap < > ( ) ; collectRelOpSchemas ( relNode , schemaMaps ) ; final RexToBeamConverter rexTranslator = ( ( BeamPlanner ) relNode . getCluster ( ) . getPlanner ( ) ) . getRexTranslator ( ) ; schemaMaps . putAll ( rexTranslator . getRegisteredSchemas ( ) ) ; for ( Map . Entry < String , RelDataType > schema : schemaMaps . entrySet ( ) ) { results . add ( makeSchemaDeclaration ( RexBeamUtils . getSchemaParam ( schema . getKey ( ) ) , schema . getValue ( ) ) ) ; } return results ; }
Declares all required schema constants.
Declares all required schema constants .
// Get schemas for all required relational operators // Get schemas for all required relational expressions // Now declare those schemas