import org.supercsv.io.ICsvMapWriter; //导入依赖的package包/类
public static void main(String[] args) throws IOException, ParsingException
{
   CsvPreference csvPrefs = new CsvPreference('"', '|', "\n");
   ICsvMapWriter out = new CsvMapWriter(new FileWriter(args[1]), csvPrefs);
   out.writeHeader(FIELDS);

   WikiReader wikiReader = new WikiReader();
   wikiReader.setSkipRedirects(true);
   FhlcExporter fe = new FhlcExporter(out);
   wikiReader.addWikiPageParser(fe);
   InputStream in = new FileInputStream(args[0]);
   wikiReader.read(in);
   in.close();
   out.close();
}
 

import org.supercsv.io.ICsvMapWriter; //导入依赖的package包/类
public ICsvMapWriter getCSVMapWriter(String fileToWrite) {
	try {
		return new CsvMapWriter(new FileWriterWithEncoding(fileToWrite,"UTF-8", true),
				new CsvPreference.Builder(CsvPreference.EXCEL_PREFERENCE)
		.useEncoder(new DefaultCsvEncoder())
		.build() );
	} catch (IOException e) {
		logger.error("Error in creating CSV Bean writer!"+e);
	}
	return null;
}
 

import org.supercsv.io.ICsvMapWriter; //导入依赖的package包/类
/**
 * Executes the job.query and creates a data file that will contains the records from job.from to job.to positions.
 */
private void doWork(final DownloadFileWork work) throws IOException {

  final DatasetUsagesCollector datasetUsagesCollector = new DatasetUsagesCollector();

  try (ICsvMapWriter csvMapWriter = new CsvMapWriter(new FileWriterWithEncoding(work.getJobDataFileName(),
                                                                                Charsets.UTF_8),
                                                     CsvPreference.TAB_PREFERENCE)) {

    SolrQueryProcessor.processQuery(work, new Predicate<Integer>() {
      @Override
      public boolean apply(@Nullable Integer occurrenceKey) {
        try {
          org.apache.hadoop.hbase.client.Result result = work.getOccurrenceMapReader().get(occurrenceKey);
          Map<String, String> occurrenceRecordMap = buildOccurrenceMap(result, DownloadTerms.SIMPLE_DOWNLOAD_TERMS);
          if (occurrenceRecordMap != null) {
            //collect usages
            datasetUsagesCollector.collectDatasetUsage(occurrenceRecordMap.get(GbifTerm.datasetKey.simpleName()),
                    occurrenceRecordMap.get(DcTerm.license.simpleName()));
            //write results
            csvMapWriter.write(occurrenceRecordMap, COLUMNS);
            return true;
          } else {
            LOG.error(String.format("Occurrence id %s not found!", occurrenceKey));
          }
        } catch (Exception e) {
          throw Throwables.propagate(e);
        }
        return false;
      }
    });
  } finally {
    // Release the lock
    work.getLock().unlock();
    LOG.info("Lock released, job detail: {} ", work.toString());
  }
  getSender().tell(new Result(work, datasetUsagesCollector.getDatasetUsages(),
          datasetUsagesCollector.getDatasetLicenses()), getSelf());
}
 

import org.supercsv.io.ICsvMapWriter; //导入依赖的package包/类
public FhlcExporter(ICsvMapWriter out) {
   this.out = out;
}
 

import org.supercsv.io.ICsvMapWriter; //导入依赖的package包/类
/**
 * Executes the job.query and creates a data file that will contains the records from job.from to job.to positions.
 */
public void doWork(final DownloadFileWork work) throws IOException {

  final DatasetUsagesCollector datasetUsagesCollector = new DatasetUsagesCollector();

  try (
    ICsvMapWriter intCsvWriter = new CsvMapWriter(new FileWriterWithEncoding(work.getJobDataFileName()
                                                                             + TableSuffixes.INTERPRETED_SUFFIX,
                                                                             Charsets.UTF_8),
                                                  CsvPreference.TAB_PREFERENCE);
    ICsvMapWriter verbCsvWriter = new CsvMapWriter(new FileWriterWithEncoding(work.getJobDataFileName()
                                                                              + TableSuffixes.VERBATIM_SUFFIX,
                                                                              Charsets.UTF_8),
                                                   CsvPreference.TAB_PREFERENCE);
    ICsvBeanWriter multimediaCsvWriter = new CsvBeanWriter(new FileWriterWithEncoding(work.getJobDataFileName()
                                                                                      + TableSuffixes.MULTIMEDIA_SUFFIX,
                                                                                      Charsets.UTF_8),
                                                           CsvPreference.TAB_PREFERENCE)) {
    SolrQueryProcessor.processQuery(work, new Predicate<Integer>() {
      @Override
      public boolean apply(@Nullable Integer occurrenceKey) {
        try {
          // Writes the occurrence record obtained from HBase as Map<String,Object>.
          org.apache.hadoop.hbase.client.Result result = work.getOccurrenceMapReader().get(occurrenceKey);
          Map<String, String> occurrenceRecordMap = OccurrenceMapReader.buildInterpretedOccurrenceMap(result);
          Map<String, String> verbOccurrenceRecordMap = OccurrenceMapReader.buildVerbatimOccurrenceMap(result);
          if (occurrenceRecordMap != null) {
            datasetUsagesCollector.incrementDatasetUsage(occurrenceRecordMap.get(GbifTerm.datasetKey.simpleName()));
            intCsvWriter.write(occurrenceRecordMap, INT_COLUMNS);
            verbCsvWriter.write(verbOccurrenceRecordMap, VERB_COLUMNS);
            writeMediaObjects(multimediaCsvWriter, result, occurrenceKey);
            return true;
          } else {
            LOG.error(String.format("Occurrence id %s not found!", occurrenceKey));
          }
        } catch (Exception e) {
          throw Throwables.propagate(e);
        }
        return false;
      }
    });
  } finally {
    // Unlock the assigned lock.
    work.getLock().unlock();
    LOG.info("Lock released, job detail: {} ", work.toString());
  }
  getSender().tell(new Result(work, datasetUsagesCollector.getDatasetUsages()), getSelf());
}