本文整理了Java中cascading.tap.Tap.retrieveSourceFields()方法的一些代码示例，展示了Tap.retrieveSourceFields()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Tap.retrieveSourceFields()方法的具体详情如下：
包路径：cascading.tap.Tap
类名称：Tap
方法名：retrieveSourceFields

Tap.retrieveSourceFields介绍

[英]A hook for allowing a Scheme to lazily retrieve its source fields.
[中]一个钩子，用于允许方案延迟检索其源字段。

代码示例

代码示例来源：origin: cwensel/cascading

@Override
public Fields retrieveSourceFields( FlowProcess<? extends Config> flowProcess )
 {
 return original.retrieveSourceFields( flowProcess );
 }

代码示例来源：origin: cwensel/cascading

@Override
public Fields retrieveSourceFields( FlowProcess<? extends TConfig> flowProcess )
 {
 return original.retrieveSourceFields( processProvider.apply( flowProcess ) );
 }

代码示例来源：origin: cwensel/cascading

/** Force a Scheme to fetch any fields from a meta-data store */
protected void retrieveSourceFields()
 {
 for( Tap tap : sources.values() )
  tap.retrieveSourceFields( getFlowProcess() );
 }

代码示例来源：origin: cascading/lingual-core

public Fields getFieldsFor( SchemaDef schemaDef, String identifier )
 {
 String name = platformBroker.createTableNameFrom( identifier );
 if( nameFieldsMap.containsKey( name ) )
  return nameFieldsMap.get( name );
 Tap tap = createTapFor( schemaDef, identifier );
 if( !resourceExistsAndNotEmpty( schemaDef, tap ) )
  {
  LOG.debug( "not loading fields for: {}, tap does not exist or is empty", tap );
  return null;
  }
 Fields fields = tap.retrieveSourceFields( platformBroker.getFlowProcess() );
 nameFieldsMap.put( name, fields );
 return fields;
 }

代码示例来源：origin: cascading/lingual-platform

protected TupleEntryIterator getTable( String tableName ) throws IOException
 {
 Tap tap = getPlatform().getDelimitedFile( ",", "\"", new SQLTypeResolver(), TEST_ROOT + tableName + ".tcsv", SinkMode.KEEP );
 tap.retrieveSourceFields( getPlatform().getFlowProcess() );
 return tap.openForRead( getPlatform().getFlowProcess() );
 }