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

Tap.flowConfInit介绍

[英]Method flowInit allows this Tap instance to initialize itself in context of the given cascading.flow.Flow instance. This method is guaranteed to be called before the Flow is started and the cascading.flow.FlowListener#onStarting(cascading.flow.Flow) event is fired.

This method will be called once per Flow, and before #sourceConfInit(cascading.flow.FlowProcess,Object) and #sinkConfInit(cascading.flow.FlowProcess,Object) methods.
[中]方法flowInit允许该Tap实例在给定级联的上下文中初始化自身。流流实例。保证在流启动和级联之前调用此方法。流FlowListener#启动（cascading.flow.flow）事件被触发。
每个流调用一次此方法，在#sourceConfInit（cascading.Flow.FlowProcess，Object）和#sinkConfInit（cascading.Flow.FlowProcess，Object）方法之前调用。

代码示例

代码示例来源：origin: elastic/elasticsearch-hadoop

@Override
public void flowConfInit(Flow<Object> flow) {
  initInnerTapIfNotSet(flow, "cascading.flow.hadoop.HadoopFlow");
  actualTap.flowConfInit(flow);
}

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

@Override
public void flowConfInit( Flow<Config> flow )
 {
 original.flowConfInit( flow );
 }

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

private void initFromTaps( Map<String, Tap> taps )
 {
 for( Tap tap : taps.values() )
  tap.flowConfInit( this );
 }

代码示例来源：origin: org.elasticsearch/elasticsearch-hadoop

@Override
public void flowConfInit(Flow<Object> flow) {
  initInnerTapIfNotSet(flow, "cascading.flow.hadoop.HadoopFlow");
  actualTap.flowConfInit(flow);
}