Skip to content

Commit 05f1491

Browse files
committed
Include readset ID in PlinkPca output
1 parent 62c5b7e commit 05f1491

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

SequenceAnalysis/src/org/labkey/sequenceanalysis/run/variant/PlinkPcaStep.java

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,7 @@
4242
import java.io.PrintWriter;
4343
import java.util.ArrayList;
4444
import java.util.Arrays;
45+
import java.util.Collection;
4546
import java.util.HashMap;
4647
import java.util.HashSet;
4748
import java.util.List;
@@ -255,12 +256,13 @@ public void init(PipelineJob job, SequenceAnalysisJobSupport support, List<Seque
255256
filter.addCondition(FieldKey.fromString("application"), allowableApplications, CompareType.IN);
256257
}
257258

258-
Set<String> applications = new HashSet<>(new TableSelector(QueryService.get().getUserSchema(getPipelineCtx().getJob().getUser(), targetContainer, SequenceAnalysisSchema.SCHEMA_NAME).getTable(SequenceAnalysisSchema.TABLE_READSETS), PageFlowUtil.set("application"), filter, null).getArrayList(String.class));
259-
if (applications.size() == 1)
259+
Collection<Map<String, Object>> results = new TableSelector(QueryService.get().getUserSchema(getPipelineCtx().getJob().getUser(), targetContainer, SequenceAnalysisSchema.SCHEMA_NAME).getTable(SequenceAnalysisSchema.TABLE_READSETS), PageFlowUtil.set("application", "rowid"), filter, null).getMapCollection();
260+
if (results.size() == 1)
260261
{
261-
writer.println(sample + "\t" + applications.iterator().next());
262+
Map<String, Object> row = results.iterator().next();
263+
writer.println(sample + "\t" + row.get("application") + "\t" + row.get("rowid"));
262264
}
263-
else if (applications.size() > 1)
265+
else if (results.size() > 1)
264266
{
265267
duplicates.add(sample);
266268
}

0 commit comments

Comments
 (0)