Examples of addTapTableFor()

Examples of cascading.lingual.tap.TapSchema.addTapTableFor()

137
138
139
140
141
142
143
144
145
146
147
      Stereotype stereotype = new Stereotype( name, function.apply( tap ) );
      TableDef tableDef = new TableDef( currentSchemaDef, name, tap.getIdentifier(), stereotype );

      currentSchemaDef.addStereotype( stereotype );
      currentTapSchema.addTapTableFor( tableDef, getDefaultSchema() == null );
      }
    }

  private SchemaDef createGetSchemaDef( SchemaDef parentSchemaDef, String schemaName )
    {
View Full Code Here

Examples of cascading.lingual.tap.TapSchema.addTapTableFor()

419
420
421
422
423
424
425
426
427
428
429
        LOG.debug( "replacing alias: {}, for: {} ", tableAlias, table.getName() );
      }

    String currentTableName = createTableDefFor( schemaName, null, tap.getIdentifier(), tap.getSinkFields(), null, null );
    TableDef tableDef = schemaDef.getTable( currentTableName );
    TapTable tapTable = subSchema.addTapTableFor( tableDef ); // add table named after flow

    LOG.debug( "adding table:{}", tableDef.getName() );

    if( tableAlias != null && !tapTable.getName().equals( tableAlias ) )
      {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.