Package org.broadinstitute.gatk.engine.executive

Examples of org.broadinstitute.gatk.engine.executive.OutputMergeTask


        final Map<Stub,Storage> threadLocalOutputStreams = findStorage(Thread.currentThread());

        if( threadLocalOutputStreams == null || threadLocalOutputStreams.isEmpty() )
            return null;

        final OutputMergeTask outputMergeTask = new OutputMergeTask();
        for( Map.Entry<Stub,Storage> entry: threadLocalOutputStreams.entrySet() ) {
            final Stub stub = entry.getKey();
            final Storage storageEntry = entry.getValue();

            storageEntry.close();
            outputMergeTask.addMergeOperation(getTargetStream(stub), storageEntry);
        }

//        logger.info("Closing " + Thread.currentThread().getId() + " => " + threadLocalOutputStreams);
        threadLocalOutputStreams.clear();
View Full Code Here

TOP

Related Classes of org.broadinstitute.gatk.engine.executive.OutputMergeTask

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.