EDIT

    @Override

		Map<String, String> csvRecord = item.map;

		Reference sourceReference = state.getTransactionalSourceReference();

			fireWarningEvent(warning, item, 8);

		}else{

			resultList.add(mcb);

			handleAcceptedNameUsage(item, state, taxonBase, id);

//		    <field index='24' term='http://purl.org/dc/terms/description'/>

//		    </core>

	}

	}

			String parentId = item.get(TermUri.DWC_PARENT_NAME_USAGE_ID);

			if (id.equals(parentId)){

				//taxon can't be it's own child

					if (classification == null){

						String warning = "Classification not found. Can't create parent-child relationship";

						fireWarningEvent(warning, item, 12);

					}

				}

			}else if (taxonBase.isInstanceOf(Synonym.class)){

				fireWarningEvent(message, item, 12);

			}

		}

	}

		//

		if (config.isDatasetsAsClassifications()){

			String datasetKey = item.get(TermUri.DWC_DATASET_ID);

				if (StringUtils.isNotBlank(config.getClassificationName())){

					newClassification.setName(LanguageString.NewInstance(config.getClassificationName(), Language.DEFAULT()));

				}

				resultSet.add(newClassification);

			}

		}

	}

		if (acceptedNameUsageExists(item)){

			String accId = item.get(TermUri.DWC_ACCEPTED_NAME_USAGE_ID);

			handleAcceptedNameUsageParam(item, state, taxonBase, id, accId);

    }

	@Override

		//TODO what if not transactional?

		Reference sourceReference = state.getTransactionalSourceReference();

		//taxon

		TaxonBase<?> taxonBase = getTaxonBase(csvTaxonRecord);

		resultList.add(mcb);

		//original source

		String id = csvTaxonRecord.get(ID);

		IdentifiableSource source = taxonBase.addSource(OriginalSourceType.Import, id, "Taxon", sourceReference, sourceReferenceDetail);

		resultList.add(mappedSource);

		csvTaxonRecord.remove(ID);

//		    <field index='24' term='http://purl.org/dc/terms/description'/>

//		    </core>

	}

	}

		TermUri idTerm = TermUri.DWC_DATASET_ID;

		TermUri strTerm = TermUri.DWC_DATASET_NAME;

				//source

				IdentifiableSource source = classification.addSource(OriginalSourceType.Import, classificationId, "Dataset", sourceReference, sourceReferecenDetail);

				//add to result

				//TODO this is not so nice but currently necessary as classifications are requested in the same partition

				state.putMapping(idTerm.toString(), classificationId, classification);

				state.putMapping(strTerm.toString(), classificationName, classification);

		return id;

	}

		if (config.isDatasetsAsSecundumReference()){

			//TODO store nameAccordingTo info some where else or let the user define where to store it.

			return null;

	}

		TaxonName name = null;

		String strScientificName = getValue(item, TermUri.DWC_SCIENTIFIC_NAME);

		//Name

	 * @param idIsInternal

	 * @return

	 */

		Reference newRef = null;

		Reference sourceCitation = null;

	@Override

		Map<String, String> csv = item.map;

		Reference sourceReference = state.getTransactionalSourceReference();

			}

			resultList.add(mcb);

		}else{

		//return

	}

	@Override

	public final Set<String> requiredSourceNamespaces() {

 		result.add(TermUri.DWC_TAXON.toString());

 		return result;

	}

		return this.getClass().getName();

	}

}

	}

	@Override

		Map<String, String> csv = item.map;

		Reference sourceReference = state.getTransactionalSourceReference();

					}

				}

					Rights copyright = Rights.NewInstance(rights, language);

					taxonDescription.addRights(copyright);

				}

				fireWarningEvent(message, item, 4);

			}

			resultList.add(mcb);

		}else{

			String message = "Taxon is not available for id '%s'";

			fireWarningEvent(message, item, 12);

		}

	}

	 * @param resultList

	 * @return

	 */

		String descriptionType = item.get(TermUri.DC_TYPE);

		item.remove(TermUri.DC_TYPE);

				feature.setSupportsTextData(true);

//				state.putMapping(namespace, type, feature);

				state.getCurrentIO().saveNewTerm(feature);

				resultList.add(mcb);

			}

			return feature;

	}

	@Override

		Map<String, String> csv = item.map;

		Reference sourceReference = state.getTransactionalSourceReference();

			String locationId = item.get(TermUri.DWC_LOCATION_ID);

			NamedArea area = getAreaByLocationId(item, locationId);

			if (area != null){

				resultList.add(mcb);

			}else if (! config.isExcludeLocality()){

				String locality = item.get(TermUri.DWC_LOCALITY);

				area = getAreaByLocality(item, locality);

				resultList.add(mcb);

			}

				desc.addElement(distribution);

				//save taxon

				resultList.add(mcb);

			}

	}

	@Override

		Map<String, String> csv = item.map;

		Reference sourceReference = state.getTransactionalSourceReference();

		}

		//return

	}

	@Override

	public Set<String> requiredSourceNamespaces() {

 		result.add(TermUri.DWC_TAXON.toString());

 		return result;

	}

	}

	@Override

		Map<String, String> csv = item.map;

		Reference sourceReference = state.getTransactionalSourceReference();

		handleType(reference, strType, taxon, resultList, item);

	}

		// TODO handleType not yet implemented

		if (taxon == null){

		return tp;

	}

		Team team = Team.NewTitledInstance(strCreator, strCreator);

		return team;

	}

	}

	@Override

		Reference sourceReference = state.getTransactionalSourceReference();

		String sourceReferecenDetail = null;

				if (typeStatus.isInstanceOf(SpecimenTypeDesignationStatus.class)){

					SpecimenTypeDesignationStatus status = CdmBase.deproxy(typeStatus, SpecimenTypeDesignationStatus.class);

					name.addSpecimenTypeDesignation(specimen, status, null, null, null, false, true);

					resultList.add(mcb);

				}else if (typeStatus.isInstanceOf(NameTypeDesignationStatus.class)){

					String message = "NameTypeDesignation not yet implemented";

				}

			}

			resultList.add(mcb);

		}else{

		}

		//return

	}

		String institutionCode = item.get(TermUri.DWC_INSTITUTION_CODE);

		String collectionCode = item.get(TermUri.DWC_COLLECTION_CODE);

		//institution

		Institution institution = getInstitutionByInstitutionCode(item, institutionCode);

		if (institution != null){

			resultList.add(mcb);

		}

		//collection

		Collection collection = getCollectionByCollectionCode(item, collectionCode, institution);

		if (collection != null){

			resultList.add(mcb);

		}

		return collection;

	@Override

	public Set<String> requiredSourceNamespaces() {

 		result.add(TermUri.DWC_TAXON.toString());

 		result.add(TermUri.DWC_LOCATION_ID.toString());

 		return result;

	@Override

		Map<String, String> csv = item.map;

		Reference sourceReference = state.getTransactionalSourceReference();

		String id = csv.get(CORE_ID);

		Taxon taxon = getTaxonBase(id, item, Taxon.class, state);

		if (taxon != null){

			String vernacular = item.get(TermUri.DWC_VERNACULAR_NAME);

			//TODO language, area,

			TaxonDescription desc = getTaxonDescription(taxon, false);

		}

		//return

	}

/**

* Copyright (C) 2009 EDIT

* http://www.e-taxonomy.eu

* The contents of this file are subject to the Mozilla Public License Version 1.1

* See LICENSE.TXT at the top of this package for the full license terms.

*/

package eu.etaxonomy.cdm.io.dwca.in;

/**

 * Interface for all converters from some input to some output.

 * Supports mapping of input to output and identifier identification.

 * @author a.mueller

 * @date 23.11.2011

 *

 */

public interface IConverter<IN extends IConverterInput, OUT extends IConverterOutput, SOURCE_ID extends Object> {

	/**

	 * Returns the identifier (if any) of the input

	 * @param item

 * @author a.mueller

 *

 */

	private static final Logger logger = Logger.getLogger(StreamPartitioner.class);

	private final int partitionSize;

	private final LookAheadStream<ITEM> inStream;

	private final IPartitionableConverter converter;

	private final StreamImportStateBase<StreamImportConfiguratorBase, StreamImportBase> state;

	public StreamPartitioner(INamespaceReader<ITEM> input, IPartitionableConverter converter, StreamImportStateBase state, Integer size){

		 this.inStream = new LookAheadStream<ITEM>(input);

	private void initNewOutStream(){

	}

	@Override

	}

	@Override

		logger.debug("Start partitioner read");

		handleNextPartition();

		initNewOutStream();

		logger.debug("End partitioner read");

		state.loadRelatedObjects(partialMapping);

		while (inStream.isLookingAhead() && inStream.hasNext()){

			while (resultReader.hasNext()){

				resultList.add(item);

			}

		}

		return;

	 * Add new items to the local mapping

	 * @param item

	 */

		CdmBase cdmBase = item.getCdmBase();

		if (cdmBase.getId() == 0){

			if (cdmBase.isInstanceOf(IdentifiableEntity.class)){

			    Set<String> requiredSourceNamespaces = converter.requiredSourceNamespaces();

				if (requiredSourceNamespaces.contains(item.getNamespace())){

				}

			}

		}

 * @author a.mueller

 *

 */

	protected void makeSourceRef(STATE state) {

			ItemFilter<StreamItem> filter = partitionConverter.getItemFilter();

			IItemStream filteredStream = filter == null ? recordStream : new FilteredStream(recordStream, filter);

					partitionConverter, state, partitionSize);//   (csvStream, streamConverter,state 1000);

			int i = 1;

				TransactionStatus tx = startTransaction();

				try {

					fireProgressEvent("Handel " + i + ". partition", i + ". partition");

					logger.info("Handel " + i++ + ". partition");

			state.setSuccess(false);

			return;

		}

		handleResults(state, resultReader, item.getLocation());

		return;

	}

	 * @param item

	 * @param resultReader

	 */

		while (resultReader.hasNext()){

			MappedCdmBase<?> mappedCdmBase = resultReader.read();

	}

	//Make public to allow to use by converters

	@Override

	public Feature getFeature(STATE state, UUID uuid, String label, String description, String labelAbbrev, TermVocabulary<Feature> voc) {