New sharding system is live. Disable with -ds.
git-svn-id: file:///humgen/gsa-scr1/gsa-engineering/svn_contents/trunk@3016 348d0f76-0448-11de-a6fe-93d51630548a
This commit is contained in:
parent
1fd909cdaf
commit
2cc040aa1c
|
|
@ -681,19 +681,19 @@ public class GenomeAnalysisEngine {
|
||||||
ShardStrategyFactory.SHATTER_STRATEGY.LINEAR;
|
ShardStrategyFactory.SHATTER_STRATEGY.LINEAR;
|
||||||
shardStrategy = ShardStrategyFactory.shatter(readsDataSource,
|
shardStrategy = ShardStrategyFactory.shatter(readsDataSource,
|
||||||
referenceDataSource,
|
referenceDataSource,
|
||||||
argCollection.experimentalSharding ? ShardStrategyFactory.SHATTER_STRATEGY.LOCUS_EXPERIMENTAL : shardType,
|
!argCollection.disableExperimentalSharding ? ShardStrategyFactory.SHATTER_STRATEGY.LOCUS_EXPERIMENTAL : shardType,
|
||||||
drivingDataSource.getSequenceDictionary(),
|
drivingDataSource.getSequenceDictionary(),
|
||||||
SHARD_SIZE,
|
SHARD_SIZE,
|
||||||
intervals, maxIterations);
|
intervals, maxIterations);
|
||||||
} else
|
} else
|
||||||
shardStrategy = ShardStrategyFactory.shatter(readsDataSource,
|
shardStrategy = ShardStrategyFactory.shatter(readsDataSource,
|
||||||
referenceDataSource,
|
referenceDataSource,
|
||||||
argCollection.experimentalSharding ? ShardStrategyFactory.SHATTER_STRATEGY.LOCUS_EXPERIMENTAL : ShardStrategyFactory.SHATTER_STRATEGY.LINEAR,
|
!argCollection.disableExperimentalSharding ? ShardStrategyFactory.SHATTER_STRATEGY.LOCUS_EXPERIMENTAL : ShardStrategyFactory.SHATTER_STRATEGY.LINEAR,
|
||||||
drivingDataSource.getSequenceDictionary(),
|
drivingDataSource.getSequenceDictionary(),
|
||||||
SHARD_SIZE, maxIterations);
|
SHARD_SIZE, maxIterations);
|
||||||
} else if (walker instanceof ReadWalker ||
|
} else if (walker instanceof ReadWalker ||
|
||||||
walker instanceof DuplicateWalker) {
|
walker instanceof DuplicateWalker) {
|
||||||
if(argCollection.experimentalSharding)
|
if(!argCollection.disableExperimentalSharding)
|
||||||
shardType = ShardStrategyFactory.SHATTER_STRATEGY.READS_EXPERIMENTAL;
|
shardType = ShardStrategyFactory.SHATTER_STRATEGY.READS_EXPERIMENTAL;
|
||||||
else
|
else
|
||||||
shardType = ShardStrategyFactory.SHATTER_STRATEGY.READS;
|
shardType = ShardStrategyFactory.SHATTER_STRATEGY.READS;
|
||||||
|
|
@ -740,7 +740,7 @@ public class GenomeAnalysisEngine {
|
||||||
return null;
|
return null;
|
||||||
|
|
||||||
SAMDataSource dataSource = null;
|
SAMDataSource dataSource = null;
|
||||||
if(argCollection.experimentalSharding)
|
if(!argCollection.disableExperimentalSharding)
|
||||||
dataSource = new BlockDrivenSAMDataSource(reads);
|
dataSource = new BlockDrivenSAMDataSource(reads);
|
||||||
else
|
else
|
||||||
dataSource = new IndexDrivenSAMDataSource(reads);
|
dataSource = new IndexDrivenSAMDataSource(reads);
|
||||||
|
|
|
||||||
|
|
@ -155,8 +155,8 @@ public class GATKArgumentCollection {
|
||||||
// public boolean enableRodWalkers = false;
|
// public boolean enableRodWalkers = false;
|
||||||
|
|
||||||
@Element(required = false)
|
@Element(required = false)
|
||||||
@Argument(fullName = "experimental_sharding",shortName="es", doc="Use the experimental sharding strategy. Will not work for all traversal types.", required = false)
|
@Argument(fullName = "disable_experimental_sharding",shortName="ds", doc="Disable the experimental sharding strategy.", required = false)
|
||||||
public boolean experimentalSharding = false;
|
public boolean disableExperimentalSharding = false;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* marshal the data out to a object
|
* marshal the data out to a object
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue