Skip to content
Snippets Groups Projects
Commit ff0c3a5e authored by Peter van 't Hof's avatar Peter van 't Hof
Browse files

Added some errors when there is a field conflict

parent 2c3cf84b
No related branches found
No related tags found
No related merge requests found
...@@ -53,6 +53,11 @@ object VCFWithVCF extends ToolCommand { ...@@ -53,6 +53,11 @@ object VCFWithVCF extends ToolCommand {
val secondHeader = secondaryReader.getFileHeader val secondHeader = secondaryReader.getFileHeader
for (x <- commandArgs.fields) { for (x <- commandArgs.fields) {
if (header.hasInfoLine(x.outputField))
throw new IllegalArgumentException("Field '" + x.outputField + "' already exist in input vcf")
if (!secondHeader.hasInfoLine(x.inputField))
throw new IllegalArgumentException("Field '" + x.inputField + "' does not exist in secondary vcf")
val oldHeaderLine = secondHeader.getInfoHeaderLine(x.inputField) val oldHeaderLine = secondHeader.getInfoHeaderLine(x.inputField)
val newHeaderLine = new VCFInfoHeaderLine(x.outputField, VCFHeaderLineCount.UNBOUNDED, val newHeaderLine = new VCFInfoHeaderLine(x.outputField, VCFHeaderLineCount.UNBOUNDED,
...@@ -65,7 +70,7 @@ object VCFWithVCF extends ToolCommand { ...@@ -65,7 +70,7 @@ object VCFWithVCF extends ToolCommand {
writer.writeHeader(header) writer.writeHeader(header)
var idx = 0 var idx = 0
for (record: VariantContext <- reader.iterator()) { for (record <- reader) {
val secondaryRecords = if (commandArgs.matchAllele) { val secondaryRecords = if (commandArgs.matchAllele) {
secondaryReader.query(record.getChr, record.getStart, record.getEnd).toList. secondaryReader.query(record.getChr, record.getStart, record.getEnd).toList.
filter(x => record.getAlternateAlleles.exists(x.hasAlternateAllele(_))) filter(x => record.getAlternateAlleles.exists(x.hasAlternateAllele(_)))
...@@ -97,6 +102,7 @@ object VCFWithVCF extends ToolCommand { ...@@ -97,6 +102,7 @@ object VCFWithVCF extends ToolCommand {
logger.info(s"""Processed $idx records""") logger.info(s"""Processed $idx records""")
} }
} }
logger.info(s"""Processed $idx records""")
logger.debug("Closing readers") logger.debug("Closing readers")
writer.close() writer.close()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment