} 数据分批次的插入数据库。插入的逻辑由Listting Seven中的execute()方法提供。大部分的编码都是用来实现可能存在不同类型输入的解析。
Listing Seven:数据插入的代码部分。
- public void execute(Tuple tuple, BasicOutputCollector collector)
- {
- batchExecuted=false;
- if(tuple!=null)
- {
- List<Object> inputTupleList = (List<
34/47 首页 上一页 32 33 34 35 36 37 下一页 尾页