EDIT

	@Override

	protected String getRecordQuery(BerlinModelImportConfigurator config) {

			String strQuery =   

               " tg.ID AS GazetteerId, tg.L2Code, tg.L3Code, tg.L4Code, tg.Country, tg.ISOCountry, " +

            " FROM Fact " + 

                 " INNER JOIN EcoFact ON Fact.ExtensionFk = EcoFact.EcoFactId " +

                 " INNER JOIN PTaxon ON dbo.Fact.PTNameFk = dbo.PTaxon.PTNameFk AND dbo.Fact.PTRefFk = dbo.PTaxon.PTRefFk " +

		Set<TaxonBase> taxaToSave = new HashSet<TaxonBase>();

		Map<String, TaxonBase> taxonMap = (Map<String, TaxonBase>) partitioner.getObjectMap(BerlinModelTaxonImport.NAMESPACE);

		ResultSet rs = partitioner.getResultSet();

					//facade

					DerivedUnitType type = makeDerivedUnitType(recordBasis);

					//field observation

					handleSingleSpecimen(rs, facade, state, partitioner);

			return false;

		}

	}

			result.put(nameSpace, objectMap);

			//field observation map map

			cdmClass = FieldObservation.class;

			idSet = fieldObservationIdSet;

			Map<String, FieldObservation> fieldObservationMap = (Map<String, FieldObservation>)getCommonService().getSourcedObjectsByIdInSource(cdmClass, idSet, nameSpace);