%\VignetteIndexEntry{SeqArray: an R/Bioconductor Package for Big Data Management of Genome-Wide Sequencing Variants}
%\VignetteDepends{gdsfmt}
%\VignetteKeywords{GWAS, SNP, Sequencing Variants}
%\VignettePackage{SeqArray}

\documentclass[12pt]{article}
\usepackage{fullpage}
\usepackage{setspace}
\usepackage{indentfirst}
\usepackage{amsmath}  
\usepackage{graphicx}
\usepackage[pdftex, plainpages=false, letterpaper, bookmarks, bookmarksnumbered, colorlinks, linkcolor=blue, citecolor=blue, filecolor=blue, urlcolor=blue]{hyperref}
\usepackage{url}
\usepackage{Sweave}

% Different font in captions
\newcommand{\captionfonts}{\footnotesize}
\newcommand{\hn}[1]{\textsf{#1}}
\newcommand{\fn}[1]{\textbf{#1}}
\newcommand{\vr}[1]{\textbf{#1}}


\begin{document}

\title{SeqArray: an R/Bioconductor Package for Big Data Management of Genome-Wide Sequencing Variants}
\author{Xiuwen Zheng \\
	Department of Biostatistics \\
	University of Washington -- Seattle}
\date{Feb 21, 2013}


\maketitle
\tableofcontents

% \SweaveOpts{keep.source=TRUE, eps=FALSE}

\onehalfspace

% ---- Overview ----
\section{Overview}

In the era of big data, thousands of gigabyte-size data sets are challenging scientists for data management, even on well-equipped hardware. Currently, next-generation sequencing techniques are being adopted to investigate common and rare variants, making the analyses of large-scale genotypic data challenging. For example, the 1000 Genomes Project has identified approximately 38 million single nucleotide polymorphisms (SNPs), 1.4 million short insertions and deletions, and more than 14,000 larger deletions from whole-genome sequencing technologies [1]. In the near future, new technologies, like third-generation whole-genome sequencing, will be enabling data to be generated at an unprecedented scale [2]. The Variant Call Format (VCF) was developed for the 1000 Genomes Project, which is a generic text format for storing DNA polymorphism data such as SNPs, insertions, deletions and structural variants, together with rich annotations [3]. However, this format is less efficient for large-scale analyses since numeric data have to be parsed from a text VCF file before further analyses. The computational burden associated with sequencing variants is especially evident with large sample and variant sizes, and it requires efficient numerical implementation and data management.

Here I introduce a high-performance C/C++ computing library CoreArray (\url{http://corearray.sourceforge.net}) for big-data management of genome-wide variants [4]. CoreArray was designed for developing portable and scalable storage technologies for bioinformatics data, allowing parallel computing at the multicore and cluster levels. It provides the genomic data structure (GDS) file format for array-oriented data: this is a universal data format to store multiple data variables in a single file. The CoreArray library modules are demonstrated in Figure~\ref{fig:CoreArray-Modules}. A hierarchical data structure is used to store multiple extensible data variables in the GDS format, and all datasets are stored in a single file with chunked storage layout. A document about CoreArray can be found: \url{http://cran.r-project.org/web/packages/gdsfmt/vignettes/CoreArrayTutorial.pdf}.

Here, I focus on the application of CoreArray for statisticians working in the R environment, and developed R packages gdsfmt and SeqArray to address or reduce the computational burden associated with data management of sequencing variants. Gdsfmt provides a general R interface for the CoreArray library, and SeqArray is specifically designed for data management of sequencing variants. The kernels of gdsfmt and SeqArray were written in C/C++ and highly optimized. Genotypic data and annotations are stored in an array-oriented manner, offering efficient access of genetic variants using the R language. There are six key functions in SeqArray (Table~\ref{tab:KeyFun}), and most of data analyses could be done using these six functions. The 1000 Genomes Project released 39 million genetic variants for 1092 individuals, and a 26G data file was created by SeqArray to store sequencing variants with phasing information, where 2 bits were used as an atomic data type. The file size can be further reduced to 1.3G by compression algorithms without sacrificing access efficiency, since it has a large proportion of rare variants.

SeqArray will be of great interest to scientists involved in data analyses of large-scale genomic sequencing data using R environment, particularly those with limited experience of low-level C programming and parallel computing.


% -------- BEGIN FIGURE --------
\begin{figure}[t]
	\centering
	\includegraphics[width=0.90\columnwidth]{CoreArray-Module.png}
\caption{CoreArray library modules.}
\label{fig:CoreArray-Modules}
\end{figure}
% -------- END FIGURE --------

% -------- BEGIN TABLE --------
\begin{table}[t]
\caption{The key functions in the SeqArray package.}
\label{tab:KeyFun}
\begin{center}
\begin{tabular}{l | p{12cm}}
	\hline
	Function     & Description \\
	\hline\hline
	seqVCF2GDS   & Imports VCF files \\
	seqSummary   & Gets the summary of a sequencing GDS file (\# of samples, \# of variants, INFO/FORMAT variables, etc) \\
	seqSetFilter & Sets a filter to sample or variant (define a subset of data) \\
	seqGetData   & Gets data from a sequencing GDS file (from a subset of data) \\
	seqApply     & Applies a user-defined function over array margins \\
	seqParallel  & Applies functions in parallel \\
	\hline
\end{tabular}
\end{center}
\end{table}
% -------- END TABLE --------


% ---- Preparing Data ----
\section{Preparing Data}

% -------- Data formats used in SeqArray --------
\subsection{Data formats used in SeqArray}

To support efficient memory management for genome-wide numerical data, the \hn{gdsfmt} package provides the genomic data structure (GDS) file format for array-oriented bioinformatic data based on the CoreArray library, which is a container for storing genotypic and annotation data. The GDS format supports data blocking so that only the subset of data that is being processed needs to reside in memory.

<<>>=
# load the R package SeqArray
library(SeqArray)
@

Here is a typical GDS file shipped with the SeqArray package:
<<>>=
gds.fn <- seqExampleFileName("gds")
# or gds.fn <- "C:/YourFolder/Your_GDS_File.gds"
gds.fn

seqSummary(gds.fn)
@
\fn{seqExampleFileName()} returns the file name of a GDS file used as an example in \hn{SeqArray}, and it is a subset of data from the 1000 Genomes Project. \fn{seqSummary()} summarizes the genotypes and annotations stored in the GDS file.

<<>>=
# open a GDS file
genofile <- seqOpen(gds.fn)

# display the contents of the GDS file in a hierarchical structure
genofile
@

For those who would like to know how variable-length genotypic data and annotations are stored in an array-oriented manner, \fn{print(, all=TRUE)} displays all contents including hidden structures:
<<>>=
# display all contents of the GDS file
print(genofile, all=TRUE)

# close the GDS file
seqClose(genofile)
@

The output lists all variables stored in the GDS file. At the first level, it stores variables \vr{sample.id}, \vr{variant.id}, etc. The additional information are displayed in the square brackets indicating data type, size, compressed or not + compression ratio, where ``Bit2'' indicates that each byte encodes up to four alleles since one byte consists of eight bits, and ``VStr8'' indicates variable-length character. The annotations are stored in the directory \vr{annotation}, which includes the fields of ID, QUAL, FILTER, INFO and FORMAT corresponding to the original VCF file(s). All of the functions in \hn{SeqArray} require a minimum set of variables in the annotation data:
\begin{itemize}
	\item \vr{sample.id}, a unique identifier for each sample.
	\item \vr{variant.id}, a unique identifier for each variant.
	\item \vr{position}, integer, the base position of each variant on the chromosome, and 0 or NA for unknown position.
	\item \vr{chromosome}, character, the chromosome code, e.g., 1-22 for autosomes, X, Y, XY (the pseudoautosomal region), M (the mitochondrial probes), and ``'' (a blank string) for probes with unknown chromosome.
	\item \vr{allele}, character, reference and alternative alleles using comma as a separator.
	\item {\vr{genotype}, a folder,
		\begin{itemize}
			\item \vr{data}, a 3-dimensional array for genotypic data, the first dimension refers to the number of ploidy, the second is sample and the third is variant.
			\item \vr{@data}, the index data for the variable \vr{data}, and the prefix \vr{@} is used to indicate the index data. It should be equal-size as \vr{variant.id}, which is used to specify the data size of each variant.
			\item \vr{extra.index}, an index (3-by-$*$) matrix for triploid call (look like ``0/0/1'' in the VCF file). E.g., for ``0/0/1'', the first two alleles are stored in \vr{data}, and the last allele is saved in the variable \vr{extra}. For each column of \vr{extra.index}, the first value is the index of sample (starting from 1), the second value is the index of variant (starting from 1), and the last value is how many alleles remain (usually it is 1 since the first two alleles are stored in \vr{data}) that indicates how many alleles stored in \vr{extra} contiguously.
			\item \vr{extra}, one-dimensional array, the additional data for triploid call, each allele block corresponds to each column in \vr{extra.index}.
		\end{itemize}}
\end{itemize}

The optional variables include \vr{phase} (phasing information) and \vr{annotation}. The variable \vr{phase} includes:
\begin{itemize}
	\item \vr{data}, a matrix or 3-dimensional array for phasing information. ``0'' for unphased status and ``1'' for phased status. If it is a matrix, the first dimension is sample and the second is variant, corresponding to diploid genotypic data. If it is a 3-dimensional array, the first dimension refers to the number of ploidy minus one. More details about ``/'' and ``|'' in a VCF file can be founded: \url{http://www.1000genomes.org/wiki/Analysis/Variant Call Format/vcf-variant-call-format-version-41}.
	\item \vr{extra.index}, an index (3-by-$*$) matrix for triploid call (look like ``0/0/1'' in the VCF file). E.g., for ``0/0/1'', the first separator (``/'' here) is stored in \vr{data}, and the last separator is saved in the variable \vr{extra}. For each column of \vr{extra.index}, the first value is the index of sample (starting from 1), the second value is the index of variant (starting from 1), and the last value is how many separators remain (usually it is 1 since the first separator is stored in \vr{data}) that indicates how many separator stored in \vr{extra} contiguously.
	\item \vr{extra}, one-dimensional array, the additional data of separator indicator for triploid call, each separator block corresponds to each column in \vr{extra.index}.
\end{itemize}

The variable \vr{annotation} includes:
\begin{itemize}
	\item \vr{id}, ID semi-colon separated list of unique identifiers where available. If this is a dbSNP variant it is encouraged to use the rs number(s). No identifier should be present in more than one data record. If there is no identifier available, then a blank string is used.
	\item \vr{qual}, phred-scaled quality score for the assertion made in ALT.
	\item \vr{filter}, PASS if this position has passed all filters, i.e. a call is made at this position.
	\item {\vr{info}, additional information for each variant, according to the INFO field in a VCF file,
		\begin{itemize}
			\item \vr{VARIABLE\_NAME}, variable. If it is fixed-length, missing value indicates that there is no entry for that variant in the VCF file.
			\item \vr{@VARIABLE\_NAME}, \underline{optional} if \vr{VARIABLE\_NAME} is variable-length, one-dimensional array. The prefix \vr{@} is used to indicate the index data. It should be equal-size as \vr{variant.id}, which is used to specify the data size of each variant.
			\item \vr{OTHER\_VARIABLES, ...}
		\end{itemize}}
	\item {\vr{format}, additional information for each variant and sample, according to the FORMAT field in a VCF file,
		\begin{itemize}
			\item {\vr{VARIABLE\_NAME}, a folder,
				\begin{itemize}
					\item \vr{data}, a $n_{samp}$-by-$*$ matrix.
					\item \vr{@data}, one-dimensional array, the index data for the variable \vr{data}, and the prefix \vr{@} is used to indicate the index data. It should be equal-size as \vr{variant.id}, which is used to specify the data size of each variant.
				\end{itemize}}
			\item \vr{OTHER\_VARIABLES, ...}
		\end{itemize}}
\end{itemize}


% -------- Format conversion from VCF files --------
\subsection{Format conversion from VCF files}

The \hn{SeqArray} package provides a function \fn{seqVCF2GDS} to reformat a VCF file, and it allows merging multiple VCF files during format conversion. The genotypic and annotation data are stored in a compressed manner.

<<>>=
# the VCF file, using the example in the SeqArray package
vcf.fn <- seqExampleFileName("vcf")
# or vcf.fn <- "C:/YourFolder/Your_VCF_File.vcf"
vcf.fn

# parse the header
seqVCF.Header(vcf.fn)
@
The columns ``Number'', ``Type'' and ``Description'' are defined by the 1000 Genomes Project: \url{http://www.1000genomes.org/wiki/Analysis/Variant Call Format/vcf-variant-call-format-version-41}. Briefly, the Number entry is an Integer that describes the number of values that can be included with the INFO field. For example, if the INFO field contains a single number, then this value should be 1; if the INFO field describes a pair of numbers, then this value should be 2 and so on. If the field has one value per alternate allele then this value should be `A'; if the field has one value for each possible genotype then this value should be `G'.  If the number of possible values varies, is unknown, or is unbounded, then this value should be `.'. The `Flag' type indicates that the INFO field does not contain a Value entry, and hence the Number should be 0 in this case. Possible Types for FORMAT fields are: Integer, Float, Character, and String (this field is otherwise defined precisely as the INFO field).

<<>>=
# convert, save in "tmp.gds"
seqVCF2GDS(vcf.fn, "tmp.gds")
seqSummary("tmp.gds")
@

<<echo=FALSE>>=
unlink("tmp.gds")
@


% -------- Export to a VCF File --------
\subsection{Export to a VCF File}

The \hn{SeqArray} package provides a function \fn{seqGDS2VCF} to export data to a VCF file. The arguments \vr{info.var} and \vr{fmt.var} in \fn{seqGDS2VCF} allow users to specify the variables listed in the INFO and FORMAT fields of VCF format, or remove the INFO and FORMAT information. \fn{seqSetFilter} can be used to define a subset of data for the export.

<<>>=
# the file of GDS
gds.fn <- seqExampleFileName("gds")
# or gds.fn <- "C:/YourFolder/Your_GDS_File.gds"

# open a GDS file
genofile <- seqOpen(gds.fn)

# convert
seqGDS2VCF(genofile, "tmp.vcf.gz")
# read
z <- readLines("tmp.vcf.gz", n=20)
for (i in z) cat(substr(i, 1, 76), " ...\n", sep="")

# output BN,GP,AA,HM2 in INFO (the variables are in this order), no FORMAT
seqGDS2VCF(genofile, "tmp2.vcf.gz", info.var=c("BN","GP","AA","HM2"), fmt.var=character(0))
# read
z <- readLines("tmp2.vcf.gz", n=15)
for (i in z) cat(substr(i, 1, 56), " ...\n", sep="")

# close the GDS file
seqClose(genofile)
@

Users can use \fn{diff}, a command line tool in Unix-like systems, to compare files line by line, in order to confirm data consistency. 
\begin{Schunk}
\begin{Sinput}
# assuming the original VCF file is old.vcf.gz,
# call "seqVCF2GDS" for the import and "seqGDS2VCF" for the export to create a new VCF file new.vcf.gz
$ diff <(zcat old.vcf.gz) <(zcat new.vcf.gz)
# OR
$ diff <(gunzip -c old.vcf.gz) <(gunzip -c new.vcf.gz)
\end{Sinput}

\begin{Soutput}
1a2,3
> ##fileDate=20130309
> ##source=SeqArray_RPackage_v1.0

# LOOK GOOD! There are only two lines different, and both are in the header.
\end{Soutput}
\end{Schunk}

<<>>=
# delete temporary files
unlink(c("tmp.vcf.gz", "tmp1.vcf.gz", "tmp2.vcf.gz"))
@


% -------- Modification --------
\subsection{Modification}

The \hn{SeqArray} package provides a function \fn{seqDelete} to remove data annotations in the INFO and FORMAT fields. It is suggested to use \fn{cleanup.gds} in the \hn{gdsfmt} package after calling \fn{seqDelete} to reduce the file size. For example,

<<>>=
# the file of VCF
vcf.fn <- seqExampleFileName("vcf")
# or vcf.fn <- "C:/YourFolder/Your_VCF_File.vcf"

# convert
seqVCF2GDS(vcf.fn, "tmp.gds", verbose=FALSE)

# make sure that open with "readonly=FALSE"
genofile <- seqOpen("tmp.gds", readonly=FALSE)

# display the original structure
genofile

# delete "HM2", "HM3", "AA", "OR" and "DP"
seqDelete(genofile, info.varname=c("HM2", "HM3", "AA", "OR"), format.varname="DP")

# display
genofile

# close the GDS file
seqClose(genofile)

# clean up the fragments, reduce the file size
cleanup.gds("tmp.gds")
@

<<echo=FALSE>>=
unlink("tmp.gds")
@





% ---- Data Processing ----
\section{Data Processing}

% -------- Get Data --------
\subsection{Get Data}

<<>>=
# open a GDS file
gds.fn <- seqExampleFileName("gds")
genofile <- seqOpen(gds.fn)
@

It is suggested to use \fn{seqGetData} to take out data from the GDS file since this function can take care of variable-length data and multi-allelic genotypes, although users could also use \fn{read.gdsn} in the \hn{gdsfmt} package to read data.
<<>>=
# take out sample id
head(samp.id <- seqGetData(genofile, "sample.id"))

# take out variant id
head(variant.id <- seqGetData(genofile, "variant.id"))

# get "chromosome"
table(seqGetData(genofile, "chromosome"))

# get "allele"
head(seqGetData(genofile, "allele"))

# get "annotation/info/GP"
head(seqGetData(genofile, "annotation/info/GP"))
@

Users can set a filter to sample and/or variant by \fn{seqSetFilter}. For example, we consider a data subset consisting of three samples and four variants:
<<>>=
# set sample and variant filters
seqSetFilter(genofile, sample.id=samp.id[c(2,4,6)])
set.seed(100)
seqSetFilter(genofile, variant.id=sample(variant.id, 4))

# get "allele"
seqGetData(genofile, "allele")
@

Get genotypic data, it is a 3-dimensional array with respect to allele, sample and variant. ``0'' refers to the reference allele (or the first allele in the variable \vr{allele}), ``1'' for the second allele, and so on, while NA is missing allele.
<<>>=
# get genotypic data
seqGetData(genofile, "genotype")
@

{\bf Now} let us take a look at a variable-length dataset \vr{annotation/info/AA}, which corresponds to the INFO column in the original VCF file. There are four variants, each variant has data with size ONE (\vr{\$length}), and data are saved in \vr{\$data} contiguously. \vr{\$length} could be ZERO indicating no data for that variant.
<<>>=
# get "annotation/info/AA", a variable-length dataset
seqGetData(genofile, "annotation/info/AA")
@
Another variable-length dataset is \vr{annotation/format/DP} corresponding to the FORMAT column in the original VCF file. Again, \vr{\$length} refers to the size of each variant, and data are saved in \vr{\$data} contiguously with respect to the dimension \vr{variant}. \vr{\$length} could be ZERO indicating no data for that variant.
<<>>=
# get "annotation/format/DP", a variable-length dataset
seqGetData(genofile, "annotation/format/DP")
@


% -------- Apply Functions Over Array Margins --------
\subsection{Apply Functions Over Array Margins}

\hn{SeqArray} provides \fn{seqApply} to apply a user-defined function over array margins, which is coded in C/C++. It is suggested to use \fn{seqApply} instead of \fn{apply.gdsn} in the \hn{gdsfmt} package, since this function can take care of variable-length data and multi-allelic genotypes. For example, read two variables \vr{genotype} and \vr{annotation/id} variant by variant:
<<>>=
# set sample and variant filters
set.seed(100)
seqSetFilter(genofile, sample.id=samp.id[c(2,4,6)], variant.id=sample(variant.id, 4))
@
<<>>=
# read multiple variables variant by variant
seqApply(genofile, c(geno="genotype", id="annotation/id"),
	FUN=function(x) print(x), margin="by.variant", as.is="none")
@

<<>>=
# remove the sample and variant filters
seqSetFilter(genofile)

# get the numbers of alleles per variant
z <- seqApply(genofile, "allele",
	FUN=function(x) length(unlist(strsplit(x,","))), as.is="integer")
table(z)
@

Another example is to use the argument \vr{var.index} in the function \fn{seqApply} to include external information in the analysis, where the variable \vr{index} in the user-defined \vr{FUN} is an index of the specified dimension starting from 1 (e.g., variant).
<<>>=
HM3 <- seqGetData(genofile, "annotation/info/HM3")
@
<<>>=
# Now HM3 is a global variable
# print out RS id if the frequency of reference allele is less than 0.5% and it is HM3
seqApply(genofile, c(geno="genotype", id="annotation/id"),
	FUN = function(index, x) {
		p <- mean(x$geno == 0, na.rm=TRUE)  # the frequency of reference allele
		if ((p < 0.005) & HM3[index]) print(x$id) },
	as.is="none", var.index=TRUE, margin="by.variant")
@


% -------- Apply Functions in Parallel --------
\subsection{Apply Functions in Parallel}

Now, let us consider an example of calculating the frequency of reference allele, and this calculation can be done using \fn{seqApply} and \fn{seqParallel}. Let's try the uniprocessor implementation first.
<<>>=
# calculate the frequency of reference allele,
afreq <- seqApply(genofile, "genotype", FUN=function(x) mean(x==0, na.rm=TRUE),
	as.is="double", margin="by.variant")
length(afreq)
summary(afreq)
@

A multi-process implementation:
<<eval=FALSE>>=
# load the "parallel" package
library(parallel)

# Use option cl.core to choose an appropriate cluster size (or # of cores)
cl <- makeCluster(getOption("cl.cores", 2))
@
<<echo=FALSE>>=
cl <- NULL
@
<<>>=
# run in parallel
afreq <- seqParallel(cl, genofile, FUN = function(gdsfile) {
		seqApply(gdsfile, "genotype", as.is="double",
			FUN=function(x) mean(x==0, na.rm=TRUE))
	}, split = "by.variant")

length(afreq)
summary(afreq)
@

<<eval=FALSE>>=
# Since we created the cluster manually, we should stop it:
stopCluster(cl)
@

<<>>=
seqClose(genofile)
@


% -------- Integration with Other Packages in Bioconductor --------
\subsection{Integration with Other Packages in Bioconductor}

A new R/Bioconductor package ``\hn{SeqTools}'' will be submitted to Bioconductor soon by Stephanie M. Gogarten \url{sdmorris@u.washington.edu} from the Department of Biostatistics at University of Washington -- Seattle, which defines S4 classes and methods for other common operations on SeqArray datasets. \hn{SeqTools} will provides functions compatible with current Bioconductor classes like \vr{GRanges}, \vr{DNAStringSet}, etc.




% ---- Examples ----
\section{Examples}

In this section, a GDS file shipped with the package is used as an example:
<<>>=
# open a GDS file
gds.fn <- seqExampleFileName("gds")
genofile <- seqOpen(gds.fn)
@

% -------- The performance of seqApply --------
\subsection{The performance of seqApply}

Let us try three approaches to export unphased genotypes: 1) the for loop in R; 2) vectorize the function in R; 3) the for loop in \fn{seqApply}. The function \fn{seqApply} has been highly optimized by blocking the computations to exploit the high-speed memory instead of disk. The results of running times (listed as follows) indicate that \fn{seqApply} works well and is comparable with vectorization in R.

{\bf 1) the for loop in R:}
\begin{Schunk}
\begin{Sinput}
> system.time({
>     geno <- seqGetData(genofile, "genotype")
>     gc <- matrix("", nrow=dim(geno)[2], ncol=dim(geno)[3])
>     for (i in 1:dim(geno)[3])
>     {
>         for (j in 1:dim(geno)[2])
>         gc[j,i] <- paste(geno[1,j,i], geno[2,j,i], sep="/")
>     }
>     gc[gc == "NA/NA"] <- NA
>     gc
> })
\end{Sinput}
\begin{Soutput}
   user  system elapsed 
  2.185   0.019   2.386       <- the function takes 2.4 seconds
\end{Soutput}

\begin{Sinput}
> dim(gc)
\end{Sinput}
\begin{Soutput}
[1]   90 1348
\end{Soutput}
\begin{Sinput}
> table(c(gc))
\end{Sinput}
\begin{Soutput}
  0/0   0/1   1/0   1/1  <NA> 
88350  7783  8258  8321  8608 
\end{Soutput}
\end{Schunk}


{\bf 2) Vectorize the function in R:}
\begin{Schunk}
\begin{Sinput}
> system.time({
>     geno <- seqGetData(genofile, "genotype")
>     gc <- matrix(paste(geno[1,,], geno[2,,], sep="/"), nrow=dim(geno)[2], ncol=dim(geno)[3])
>     gc[gc == "NA/NA"] <- NA
>     gc
> })
\end{Sinput}
\begin{Soutput}
   user  system elapsed 
  0.134   0.002   0.147       <- the function takes 0.15 seconds
\end{Soutput}
\end{Schunk}


{\bf 3) the for loop in \fn{seqApply}:}
\begin{Schunk}
\begin{Sinput}
> system.time({
>     gc <- seqApply(genofile, "genotype", function(x) { paste(x[1,], x[2,], sep="/") },
>         margin="by.variant", as.is="list")
>     gc2 <- matrix(unlist(gc), ncol=length(gc))
>     gc2[gc2 == "NA/NA"] <- NA
>     gc2
> })
\end{Sinput}
\begin{Soutput}
   user  system elapsed 
  0.157   0.002   0.168       <- the function takes 0.17 seconds
\end{Soutput}
\end{Schunk}


% -------- Missing Rates --------
\subsection{Missing Rates}

{\bf 1) Calculate the missing rate per variant:}
<<>>=
m.variant <- local({
    # get ploidy, the number of samples and variants
    z <- seqSummary(genofile, "genotype")
    # dm[1] -- # of selected samples, dm[2] -- # of selected variants
    dm <- z$seldim
    # ploidy
    ploidy <- z$dim[1]

    # apply the function marginally
    m <- seqApply(genofile, "genotype", function(x) { sum(is.na(x)) },
        margin="by.variant", as.is="integer")

    # output
    m / (ploidy * dm[1])
})

length(m.variant)
summary(m.variant)
@

{\bf 2) Calculate the missing rate per sample:}
<<>>=
m.sample <- local({
    # get ploidy, the number of samples and variants
    z <- seqSummary(genofile, "genotype")
    # dm[1] -- # of selected samples, dm[2] -- # of selected variants
    dm <- z$seldim
    # ploidy
    ploidy <- z$dim[1]

    # need a global variable (only available in the bracket of "local")
    n <- integer(dm[1])

    # apply the function marginally
    seqApply(genofile, "genotype", function(x) { n <<- n + colSums(is.na(x)) },
        margin="by.variant", as.is="none")

    # output
    n / (ploidy * dm[2])
})

length(m.sample)
summary(m.sample)
@

%     -------- Multi-process Implementation --------
\subsubsection{Multi-process Implementation}

<<eval=FALSE>>=
# load the "parallel" package
library(parallel)

# Use option cl.core to choose an appropriate cluster size (or # of cores)
cl <- makeCluster(getOption("cl.cores", 2))
@
<<echo=FALSE>>=
cl <- NULL
@

{\bf 1) Calculate the missing rate per variant:}
<<>>=
# run in parallel
m.variant <- local({
    # get ploidy, the number of samples and variants
    z <- seqSummary(genofile, "genotype")
    # dm[1] -- # of selected samples, dm[2] -- # of selected variants
    dm <- z$seldim
    # ploidy
    ploidy <- z$dim[1]

    m <- seqParallel(cl, genofile, FUN = function(gdsfile) {
        # apply the function marginally
        seqApply(gdsfile, "genotype", function(x) { sum(is.na(x)) },
            margin="by.variant", as.is="integer")
    }, split = "by.variant")

    # output
    m / (ploidy * dm[1])
})

summary(m.variant)
@

{\bf 2) Calculate the missing rate per sample:}
<<>>=
m.sample <- local({
    # run in parallel
    m <- seqParallel(cl, genofile, FUN = function(gdsfile)
        local({
            # dm[1] -- # of selected samples, dm[2] -- # of selected variants
            dm <- seqSummary(gdsfile, "genotype")$seldim

            # need a global variable (only available in the bracket of "local")
            n <- integer(dm[1])

            # apply the function marginally
            seqApply(gdsfile, "genotype", function(x) { n <<- n + colSums(is.na(x)) },
                margin="by.variant", as.is="none")

            # output
            n
        }), .combine = "+",     # sum all variables "n" of different processes
        split = "by.variant")

    # get ploidy, the number of samples and variants
    z <- seqSummary(genofile, "genotype")
    # dm[1] -- # of selected samples, dm[2] -- # of selected variants
    dm <- z$seldim
    # ploidy
    ploidy <- z$dim[1]

    # output
    m / (ploidy * dm[2])
})

summary(m.sample)
@


<<eval=FALSE>>=
# Since we created the cluster manually, we should stop it:
stopCluster(cl)
@



% -------- Allele Frequency --------
\subsection{Allele Frequency}

{\bf Calculate the frequency of reference allele:}
<<>>=
# apply the function variant by variant
afreq <- seqApply(genofile, "genotype", function(x) { mean(x==0, na.rm=TRUE) },
	as.is="double", margin="by.variant")

length(afreq)
summary(afreq)
@

%     -------- Multi-process Implementation --------
\subsubsection{Multi-process Implementation}

<<eval=FALSE>>=
# load the "parallel" package
library(parallel)

# Use option cl.core to choose an appropriate cluster size (or # of cores)
cl <- makeCluster(getOption("cl.cores", 2))
@
<<echo=FALSE>>=
cl <- NULL
@
<<>>=
# run in parallel
afreq <- seqParallel(cl, genofile, FUN = function(gdsfile) {
        seqApply(gdsfile, "genotype", as.is="double",
            FUN=function(x) mean(x==0, na.rm=TRUE))
    }, split = "by.variant")

length(afreq)
summary(afreq)
@

<<eval=FALSE>>=
# Since we created the cluster manually, we should stop it:
stopCluster(cl)
@


% -------- Principal Component Analysis --------
\subsection{Principal Component Analysis}

In the principal component analysis, we employ the dosage of reference alleles to avoid confusion of multiple alleles. The genetic correlation matrix is defined as $M = [ m_{j,j'} ]$:
\[
	m_{j,j'} = \frac{1}{L} \sum_{l=1}^L \frac{(g_{j,l} - 2p_l)(g_{j',l} - 2p_l)}{p_l (1 - p_l)}
\]
where $g_{j,l}$ is a genotype of individual $j$ at locus $l$ ($\in \{0,1,2\}$, \# of reference allele), $p_l$ is the frequency of reference allele and there are $L$ loci in total.

<<>>=
# genetic correlation matrix
genmat <- local({
    # get the number of samples and variants
    # dm[1] -- # of selected samples, dm[2] -- # of selected variants
    dm <- seqSummary(genofile, "genotype")$seldim

    # need a global variable (only available in the bracket of "local")
    s <- matrix(0.0, nrow=dm[1], ncol=dm[1])

    # apply the function variant by variant
    seqApply(genofile, "genotype", function(x) {
        g <- (x==0)                   # indicator of reference allele
        p <- mean(g, na.rm=TRUE)      # allele frequency
        g2 <- colSums(g) - 2*p        # genotypes adjusted by allele frequency
        m <- (g2 %o% g2) / (p*(1-p))  # genetic correlation matrix
        m[!is.finite(m)] <- 0         # correct missing values
        s <<- s + m                   # output to the global variable "s"
    }, margin="by.variant", as.is="none")

    # output, scaled by the trace of matrix "s" over the number of samples
    s / (sum(diag(s)) / dm[1])
})

# eigen-decomposition
eig <- eigen(genmat)

# eigenvalues
head(eig$value)
@
<<fig=TRUE, pdf=FALSE, png=TRUE, resolution=100>>=
# eigenvectors
plot(eig$vectors[,1], eig$vectors[,2], xlab="PC 1", ylab="PC 2")
@


%     -------- Multi-process Implementation --------
\subsubsection{Multi-process Implementation}

<<eval=FALSE>>=
# load the "parallel" package
library(parallel)

# Use option cl.core to choose an appropriate cluster size (or # of cores)
cl <- makeCluster(getOption("cl.cores", 2))
@
<<echo=FALSE>>=
cl <- NULL
@
<<>>=
genmat <- seqParallel(cl, genofile, FUN = function(gdsfile)
    local({
        # get the number of samples and variants
        # dm[1] -- # of selected samples, dm[2] -- # of selected variants
        dm <- seqSummary(gdsfile, "genotype")$seldim

        # need a global variable (only available in the bracket of "local")
        s <- matrix(0.0, nrow=dm[1], ncol=dm[1])

        # apply the function variant by variant
        seqApply(gdsfile, "genotype", function(x) {
            g <- (x==0)                   # indicator of reference allele
            p <- mean(g, na.rm=TRUE)      # allele frequency
            g2 <- colSums(g) - 2*p        # genotypes adjusted by allele frequency
            m <- (g2 %o% g2) / (p*(1-p))  # genetic correlation matrix
            m[!is.finite(m)] <- 0         # correct missing values
            s <<- s + m                   # output to the global variable "s"
        }, margin="by.variant", as.is="none")

        # output
        s
    }), .combine = "+",     # sum all variables "s" of different processes
    split = "by.variant")

# finally, scaled by the trace of matrix "s" over the number of samples
dm <- seqSummary(genofile, "genotype")$seldim
genmat <- genmat / (sum(diag(genmat)) / dm[1])

# eigen-decomposition
eig <- eigen(genmat)
# eigenvalues
head(eig$value)
@

<<eval=FALSE>>=
# Since we created the cluster manually, we should stop it:
stopCluster(cl)
@



% -------- Individual Inbreeding Coefficient --------
\subsection{Individual Inbreeding Coefficient}

To calculate an individual inbreeding coefficient using SNP genotype data, I demonstrate how to use \fn{seqApply} to calculate Visscher's estimator described in Yang {\it et al.} (2010) [5]. The estimator of individual inbreeding coefficient is defined as
\[
	\hat{\theta} = \frac{1}{L} \sum_{l=1}^L \frac{g_l^2 - g_l (1 + 2p_l) + 2p_l^2}{2 p_l (1 - p_l)}
\]
where $g_l$ is a SNP genotype at locus $l$ ($\in \{0,1,2\}$, \# of reference allele), $p_l$ is the frequency of reference allele and there are $L$ loci in total.

<<>>=
coeff <- local({
    # get the number of samples and variants
    # dm[1] -- # of selected samples, dm[2] -- # of selected variants
    dm <- seqSummary(genofile, "genotype")$seldim

    # need global variables (only available in the bracket of "local")
    n <- integer(dm[1])
    s <- double(dm[1])

    # apply the function variant by variant
    seqApply(genofile, "genotype", function(x) {
        p <- mean(x==0, na.rm=TRUE)      # allele frequency
        g <- colSums(x==0)               # genotypes: # of reference allele
        d <- (g*g - g*(1 + 2*p) + 2*p*p) / (2*p*(1-p))
        n <<- n + is.finite(d)           # output to the global variable "n"
        d[!is.finite(d)] <- 0
        s <<- s + d                      # output to the global variable "s"
    }, margin="by.variant", as.is="none")

    # output
    s / n
})

length(coeff)
summary(coeff)
@

%     -------- Multi-process Implementation --------
\subsubsection{Multi-process Implementation}

<<eval=FALSE>>=
# load the "parallel" package
library(parallel)

# Use option cl.core to choose an appropriate cluster size (or # of cores)
cl <- makeCluster(getOption("cl.cores", 2))
@
<<echo=FALSE>>=
cl <- NULL
@
<<>>=
coeff <- seqParallel(cl, genofile, FUN = function(gdsfile)
    local({
        # get the number of samples and variants
        # dm[1] -- # of selected samples, dm[2] -- # of selected variants
        dm <- seqSummary(gdsfile, "genotype")$seldim

        # need global variables (only available in the bracket of "local")
        n <- integer(dm[1])
        s <- double(dm[1])

        # apply the function variant by variant
        seqApply(gdsfile, "genotype", function(x) {
            p <- mean(x==0, na.rm=TRUE)      # allele frequency
            g <- colSums(x==0)               # genotypes: # of reference allele
            d <- (g*g - g*(1 + 2*p) + 2*p*p) / (2*p*(1-p))
            n <<- n + is.finite(d)           # output to the global variable "n"
            d[!is.finite(d)] <- 0
            s <<- s + d                      # output to the global variable "s"
        }, margin="by.variant", as.is="none")

        # output
        list(s=s, n=n)
    }), # sum all variables "s" and "n" of different processes
    .combine = function(x1,x2) { list(s = x1$s + x2$s, n = x1$n + x2$n) },
    split = "by.variant")

# finally, average!
coeff <- coeff$s / coeff$n

summary(coeff)
@

<<eval=FALSE>>=
# Since we created the cluster manually, we should stop it:
stopCluster(cl)
@

<<>>=
# close the GDS file
seqClose(genofile)
@




% ---- The 1000 Genomes Project ----
\section{The 1000 Genomes Project}

The 1000 Genomes Project datasets consist of 39,706,715 variants and 1,092 study samples. The original VCF data files for the 1000 Genomes Project were downloaded from \url{http://ftp.1000genomes.ebi.ac.uk/vol1/ftp/phase1/analysis_results/integrated_call_sets/}, and all compressed VCF files are $\sim$ 180G in total. The function ``seqVCF2GDS'' in the R package SeqArray was used to convert and merge all VCF files, and all $\sim$39M variants and annotations were extracted from the VCF files without losing any information. A single GDS file of $\sim$140G was created, and all data variables were stored in a compressed manner.

The detailed information are listed here:
\begin{Schunk}
\begin{Sinput}
> seqSummary("G1000-Release.gds")
\end{Sinput}
\begin{Soutput}
Sequence Variant Format: v1.0
The number of samples: 1092
The number of variants: 39706715
The chromosomes:
      1      10      11      12      13      14      15      16      17      18 
3007196 1882663 1894908 1828006 1373000 1258254 1130554 1210619 1046733 1088820 
     19       2      20      21      22       3       4       5       6       7 
 816115 3307592  855166  518965  494328 2763454 2736765 2530217 2424425 2215231 
      8       9       X    <NA> 
2183839 1652388 1487477       0 
The number of alleles per site:
       2 
39706715 
Annotation, information variables:
	LDAF, 1, Float, MLE Allele Frequency Accounting for LD
	AVGPOST, 1, Float, Average posterior probability from MaCH/Thunder
	RSQ, 1, Float, Genotype imputation quality from MaCH/Thunder
	ERATE, 1, Float, Per-marker Mutation rate from MaCH/Thunder
	THETA, 1, Float, Per-marker Transition rate from MaCH/Thunder
	CIEND, 2, Integer, Confidence interval around END for imprecise variants
	CIPOS, 2, Integer, Confidence interval around POS for imprecise variants
	END, 1, Integer, End position of the variant described in this record
	HOMLEN, ., Integer, Length of base pair identical micro-homology at event breakpoints
	HOMSEQ, ., String, Sequence of base pair identical micro-homology at event breakpoints
	SVLEN, 1, Integer, Difference in length between REF and ALT alleles
	SVTYPE, 1, String, Type of structural variant
	AC, ., Integer, Alternate Allele Count
	AN, 1, Integer, Total Allele Count
	AA, 1, String, Ancestral Allele, ftp://ftp.1000genomes.ebi.ac.uk/vol1/ftp/pilot_data/technical/reference/ancestral_alignments/README
	AF, 1, Float, Global Allele Frequency based on AC/AN
	AMR_AF, 1, Float, Allele Frequency for samples from AMR based on AC/AN
	ASN_AF, 1, Float, Allele Frequency for samples from ASN based on AC/AN
	AFR_AF, 1, Float, Allele Frequency for samples from AFR based on AC/AN
	EUR_AF, 1, Float, Allele Frequency for samples from EUR based on AC/AN
	VT, 1, String, indicates what type of variant the line represents
	SNPSOURCE, ., String, indicates if a snp was called when analysing the low coverage or exome alignment data
Annotation, format variables:
	DS, 1, Float, Genotype dosage from MaCH/Thunder
	GL, ., Float, Genotype Likelihoods
\end{Soutput}
\end{Schunk}

\begin{Schunk}
\begin{Soutput}
+ 	[   ]
|--+ description	[   ] *
|--+ sample.id	[ VStr8 1092 ZIP(26.02%) ]
|--+ variant.id	[ Int32 39706715 ZIP(34.58%) ]
|--+ position	[ Int32 39706715 ZIP(45.97%) ]
|--+ chromosome	[ VStr8 39706715 ZIP(0.10%) ]
|--+ allele	[ VStr8 39706715 ZIP(20.59%) ]
|--+ genotype	[   ] *
|  |--+ data	[ Bit2 2x1092x39706715 ZIP(5.61%) ]
|  |--+ extra.index	[ Int32 3x0 ZIP ] *
|  |--+ extra	[ Int16 0 ZIP ]
|--+ phase	[   ]
|  |--+ data	[ Bit1 1092x39706715 ZIP(0.11%) ]
|  |--+ extra.index	[ Int32 3x0 ZIP ] *
|  |--+ extra	[ Bit1 0 ZIP ]
|--+ annotation	[   ]
|  |--+ id	[ VStr8 39706715 ZIP(38.26%) ]
|  |--+ qual	[ Float32 39706715 ZIP(3.44%) ]
|  |--+ filter	[ Int32,factor 39706715 ZIP(0.10%) ] *
|  |--+ info	[   ]
|  |  |--+ LDAF	[ Float32 39706715 ZIP(47.36%) ] *
|  |  |--+ AVGPOST	[ Float32 39706715 ZIP(28.40%) ] *
|  |  |--+ RSQ	[ Float32 39706715 ZIP(58.30%) ] *
|  |  |--+ ERATE	[ Float32 39706715 ZIP(13.38%) ] *
|  |  |--+ THETA	[ Float32 39706715 ZIP(20.83%) ] *
|  |  |--+ CIEND	[ Int32 2x39706715 ZIP(14.41%) ] *
|  |  |--+ CIPOS	[ Int32 2x39706715 ZIP(14.41%) ] *
|  |  |--+ END	[ Int32 39706715 ZIP(26.38%) ] *
|  |  |--+ HOMLEN	[ Int32 8856 ZIP(20.11%) ] *
|  |  |--+ HOMSEQ	[ VStr8 7050 ZIP(27.39%) ] *
|  |  |--+ SVLEN	[ Int32 39706715 ZIP(26.38%) ] *
|  |  |--+ SVTYPE	[ VStr8 39706715 ZIP(1.70%) ] *
|  |  |--+ AC	[ Int32 39706715 ZIP(29.30%) ] *
|  |  |--+ AN	[ Int32 39706715 ZIP(0.10%) ] *
|  |  |--+ AA	[ VStr8 39706715 ZIP(20.51%) ] *
|  |  |--+ AF	[ Float32 39706715 ZIP(22.77%) ] *
|  |  |--+ AMR_AF	[ Float32 39706715 ZIP(21.79%) ] *
|  |  |--+ ASN_AF	[ Float32 39706715 ZIP(22.93%) ] *
|  |  |--+ AFR_AF	[ Float32 39706715 ZIP(23.61%) ] *
|  |  |--+ EUR_AF	[ Float32 39706715 ZIP(23.07%) ] *
|  |  |--+ VT	[ VStr8 39706715 ZIP(1.31%) ] *
|  |  |--+ SNPSOURCE	[ VStr8 38671749 ZIP(0.35%) ] *
|  |--+ format	[   ]
|  |  |--+ DS	[   ] *
|  |  |  |--+ data	[ Float32 1092x39706715 ZIP(2.88%) ]
|  |  |--+ GL	[   ] *
|  |  |  |--+ data	[ Float32 1092x119120145 ZIP(27.61%) ]
\end{Soutput}
\end{Schunk}




% ---- Resources ----
\section{Resources}

\begin{enumerate}
	\item \hn{CoreArray} project: \url{http://corearray.sourceforge.net/}
	\item \hn{gdsfmt} R package: \url{http://cran.r-project.org/web/packages/gdsfmt/index.html}
	\item \hn{SeqArray} an R/Bioconductor package: \url{http://corearray.sourceforge.net/tutorials/SeqArray/}
\end{enumerate}


% ==========   Bibliography   ==========
\section*{References}

\singlespace
\begin{enumerate}
	\item [1] 1000 Genomes Project Consortium, Abecasis, G. R., Auton, A., Brooks, L. D., DePristo, M. A., Durbin, R. M., Handsaker, R. E., Kang, H. M., Marth, G. T., and McVean, G. A. An integrated map of genetic variation from 1,092 human genomes. {\it Nature} 491, 7422 (Nov 2012), 56--65.
	\item [2] Schadt, E. E., Linderman, M. D., Sorenson, J., Lee, L., and Nolan, G. P. Computational solutions to large-scale data management and analysis. {\it Nat Rev Genet} 11, 9 (Sep 2010), 647--657.
	\item [3] Danecek, P., Auton, A., Abecasis, G., Albers, C. A., Banks, E., DePristo, M. A., Handsaker, R. E., Lunter, G., Marth, G. T., Sherry, S. T., McVean, G., Durbin, R., and 1000 Genomes Project Analysis Group. The variant call format and vcftools. {\it Bioinformatics} 27, 15 (Aug 2011), 2156--2158.
	\item [4] Zheng X, Levine D, Shen J, Gogarten SM, Laurie C, Weir BS. A High-performance Computing Toolset for Relatedness and Principal Component Analysis of SNP Data. {\it Bioinformatics}. 2012 Oct 11.
	\item [5] Yang J, Benyamin B, McEvoy BP, Gordon S, Henders AK, Nyholt DR, Madden PA, Heath AC, Martin NG, Montgomery GW, Goddard ME, Visscher PM. 2010. Common SNPs explain a large proportion of the heritability for human height. Nat Genet. 42(7):565-9. Epub 2010 Jun 20.
\end{enumerate}
 

\end{document}
