   'TotalWages'
   'Notes'
 ]
+###
 
 fetchDb = (mongo, callback) ->
   throw new Error 'need a mongo connection'  unless mongo

    process.nextTick -> callback null, mongo


module.exports = (path, { mongo, collectionName, encoding }, dropFirst = yes) ->

  stream = new Stream


fs            = require 'fs'
csv           = require 'csv'
nodePath      = require 'path'
{Stream}      = require 'stream'
{MongoClient} = require 'mongodb'
{daisy}       = require 'sinkrow'

###
COLUMNS = [
  'RecordNumber'
  'Zipcode'
