text: var categoryDefaults = require('../config/category_map');
  
  var streams = {};
  
  streams.config = {
    categoryDefaults: categoryDefaults
  };
  
  streams.pbfParser = require('./multiple_pbfs').create;
  streams.docConstructor = require('./document_constructor');
  streams.blacklistStream = require('pelias-blacklist-stream');
  streams.tagMapper = require('./tag_mapper');
  streams.deduper = require('./deduper');
  streams.adminLookup = require('pelias-wof-admin-lookup').create;
  streams.addressExtractor = require('./address_extractor');
  streams.categoryMapper = require('./category_mapper');
  streams.dbMapper = require('pelias-model').createDocumentMapperStream;
  streams.elasticsearch = require('pelias-dbclient');
  
  // default import pipeline
  streams.import = function(existingHashes){
    streams.pbfParser()
      .pipe( streams.docConstructor() )
      .pipe( streams.tagMapper() )
      .pipe( streams.addressExtractor() )
      .pipe( streams.blacklistStream() )
      .pipe( streams.categoryMapper( categoryDefaults ) )
      .pipe( streams.adminLookup() )
      .pipe( streams.deduper(existingHashes) )
      .pipe( streams.dbMapper() )
      .pipe( streams.elasticsearch() );
  };
  
  module.exports = streams;
  