object
VcfStatsSpark extends ToolCommand[Args]
Type Members
-
case class
ChunkResult(contigFuture: Future[Any], generalStats: Option[RDD[(String, GeneralStats)]], genotypeStats: Option[RDD[(String, GenotypeStats)]], sampleDistributions: Option[RDD[(String, SampleDistributions)]], sampleCompare: Option[RDD[(String, SampleCompare)]], infoFieldCounts: Map[VcfField, RDD[(String, InfoFieldCounts)]], genotypeFieldCounts: Map[VcfField, RDD[(String, GenotypeFieldCounts)]]) extends Product with Serializable
Value Members
-
final
def
!=(arg0: Any): Boolean
-
final
def
##(): Int
-
final
def
==(arg0: Any): Boolean
-
def
aboutText: String
-
-
final
def
asInstanceOf[T0]: T0
-
def
clone(): AnyRef
-
def
cmdArrayToArgs(args: Array[String]): Args
-
def
contactText: String
-
def
contigDir(outputDir: File, contig: String): File
-
def
contigGeneralStats(vcfRecords: RDD[VariantContext], cmdArgs: Broadcast[Args], regions: Broadcast[List[BedRecord]], prefixMessage: String): (Option[FutureAction[Unit]], Option[RDD[(String, GeneralStats)]])
-
def
contigGenotypeFieldCounts(vcfRecords: RDD[VariantContext], header: Broadcast[VCFHeader], cmdArgs: Broadcast[Args], regions: Broadcast[List[BedRecord]], prefixMessage: String): Map[VcfField, (Option[Future[Unit]], RDD[(String, GenotypeFieldCounts)])]
-
def
contigGenotypeStats(vcfRecords: RDD[VariantContext], header: Broadcast[VCFHeader], cmdArgs: Broadcast[Args], regions: Broadcast[List[BedRecord]], prefixMessage: String): (Option[FutureAction[Unit]], Option[RDD[(String, GenotypeStats)]])
-
def
contigInfoFieldCounts(vcfRecords: RDD[VariantContext], header: Broadcast[VCFHeader], cmdArgs: Broadcast[Args], regions: Broadcast[List[BedRecord]], prefixMessage: String): Map[VcfField, (Option[Future[Unit]], RDD[(String, InfoFieldCounts)])]
-
def
contigSampleCompare(vcfRecords: RDD[VariantContext], header: Broadcast[VCFHeader], cmdArgs: Broadcast[Args], regions: Broadcast[List[BedRecord]], prefixMessage: String): (Option[FutureAction[Unit]], Option[RDD[(String, SampleCompare)]])
-
def
contigSampleDistributions(vcfRecords: RDD[VariantContext], cmdArgs: Broadcast[Args], regions: Broadcast[List[BedRecord]], prefixMessage: String): (Option[FutureAction[Unit]], Option[RDD[(String, SampleDistributions)]])
-
def
contributingText: String
-
def
descriptionText: String
-
def
documentationText: String
-
def
emptyArgs: Args
-
final
def
eq(arg0: AnyRef): Boolean
-
def
equals(arg0: Any): Boolean
-
def
example(args: String*): String
-
def
exampleText: String
-
def
finalize(): Unit
-
def
generateDocumentation(outputDirectory: File, version: String, release: Boolean): Unit
-
def
generateReadme(outputFile: File): Unit
-
final
def
getClass(): Class[_]
-
def
hashCode(): Int
-
def
installationText: String
-
final
def
isInstanceOf[T0]: Boolean
-
def
loadVcfFile(cmdArgs: Broadcast[Args], regions: Broadcast[List[BedRecord]], prefixMessage: String, sorting: Boolean = true, countJob: Boolean = true, cache: Boolean = true)(implicit sc: SparkContext): RDD[VariantContext]
-
def
logger: Logger
-
def
main(args: Array[String]): Unit
-
def
mainFromArgs(cmdArgs: Args): Unit
-
def
mainPageContents: List[(String, String)]
-
def
manualText: String
-
final
def
ne(arg0: AnyRef): Boolean
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
def
processContig(regions: Broadcast[List[BedRecord]], cmdArgs: Broadcast[Args], header: Broadcast[VCFHeader], contig: Option[String])(implicit sc: SparkContext): ChunkResult
-
def
processContigTotal(regions: Broadcast[List[BedRecord]], cmdArgs: Broadcast[Args], header: Broadcast[VCFHeader], contig: Option[String])(implicit sc: SparkContext): (Future[Unit], RDD[(String, StatsTotal)])
-
def
readmeContents: List[(String, String)]
-
def
sparkExample(args: String*): String
-
def
sparkUnsafeExample(args: String*): String
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
def
toString(): String
-
def
toolName: String
-
def
totalContigGenotypeFieldCounts(contigs: Map[VcfField, List[RDD[(String, GenotypeFieldCounts)]]], header: Broadcast[VCFHeader], cmdArgs: Broadcast[Args])(implicit sc: SparkContext): Option[Future[Any]]
-
def
totalContigInfoFieldCounts(contigs: Map[VcfField, List[RDD[(String, InfoFieldCounts)]]], header: Broadcast[VCFHeader], cmdArgs: Broadcast[Args])(implicit sc: SparkContext): Option[Future[Any]]
-
def
totalGeneralStats(generalContig: List[RDD[(String, GeneralStats)]], cmdArgs: Broadcast[Args])(implicit sc: SparkContext): Option[Future[Unit]]
-
def
totalGenotypeStats(contigs: List[RDD[(String, GenotypeStats)]], cmdArgs: Broadcast[Args], header: Broadcast[VCFHeader])(implicit sc: SparkContext): Option[Future[Unit]]
-
def
totalSampleCompare(contigs: List[RDD[(String, SampleCompare)]], cmdArgs: Broadcast[Args], header: Broadcast[VCFHeader])(implicit sc: SparkContext): Option[Future[Unit]]
-
def
totalSampleDistributions(contigs: List[RDD[(String, SampleDistributions)]], cmdArgs: Broadcast[Args])(implicit sc: SparkContext): Option[Future[Unit]]
-
def
unsafeExample(args: String*): String
-
def
urlToolName: String
-
def
usageHeaders: List[String]
-
def
usageHtmlTable: String
-
def
usageRows(parser: OptionParser[Args]): List[List[String]]
-
def
usageText: String
-
def
validateArgs(args: String*): Unit
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit
Inherited from ToolCommand[Args]
Inherited from Logging
Inherited from AnyRef
Inherited from Any
This tool can generate metrics from a vcf file. This version of the tool run on Apache Spark