1919import java .io .IOException ;
2020import java .util .ArrayList ;
2121import java .util .List ;
22+ import java .util .stream .Collectors ;
2223
2324/**
2425 * Created by bimber on 1/16/2015.
2526 */
2627public class SequenceReadsetHandlerJob extends SequenceJob implements HasJobParams
2728{
2829 private String _handlerClassName ;
30+ private List <Integer > _readsetIds ;
2931
3032 // Default constructor for serialization
3133 protected SequenceReadsetHandlerJob ()
@@ -39,9 +41,11 @@ public SequenceReadsetHandlerJob(Container c, User user, @Nullable String jobNam
3941 _handlerClassName = handler .getClass ().getName ();
4042
4143 //for the purpose of caching files:
44+ _readsetIds = new ArrayList <>();
4245 for (SequenceReadsetImpl rs : readsets )
4346 {
4447 getSequenceSupport ().cacheReadset (rs );
48+ _readsetIds .add (rs .getReadsetId ());
4549 }
4650 }
4751
@@ -64,7 +68,7 @@ public SequenceOutputHandler<SequenceOutputHandler.SequenceReadsetProcessor> get
6468
6569 public List <Readset > getReadsets ()
6670 {
67- return getSequenceSupport (). getCachedReadsets ( );
71+ return getReadsetIds (). stream (). map ( getSequenceSupport ():: getCachedReadset ). collect ( Collectors . toList () );
6872 }
6973
7074 @ Override
@@ -94,4 +98,14 @@ public List<File> getInputFiles()
9498
9599 return null ;
96100 }
101+
102+ public List <Integer > getReadsetIds ()
103+ {
104+ return _readsetIds ;
105+ }
106+
107+ public void setReadsetIds (List <Integer > readsetIds )
108+ {
109+ _readsetIds = readsetIds ;
110+ }
97111}
0 commit comments