The repository for the Machine Learning and Big Data with kdb+/q book by Novotny et al.
Order the book at https://www.wiley.com/en-us/Machine+Learning+and+Big+Data+with+KDB%2B+Q-p-9781119404750.
$ cd quantQ/lib
$ q quantQ.q -p 5000
The naming convention for each .q file reflects the corresponding book chapter and the functions it defines reside under a homonymous namespace, as outlined in Section 3.1.0.1.
| Section | Note |
|---|---|
| 7.1 | The example of comma join corresponds to t1,t6 and not t5,t6. |
| Section | Note |
|---|---|
| 7.2.10 | In the text we state that we aim to aggregate the data from the table dataSet2 over a window starting 1 minute prior to the trade and ending at the time of the trade.; however, the window is defined as starting at the time of the trade and ending 1 minute after the trade. The example should read window: (-00:01:00;0) +\: exec time from dataSet1;. |
| Section | Note |
|---|---|
| 14.1.6.1 | Ordering of phi vector inside implementation of .quantQ.ts.simAR should be reversed to be in line with definition 14.1 and example on page 276. Addressed in the repo. Variation of the function using adverbs also provided, under .quantQ.tse.simAR |
| Section | Note |
|---|---|
| 15.3 | Example following implementation of the Hamilton product (15.29-15.32) should read as .quantQ.quat.mult[quat1;quat3]. Definition of .quantQ.quat.mult has a typo which is fixed in the repo. |
| Section | Note |
|---|---|
| 22.2 | Missing functions .quantQ.nn.funcNN and .quantQ.nn.funcErrNN have been added to the repo. |
We have added .quantQ.math namespace with various mathematical functions, constants and identities. Currently, there are constants, hyperbolic functions, number of special functions and polynomials (defined in the real domain), and the most frequently used PDF and CDF. In order to obtain the multivariate normal distribution, we have included tetrachoric expansion.
We have added into the .quantQ.stats namespace functions to work with contingency tables, namely Exact Fisher test and Barnard test.
We have added a native implementation of Nelder-Mead (amoeba) optimisation method. Functions can be found in the .quantQ.amoeba namespace. The illustration shows a solution to Rosenbrock's function.
We have implemented the Needleman-Wunsch algorithm developed in bioinformatics which can be used to align two sequences (nucleotide sequences or general finite-length sequences) using principles of dynamic programming. Functions are within the .quantQ.stats namespace. The local matching using the Smith-Waterman algorithm is available as well. Levenshtein distance calculated with Wagner-Fischer algorithm has been added.
We have added the algorithms to perform the Dynamic Time Warp calculations in the .quantQ.dtw namespace. Details of the algorithm can be found here.
We have added deep neural networks. The features implemented include the dropout, batches, and different functional forms of annealing in learning and regularisation. The architecture is specified in the input dictionary; the rest is fully automated. More examples can be found here. The implementation is part of the .quantQ.nn namespace.
We have implemented the stochastic optimisation, which can be used to minimise the provided n-dimensional function using random search. The provided method is an iterative procedure which explores at every step a neighbourhood comprising of random points lying on the n-sphere, where the radius of the sphere is shrinking with occasional attempts to investigate further points. The implementation is part of the .quantQ.so namespace.
We have added the Support Vector Machine for binary classification using the Soft Margin and Stochastic Gradient Descent (using one observation per step). Functions are specified with a set of the default setup, which is customised based on the provided dataset. The Soft Margin specification is provided with regularisation parameter, which can be optimised using the built-in n-fold cross-validation method.
The implementation includes a function which calculates more than 20 statistics used to evaluate the binary classification, including specificity, accuracy, precision, or F1. More examples can be found here. The implementation is part of the .quantQ.svm namespace.
We have added the library with the Poisson distribution and the Poisson regression to estimate the integer-valued Poisson process. The functions are based on the maximum likelihood optimised using routines from .quantQ.opt library. The library also contains the L2-regularised version with n-fold cross-validation.
Examples and basic usage of the library can be found in here. The implementation is part of the .quantQ.pois namespace.
We have added name space .quantQ.quantum which contains a set of routines to set up and perform quantum computing using quibits. The library is not connected to any actual quantum computer and is for demonstration purposes only.
Examples and basic library usage can be found in here.
We have added the library .quantQ.tda which allows us to perform the topological data analysis for a cloud on n-dimensional points. The routines provided include calculation of the distance between points, identification of the all Vietoris-Rips complexes given the provided threshold, the routine to calculate all unique loops, and several analytical functions to get insight into data using the TDA.
Examples and basic library usage can be found in here.
We have added the library .quantQ.util with various utility functions.
We have added the library .quantQ.hopf to define and work with Hopfield networks. In addition, we have added Hebbian descent to calculate train the network for a provided input/output.
We have added the library .quantQ.ta which comprises a growing list of technical indicators from what is known as Technical Analysis. The details of the library can be found in here.
We have added the library .quantQ.rsa. The library contains the implementation of the RSA algorithm to encrypt message using public and private key. The purpose of the library is to illustrate the RSA concept. The library contains several additional functions to work with prime numbers and perform factorisation.
We have added the library .quantQ.rmt. The library contains implementation of Excess Out-of-Sample Risk and Fleeting Modes paper by Bouchaud et al. here. The algorithm performs the comparison of two datasets in terms of their empirical covariance matrices using the Random Matrix Theory. In order to implement the algorithm, we have added the Denman-Bevaers and power series algorithm to calculate the square-root of the matrix along with several utility functions. Further, .quantQ.stats has been extended by generalised binomial number calculator.
We have added he library .quantQ.meb. The library implements the block bootstrap using the Maximum Entropy as proposed in Bergamelli, Novotny and Urga, 2015 here. The method is intended to be used to create a bootstrapped samples for non-stationary time series, where the temporal component is preserved by the blocks with the overall time series being replicated by using the Maximum Entropy bootstrap. For completeness, we provide an old implementation by Vinod and Lopez for reference.
In v2.0 854 unit tests were added. Every change below fixes a defect found by tests/ (854 tests). Run q tests/runAll.q to confirm.
| Module | Fix |
|---|---|
complex |
Defines .quantQ.complex.pi, which the quantum gates use (.quantQ.pi is kept). |
covarianceShocks |
covChange keys use `eigenvalues (the backtick was missing). The in-sample PCA vectors are now the eigenvectors of the in-sample covariance; previously pca was applied to the covariance matrix as if it were data. The debug print ![0N;iP] in covTabChange is removed. |
hopf |
getHopfieldNet2S uses state1, not the undefined state. getGroundState passes minE into its inner lambda, uses .quantQ.hopf.getMinEnergyHopfield instead of .quantQ.ephys..., starts from random states, and stops after 10000 tries. |
knn |
errorLocal uses weights, not weight. |
mcts |
evaluateMCTS no longer reads a global bucket. It accepts the tree (evaluated for player 1) or the MCTS bucket (the player to move comes from movesState). |
meb |
blockShuffle uses data, not xT. |
nn_deep |
predictNNDeep initialises nodesT1. |
ols |
olsTab uses the fitted nObservations, not count[y]. byR2 computes the overall R² from the input table. |
svm |
oneStep uses bucket[data], not a global data`. |
tda |
getAllLoops and getAllPureLoops pass bucket[arrayEdges]into the nested lambda; they used to rely on a globalarrayEdges. bornAndDeathLoopsuses its parametertE, not the global tabEdges`. |
math |
erlangCDF uses its scale parameter (K was undefined) and returns its value (the : was missing). |
ts |
estimate calls .quantQ.ts.innovations (the leading dot was missing). New residualsAR, which HannanRissanen needs. confInterval uses y/p, not the undefined d. |
stats |
.quant.stats.runs is now .quantQ.stats.runs, with the old name kept as an alias. |
The VARX section redefined zt, Z, Y and covarianceResidual with different arities, which broke
the VAR functions defined above it. The VARX versions are renamed ztX, ZXlag and
covarianceResidualX; the VARX Y duplicate was buggy and is dropped in favour of the VAR one.
varXest moves into .quantQ.ts, keeping .quantQ.varXest as an alias, and now computes
Y Z' (Z Z')^-1 (the brackets were wrong). estimateX passes its locals into its lambdas.
estimateNX forecasts the exogenous series with estimate1 and recurses; previously it returned a
lambda without calling it. One open question: estimateX still uses x[;0] for the contemporaneous
exogenous term. We left that as it was.
| Module | Fix |
|---|---|
quat |
mult: the Hamilton product is written out with every term in brackets. |
ols |
rSquaredAdj, AICC and fit (adjusted R², AICC) used n-1-p, which q reads as n-(1-p). They now use n-(p+1). |
| Module | Fix |
|---|---|
ada |
adaPredictionStats: false positives and false negatives were swapped. |
svm |
evalStats: falseDiscoveryRate is now FP/(FP+TP) and falseOmissionRate is FN/(FN+TN). |
hmm |
viterbi backtracks through stored back-pointers. Previously it took the argmax of delta at each step. |
meb |
BSorig/BS place the sorted draws by rank (asc[xTS]@iasc iasc xT). Block indices are now s..s+block-1; they used to run one past the end and produce nulls. |
math |
gammaApprox gets its 1/x factor. New .quantQ.math.gamma (Lanczos), used by gammaPDF and gammaCDF. genLaguerrePol has the correct recurrence and is now iterative rather than exponentially recursive. gammaIncompleteLowerApprox uses the convergent power series, and gammaIncompleteUpperApprox = Γ − lower; the Laguerre series did not converge for z>1/2. The Chebyshev polynomials return their value for n>1. getChebyshevSecondRoots uses k=1..n. normalCDF integrates the correct density with the midpoint rule, vectorised. tetrachoricExpansionBivar sums k=1..n with He_(k-1). |
ols |
RMSE is sqrt avg e*e. |
pois |
The L2 penalty is added to the minimised objective. intensity is exp(θ'x), so yVarPRED is the mode of Poisson(λ) and the log-likelihood is Σ y log λ − λ. |
quantum |
U1 = diag(1, e^{iλ}). U2 includes the 1/√2 factor. Rz uses theta. |
stats |
pValueTwoSided uses abs x. The t-tests use sdev. Wilcoxon ranks start at 1. pHolm uses α/(m+1−k) and is step-down. New pairStats enumerates each pair once (repeated observations were double-counted); it is used by Kendall, Somers and Kruskal. |
stats (bioInf) |
NeedlemanWunsch starts the traceback at (Nseq2;Nseq1), so sequences of different lengths work. LevenshteinDistance returns [Nseq2;Nseq1], which also fixes empty sequences. |
ta |
msd is mdev; the extra sqrt was wrong. This also fixes the Bollinger bands. |
infth |
proteinGetSubstring and proteinInnerProduct use N instead of a hard-coded 3. |
ts |
simMA is correct for any q. forecastAR multiplies phi1 by the latest value. forecastMA[data;period;q] now matches how forecast calls it: it gives h-step forecasts from the innovations estimates, and the old one-step predictor is kept as forecastMAOneStep. vec is raze flip a. |
upd |
-3 sublist instead of -3#, which wrapped around when fewer than 3 ticks were cached. |
mat |
det of a 1x1 matrix returns a number. |
hopf |
Hebbian descent builds W = target ⊗ input, so that W mmu input gives the target. The old orientation could not learn the mapping. |
quantQ is written for kdb+. The library and its tests also run on
PeachQ (tested with 0.89, built from source at commit 0e20de1)
and on m:
| tests | passed | skipped | |
|---|---|---|---|
| PeachQ 0.89 | 854 | 853 | 1 |
| m | 854 | 854 | 0 |
Each change below keeps the result on kdb+ the same. It replaces a construct that PeachQ either does not implement or evaluates differently with one that every implementation agrees on. Nothing here has been run on kdb+ itself since the changes.
| Module | Was | Now | Why |
|---|---|---|---|
io |
dpftsAppend written in k (k) line) |
the same function in q | PeachQ has no k interpreter, so the line stopped the whole library from loading |
io |
dpftsAppend amends each column file, sorts the partition on disk and sets p# on disk |
reads the partition (if any), applies o, sorts, sets p# in memory, then writes it with set |
on-disk amend of attributes (@[path;col;p#]) is 'nyiin PeachQ, as isupsertto a splayed path;.Q.enxsis missing, so the ``sym `` domain goes through .Q.en |
io |
saveSplayedTab / appendSplayedTab sort and amend the table on disk, then upsert |
sort and apply p# in memory, then a single set |
as above |
io |
path built as ` sv (dir;`;t;`) (gives dir//t/) |
` sv dir,t,` |
PeachQ caches mapped tables by path text, so writing through dir//t/ left a stale mapping for dir/t/ and the next read was 'corrupt |
stats |
expma as (first v)(1-l)\v*l |
{[l;r;x] (r*1-l)+x*l}[l]\[first v;v] |
the numeric-left-operand scan form is a 'type in PeachQ |
stats |
pValue* look up the normal table with binr |
.quantQ.stats.normIndex, a count of the quantiles below x |
PeachQ's binr returns count-1 instead of count past the last element |
stats |
last row of normTable was (0.5;0) |
(0.5;0f) |
keeps the columns uniform floats |
stats |
getHistogram uses bins binr data |
the same count | the same binr edge |
ols |
signLevels uses binr |
the same count | a |t| beyond 3.091 got *** instead of **** |
trees |
classify uses binr |
the same count | the same binr edge |
trees |
update rule:rule, ... |
update rule:cnt#enlist rule, ... |
PeachQ does not broadcast a function atom into a column |
trees |
parents found with x?-1_'x |
matched item by item with ~ |
PeachQ's ? on a general list of lists searches element-wise |
so |
raze[a;b] |
a,b |
raze is unary in PeachQ (in kdb+ it is ,/, so it also takes a seed) |
simul |
{x mmu x} and (a)mmu b on vectors in choleskyChB |
sum x*x, sum a*b |
PeachQ's mmu of two empty vectors is a 'length instead of 0f |
tda |
l where not l in m when l may be empty |
guarded by count l |
in PeachQ () in list is the atom 0b |
infth |
proteinInnerProduct through a keyed uj on string keys |
the dot product over the shared keys of the two dictionaries | PeachQ's keyed uj does not merge string keys |
mat |
inverseIteration tests a singular matrix for nulls in inv |
inv is trapped and a failure is treated as all nulls |
PeachQ signals 'domain where kdb+ returns nulls |
.qt.skip[name;why]records a check that is not run; the summary reports the number skipped.test_quantQ_io.qchecks the parted attribute only when the q implementation keeps attributes on disk. It probes for this by writing`p#1 1 2to a file and reading it back. PeachQ maps columns without theiru/g/pattribute by design, so on PeachQ the check is skipped.- The summary table is printed row by row instead of with
show. PeachQ'sshowcollapses long tables to a one-line summary, and kdb+'s console truncates them at its\csize.
These look like PeachQ gaps rather than intentional differences, and may be worth reporting upstream:
binrpast the last element returnscount-1; kdb+ returnscount.- Mapped splayed tables are cached by path text:
`:d//t/and`:d/t/are different cache keys. - Find (
?) on a general list whose items are lists searches element-wise instead of item-wise. - A keyed
ujon char-vector keys concatenates instead of merging. razetakes only one argument.- A function atom does not broadcast in an
updatephrase. () in listreturns the atom0b.mmuof two empty vectors signals'length.invof a singular matrix signals'domain.x b\ywith a numericbis a'type..Q.enxsis not defined.@[path;col;attr]on a splayed table is'nyi, and so isupsertto a splayed path.
Running the full suite takes about 7 minutes of wall-clock time on PeachQ, most of it system time.