import pickle
from collections import OrderedDict
import numpy as np
import pandas as pd
import os
import subprocess
import math
import copy
import pickle
import h5py
import glob

from matlas.genome_data import *
from matlas.pwms import shorten_tfname, get_motifDB_id_maps
from matlas.matches import fig2vdom, vdom_pssm
from basepair.modisco.results import ModiscoResult
from vdom.helpers import (h1, p, li, img, div, b, br, ul, a,
                          details, summary,
                          table, thead, th, tr, tbody, td, ol)
from IPython.display import display


project_root = "/mnt/lab_data/kundaje/msharmin/mouse_hem/with_tfd"
oak_root = "/oak/stanford/groups/akundaje/msharmin/mouse_hem/from_labcluster/with_tfd"
srv_root = "/srv/scratch/msharmin/mouse_hem/with_tfd"
data_name = "full_mouse50"
modisco_root = "{0}/{1}/Naive_modisco2019_msharmin".format(oak_root, data_name)
modisco_root = "{0}/{1}/Naive_modisco2019".format(srv_root, data_name)

homer_root = "{0}/{1}/Naive_scans".format(srv_root, data_name)
model_root = "{0}/{1}/fineFactorized".format(srv_root, data_name)
basset_root = "{0}/{1}/Naive_basset_motifs".format(srv_root, data_name)
reportfile= "/mnt/lab_data/kundaje/msharmin/mouse_hem/with_tfd/full_mouse50/filtering samples_MS2.xlsx"
sheetname = "filter23"

load data from labcluster

Using TensorFlow backend.
2019-10-04 15:17:40,593 [WARNING] git-lfs not installed
TF-MoDISco is using the TensorFlow backend.

from matlas.matches import DenovoModisco
task_idx = 273
modisco_dir = "{0}/task_{1}-naivegw".format(modisco_root, task_idx)
ob = DenovoModisco(modisco_dir)

task_idx = 273
modisco_dir = "{0}/task_{1}-naivegw".format(modisco_root, task_idx)
summit_file = "{0}/{1}/fineFactorized/task_{2}-naivegw/predictions/task_{2}-{3}Summit.calibrated.{1}.tab.gz".format(project_root, data_name, task_idx, "Naive")
perf_file = "{0}/task_{1}-naivegw/NaiveauPRC.txt".format(model_root, task_idx)
deeplift_hdf = "{0}/{1}/Naive_deeplift2019/task_{2}-naivegw/summit.h5".format(srv_root, data_name, task_idx)
ob = DenovoModisco(modisco_dir)
pattern_name = "metacluster_1/pattern_1"
query = ob.load_chomped_pattern(pattern_name, plot=True)

ob.initialize_with_importance_scores(summit_file, perf_file, deeplift_hdf, query.keys()) #loads all the important scores
deeplift_data = ob.deeplift_data

from matlas.utils import get_calibrated_peaks

calibrated_data = get_calibrated_peaks(summit_file, perf_file)
selected_summits = calibrated_data['selected_summits']
indices = calibrated_data['indices']

from basepair.plot.profiles import extract_signal
pattern_name = 'metacluster_1/pattern_1'
one_hot = ob.seqs_per_pattern[pattern_name]
scores = ob.contrib_per_pattern[pattern_name]
seqlets_ = ob.seqlets_per_pattern[pattern_name]
shuffled_onehot = extract_signal(ob.deeplift_data['shuffled_onehot'][indices], seqlets_)
shuffled_scores = extract_signal(ob.deeplift_data['shuffled_scores'][indices], seqlets_)

one_hot.shape, scores.shape, shuffled_onehot.shape, shuffled_scores.shape

((6372, 70, 4), (6372, 70, 4), (6372, 70, 4), (6372, 70, 4))

from matlas.matches import get_null_sequences
seq_null_onehot, seq_null_scores = get_null_sequences(one_hot, scores,
                                                shuffle_seq=True, shuffle_weight=False
                                                     )

weight_null_onehot, weight_null_scores = get_null_sequences(one_hot, scores,
                                                shuffle_seq=False, shuffle_weight=True
                                                     )

weightedseq_null_onehot, weightedseq_null_scores = get_null_sequences(one_hot, scores,
                                                shuffle_seq=True, shuffle_weight=True
                                                     )

done multiprocessing
(6372, 70, 4)
(6372, 70, 4)
done multiprocessing
(6372, 70, 4)
(6372, 70, 4)
done multiprocessing
(6372, 70, 4)
(6372, 70, 4)

from matlas.matches import collect_scoring_measures
seqlet_scores = ob.contrib_per_pattern[pattern_name]
seqlet_onehot = ob.seqs_per_pattern[pattern_name]
method_to_seqlet_scores = collect_scoring_measures(query, seqlet_scores, seqlet_onehot)
query.keys(), np.sort(np.array(list(method_to_seqlet_scores.keys())))

(dict_keys(['ppm', 'pwm', 'log10pwm', 'pssm', 'cwm', 'hyp_cwm', 'consensus']),
 array(['cwm_convolution', 'cwm_jaccard', 'cwm_masked_convolution',
        'cwm_scan', 'hyp_cwm_convolution', 'hyp_cwm_jaccard',
        'hyp_cwm_masked_convolution', 'hyp_cwm_scan',
        'log10pwm_convolution', 'log10pwm_jaccard',
        'log10pwm_masked_convolution', 'log10pwm_scan', 'ppm_convolution',
        'ppm_jaccard', 'ppm_masked_convolution', 'ppm_scan',
        'pssm_convolution', 'pssm_jaccard', 'pssm_masked_convolution',
        'pssm_scan', 'pwm_convolution', 'pwm_jaccard',
        'pwm_masked_convolution', 'pwm_scan', 'sum_score'], dtype='<U27'))

method_to_shuffled_scores = collect_scoring_measures(query, shuffled_scores, shuffled_onehot)
method_to_seq_null_scores = collect_scoring_measures(query, seq_null_scores, seq_null_onehot)
method_to_weight_null_scores = collect_scoring_measures(query, weight_null_scores, weight_null_onehot)
method_to_weightedseq_null_scores = collect_scoring_measures(query, weightedseq_null_scores, weightedseq_null_onehot)

from matlas.matches import get_any_high_scoring_instances
per_base_imp=0.0625

keys_for_scoring = ['sum_score'] 
keys_for_scoring += ["{}_scan".format(key) for key in query.keys() if key!= 'consensus']
keys_for_scoring += ["{}_jaccard".format(key) for key in query.keys() if key!= 'consensus']
keys_for_scoring += ["{}_convolution".format(key) for key in query.keys() if key!= 'consensus']
keys_for_scoring += ["{}_masked_convolution".format(key) for key in query.keys() if key!= 'consensus']
        
seqlet_hits = get_any_high_scoring_instances(method_to_seqlet_scores,
                                                min_tot_imp=per_base_imp*len(query['ppm']),
                                                keys=keys_for_scoring)

shuffled_seqlet_hits = get_any_high_scoring_instances(method_to_shuffled_scores,
                                                min_tot_imp=per_base_imp*len(query['ppm']),
                                                keys=keys_for_scoring)
seq_null_seqlet_hits = get_any_high_scoring_instances(method_to_seq_null_scores,
                                                min_tot_imp=per_base_imp*len(query['ppm']),
                                                keys=keys_for_scoring)
weight_null_seqlet_hits = get_any_high_scoring_instances(method_to_weight_null_scores,
                                                min_tot_imp=per_base_imp*len(query['ppm']),
                                                keys=keys_for_scoring)
weightedseq_null_seqlet_hits = get_any_high_scoring_instances(method_to_weightedseq_null_scores,
                                                min_tot_imp=per_base_imp*len(query['ppm']),
                                                keys=keys_for_scoring)

seqlet_hits['marker'] = 'foreground'
shuffled_seqlet_hits['marker'] = 'suffled'
seq_null_seqlet_hits['marker'] = 'seq_null'
weight_null_seqlet_hits['marker'] = 'weight_null'
weightedseq_null_seqlet_hits['marker'] = 'weightedseq'
test_hits = pd.concat([seqlet_hits,
                       shuffled_seqlet_hits,
                       seq_null_seqlet_hits,
                       weight_null_seqlet_hits,
                       weightedseq_null_seqlet_hits
                      ])

from sklearn.preprocessing import StandardScaler
from sklearn.decomposition import PCA

def transform_data(_hits, scaler=None, pca=None):
    if scaler is None:
        # should be used only during training
        scaler = StandardScaler()
        scaler.fit(_hits)
        
    # Apply transform to both the training set and testing set
    _hits = scaler.transform(_hits)

    if pca is None:
        # Make an instance of the Model
        pca = PCA(.98)
        #fitting PCA on the training set only.
        pca.fit(_hits)
        
    #Apply the mapping (transform) to both the training set and the test set.
    _hits = pca.transform(_hits)
    
    return scaler, pca, _hits

scaler, pca, train_hits = transform_data(seqlet_hits[keys_for_scoring])
pca.explained_variance_ratio_

array([0.69987347, 0.09950445, 0.08237547, 0.04125603, 0.02750585,
       0.01404074, 0.01112795, 0.00870734])

#read the real truth
def load_true_positives(tp_file):
    coordinates = []
    with open(tp_file, "r") as fp:
        for line in fp:
            line = line.strip().split(",")
            seqno = line[0]
            pos = int(line[1])
            if "-" in seqno:
                seqno = seqno.split("-")
                for i in range(int(seqno[0]), int(seqno[1])+1):
                    coordinates.append((i, pos))
            else:
                coordinates.append((int(seqno), pos))
    return coordinates

def get_tp_indices(seqlet_hits, verbose=True):
    keep = []
    for cord in coordinates:
        seqno, pos = cord
        df = seqlet_hits[(seqlet_hits['seqno']==seqno) & (seqlet_hits['start_idx']==pos)]
        if df.shape[0]>0:
            keep.append(df.index[0])
        else:
            if verbose: print(cord)

    return keep

tp_file = "{}/web_mouse_heme_data/modisco_tracks/binary_model/task_{}-naivegw/mm11_tp_spectral.txt".format(project_root, task_idx)
coordinates = load_true_positives(tp_file)
true_indices = get_tp_indices(seqlet_hits, False)

import matplotlib.pyplot as plt
def plot_pca(df, true_ids=None):
    print(df.shape)
    fig = plt.figure(figsize = (8,8))
    ax = fig.add_subplot(1,1,1) 
    ax.set_xlabel('PC1', fontsize = 15)
    ax.set_ylabel('PC2', fontsize = 15)
    ax.set_title('2 component PCA', fontsize = 20)
    if true_ids is not None:
        true_df = df.loc[np.array(true_ids),:]
        df = df.loc[np.array(list(set(list(df.index)).difference(set(true_ids)))),:]
        ax.scatter(true_df['PC1'], true_df['PC2'], s = 1, c='r', marker='+')
    ax.scatter(df['PC1'], df['PC2'], s = 1, c='b')
    #ax.axvline(9)
    #ax.axhline(-1)
    ax.grid()
    return None
pc_df = pd.DataFrame(data = train_hits, columns=["PC{}".format(i+1) for i in range(train_hits.shape[1])])
plot_pca(pc_df, true_indices)

(114461, 8)

len(true_indices)

7312

from matlas.matches import view_test_case
from modisco.visualization import viz_sequence
#from matlas.matches import view_test_cases

def view_test_cases(scores, one_hot, df, pwm, start=400, end=600, examples_to_view=None):
    
    seqnos = df.seqno.values
    positions = df.start_idx.values
    if examples_to_view is not None:
        seqnos = seqnos[examples_to_view]
        positions = positions[examples_to_view]
    
    for seqno, pos in zip(seqnos, positions):
        view_test_case(scores, one_hot, df, pwm, seqno, start=start, end=end, itemno=pos)
        
    return None
tmp_df = seqlet_hits.loc[np.sort((np.array(true_indices))),:]
# view_test_cases(seqlet_scores, 
#                seqlet_onehot, 
#                tmp_df, 
#                query['pwm'], 
#                start=0, end=70, 
#                examples_to_view=tmp_df.start_idx.values!=37)

# view_test_cases(seqlet_scores, 
#                seqlet_onehot, 
#                tmp_df, 
#                query['pwm'], 
#                start=0, end=70, 
#                examples_to_view=tmp_df.seqno.values<=1000 
#                )

view_test_cases(seqlet_scores, 
               seqlet_onehot, 
               tmp_df, 
               query['pwm'], 
               start=0, end=70, 
               examples_to_view=np.logical_and(tmp_df.seqno.values>1000, tmp_df.seqno.values<=2000) 
               )

21927 ['log10pwm_jaccard: 0.062', 'ppm_masked_convolution: 0.911', 'log10pwm_scan: 9.105', 'pwm_convolution: 4.509', 'pssm_jaccard: 0.544', 'ppm_convolution: 2.284', 'log10pwm_convolution: 3.125', 'hyp_cwm_scan: 1.754', 'hyp_cwm_masked_convolution: 0.944', 'sum_score: 2.603', 'pssm_convolution: 3.707', 'cwm_jaccard: 0.602', 'ppm_scan: 7.747', 'hyp_cwm_jaccard: 0.212', 'log10pwm_masked_convolution: 0.871', 'cwm_convolution: 0.894', 'cwm_scan: 2.466', 'pwm_jaccard: 0.062', 'hyp_cwm_convolution: 0.604', 'pwm_scan: 13.136', 'cwm_masked_convolution: 0.955', 'pssm_masked_convolution: 0.93', 'pssm_scan: 10.778', 'ppm_jaccard: 0.458', 'pwm_masked_convolution: 0.871'] coordinates: (1001, 37)
37 37 48

21957 ['log10pwm_jaccard: 0.063', 'ppm_masked_convolution: 0.901', 'log10pwm_scan: 8.072', 'pwm_convolution: 5.005', 'pssm_jaccard: 0.497', 'ppm_convolution: 2.638', 'log10pwm_convolution: 3.469', 'hyp_cwm_scan: 1.757', 'hyp_cwm_masked_convolution: 0.97', 'sum_score: 3.158', 'pssm_convolution: 4.332', 'cwm_jaccard: 0.594', 'ppm_scan: 7.315', 'hyp_cwm_jaccard: 0.215', 'log10pwm_masked_convolution: 0.829', 'cwm_convolution: 1.067', 'cwm_scan: 2.397', 'pwm_jaccard: 0.063', 'hyp_cwm_convolution: 0.748', 'pwm_scan: 11.646', 'cwm_masked_convolution: 0.95', 'pssm_masked_convolution: 0.907', 'pssm_scan: 10.476', 'ppm_jaccard: 0.41', 'pwm_masked_convolution: 0.829'] coordinates: (1002, 37)
37 37 48

21963 ['log10pwm_jaccard: 0.064', 'ppm_masked_convolution: 0.971', 'log10pwm_scan: 9.012', 'pwm_convolution: 4.129', 'pssm_jaccard: 0.565', 'ppm_convolution: 2.184', 'log10pwm_convolution: 2.862', 'hyp_cwm_scan: 1.895', 'hyp_cwm_masked_convolution: 0.97', 'sum_score: 2.724', 'pssm_convolution: 3.416', 'cwm_jaccard: 0.669', 'ppm_scan: 7.517', 'hyp_cwm_jaccard: 0.243', 'log10pwm_masked_convolution: 0.927', 'cwm_convolution: 0.835', 'cwm_scan: 2.545', 'pwm_jaccard: 0.064', 'hyp_cwm_convolution: 0.59', 'pwm_scan: 13.001', 'cwm_masked_convolution: 0.958', 'pssm_masked_convolution: 0.94', 'pssm_scan: 10.566', 'ppm_jaccard: 0.517', 'pwm_masked_convolution: 0.927'] coordinates: (1003, 0)
0 0 11

21978 ['log10pwm_jaccard: 0.076', 'ppm_masked_convolution: 0.872', 'log10pwm_scan: 9.95', 'pwm_convolution: 5.316', 'pssm_jaccard: 0.506', 'ppm_convolution: 2.659', 'log10pwm_convolution: 3.685', 'hyp_cwm_scan: 1.751', 'hyp_cwm_masked_convolution: 0.932', 'sum_score: 3.029', 'pssm_convolution: 4.193', 'cwm_jaccard: 0.579', 'ppm_scan: 7.947', 'hyp_cwm_jaccard: 0.214', 'log10pwm_masked_convolution: 0.869', 'cwm_convolution: 1.031', 'cwm_scan: 2.522', 'pwm_jaccard: 0.076', 'hyp_cwm_convolution: 0.703', 'pwm_scan: 14.355', 'cwm_masked_convolution: 0.911', 'pssm_masked_convolution: 0.867', 'pssm_scan: 11.044', 'ppm_jaccard: 0.446', 'pwm_masked_convolution: 0.869'] coordinates: (1003, 37)
37 37 48

21996 ['log10pwm_jaccard: 0.064', 'ppm_masked_convolution: 0.893', 'log10pwm_scan: 9.621', 'pwm_convolution: 5.671', 'pssm_jaccard: 0.528', 'ppm_convolution: 2.979', 'log10pwm_convolution: 3.931', 'hyp_cwm_scan: 1.861', 'hyp_cwm_masked_convolution: 0.953', 'sum_score: 3.519', 'pssm_convolution: 4.92', 'cwm_jaccard: 0.621', 'ppm_scan: 7.843', 'hyp_cwm_jaccard: 0.236', 'log10pwm_masked_convolution: 0.838', 'cwm_convolution: 1.194', 'cwm_scan: 2.523', 'pwm_jaccard: 0.064', 'hyp_cwm_convolution: 0.824', 'pwm_scan: 13.88', 'cwm_masked_convolution: 0.955', 'pssm_masked_convolution: 0.931', 'pssm_scan: 10.776', 'ppm_jaccard: 0.446', 'pwm_masked_convolution: 0.838'] coordinates: (1004, 37)
37 37 48

22020 ['log10pwm_jaccard: 0.083', 'ppm_masked_convolution: 0.863', 'log10pwm_scan: 10.038', 'pwm_convolution: 5.607', 'pssm_jaccard: 0.557', 'ppm_convolution: 2.698', 'log10pwm_convolution: 3.887', 'hyp_cwm_scan: 1.685', 'hyp_cwm_masked_convolution: 0.938', 'sum_score: 2.85', 'pssm_convolution: 4.517', 'cwm_jaccard: 0.641', 'ppm_scan: 8.207', 'hyp_cwm_jaccard: 0.237', 'log10pwm_masked_convolution: 0.845', 'cwm_convolution: 1.089', 'cwm_scan: 2.577', 'pwm_jaccard: 0.083', 'hyp_cwm_convolution: 0.746', 'pwm_scan: 14.482', 'cwm_masked_convolution: 0.952', 'pssm_masked_convolution: 0.933', 'pssm_scan: 11.011', 'ppm_jaccard: 0.434', 'pwm_masked_convolution: 0.845'] coordinates: (1005, 37)
37 37 48

22028 ['log10pwm_jaccard: 0.071', 'ppm_masked_convolution: 0.874', 'log10pwm_scan: 7.854', 'pwm_convolution: 1.755', 'pssm_jaccard: 0.572', 'ppm_convolution: 0.819', 'log10pwm_convolution: 1.216', 'hyp_cwm_scan: 1.447', 'hyp_cwm_masked_convolution: 0.947', 'sum_score: 0.832', 'pssm_convolution: 1.416', 'cwm_jaccard: 0.571', 'ppm_scan: 7.34', 'hyp_cwm_jaccard: 0.214', 'log10pwm_masked_convolution: 0.898', 'cwm_convolution: 0.329', 'cwm_scan: 2.354', 'pwm_jaccard: 0.071', 'hyp_cwm_convolution: 0.229', 'pwm_scan: 11.331', 'cwm_masked_convolution: 0.921', 'pssm_masked_convolution: 0.925', 'pssm_scan: 10.578', 'ppm_jaccard: 0.408', 'pwm_masked_convolution: 0.898'] coordinates: (1005, 54)
54 54 65

22040 ['log10pwm_jaccard: 0.057', 'ppm_masked_convolution: 0.922', 'log10pwm_scan: 8.072', 'pwm_convolution: 5.44', 'pssm_jaccard: 0.547', 'ppm_convolution: 3.067', 'log10pwm_convolution: 3.771', 'hyp_cwm_scan: 1.757', 'hyp_cwm_masked_convolution: 0.945', 'sum_score: 3.926', 'pssm_convolution: 4.982', 'cwm_jaccard: 0.583', 'ppm_scan: 7.315', 'hyp_cwm_jaccard: 0.22', 'log10pwm_masked_convolution: 0.792', 'cwm_convolution: 1.182', 'cwm_scan: 2.397', 'pwm_jaccard: 0.057', 'hyp_cwm_convolution: 0.828', 'pwm_scan: 11.646', 'cwm_masked_convolution: 0.926', 'pssm_masked_convolution: 0.918', 'pssm_scan: 10.476', 'ppm_jaccard: 0.43', 'pwm_masked_convolution: 0.792'] coordinates: (1006, 37)
37 37 48

22077 ['log10pwm_jaccard: 0.076', 'ppm_masked_convolution: 0.937', 'log10pwm_scan: 8.489', 'pwm_convolution: 5.593', 'pssm_jaccard: 0.592', 'ppm_convolution: 2.79', 'log10pwm_convolution: 3.877', 'hyp_cwm_scan: 1.582', 'hyp_cwm_masked_convolution: 0.975', 'sum_score: 3.097', 'pssm_convolution: 4.549', 'cwm_jaccard: 0.664', 'ppm_scan: 7.678', 'hyp_cwm_jaccard: 0.218', 'log10pwm_masked_convolution: 0.87', 'cwm_convolution: 1.088', 'cwm_scan: 2.451', 'pwm_jaccard: 0.076', 'hyp_cwm_convolution: 0.749', 'pwm_scan: 12.248', 'cwm_masked_convolution: 0.978', 'pssm_masked_convolution: 0.96', 'pssm_scan: 10.71', 'ppm_jaccard: 0.434', 'pwm_masked_convolution: 0.87'] coordinates: (1007, 37)
37 37 48

22091 ['log10pwm_jaccard: 0.07', 'ppm_masked_convolution: 0.899', 'log10pwm_scan: 9.614', 'pwm_convolution: 3.463', 'pssm_jaccard: 0.611', 'ppm_convolution: 1.777', 'log10pwm_convolution: 2.4', 'hyp_cwm_scan: 1.872', 'hyp_cwm_masked_convolution: 0.925', 'sum_score: 1.952', 'pssm_convolution: 3.046', 'cwm_jaccard: 0.694', 'ppm_scan: 7.914', 'hyp_cwm_jaccard: 0.222', 'log10pwm_masked_convolution: 0.867', 'cwm_convolution: 0.717', 'cwm_scan: 2.576', 'pwm_jaccard: 0.07', 'hyp_cwm_convolution: 0.476', 'pwm_scan: 13.869', 'cwm_masked_convolution: 0.967', 'pssm_masked_convolution: 0.973', 'pssm_scan: 10.981', 'ppm_jaccard: 0.442', 'pwm_masked_convolution: 0.867'] coordinates: (1008, 37)
37 37 48

# view_test_cases(seqlet_scores, 
#                seqlet_onehot, 
#                tmp_df, 
#                query['pwm'], 
#                start=0, end=70, 
#                examples_to_view=np.logical_and(tmp_df.seqno.values>2000, tmp_df.seqno.values<=3000) 
#                )

# view_test_cases(seqlet_scores, 
#                seqlet_onehot, 
#                tmp_df, 
#                query['pwm'], 
#                start=0, end=70, 
#                examples_to_view=np.logical_and(tmp_df.seqno.values>3000, tmp_df.seqno.values<=4000) 
#                )

# view_test_cases(seqlet_scores, 
#                seqlet_onehot, 
#                tmp_df, 
#                query['pwm'], 
#                start=0, end=70, 
#                examples_to_view=np.logical_and(tmp_df.seqno.values>4000, tmp_df.seqno.values<=5000) 
#                )

# view_test_cases(seqlet_scores, 
#                seqlet_onehot, 
#                tmp_df, 
#                query['pwm'], 
#                start=0, end=70, 
#                examples_to_view=np.logical_and(tmp_df.seqno.values>5000, tmp_df.seqno.values<=6000) 
#                )

# view_test_cases(seqlet_scores, 
#                seqlet_onehot, 
#                tmp_df, 
#                query['pwm'], 
#                start=0, end=70, 
#                examples_to_view=tmp_df.seq.values>6000 
#                )

from sklearn.mixture import GaussianMixture
#import sklearn.mixture.GaussianMixture
gmm = GaussianMixture(n_components=2).fit(pc_df[['PC1', 'PC2']])
labels = gmm.predict(pc_df[['PC1', 'PC2']])
plt.scatter(pc_df['PC1'], pc_df['PC2'], c=labels, s=1, cmap='viridis');

probs = gmm.predict_proba(pc_df[['PC1', 'PC2']])
plt.scatter(pc_df['PC1'], pc_df['PC2'], c=probs[:,1], s=1, cmap='seismic');

_, _, test_hits = transform_data(shuffled_seqlet_hits[keys_for_scoring], scaler, pca)
shuffled_pc_df = pd.DataFrame(data = test_hits, columns=["PC{}".format(i+1) for i in range(test_hits.shape[1])])
#plot_pca(shuffled_pc_df, true_ids=None)

probs = gmm.predict_proba(shuffled_pc_df[['PC1', 'PC2']])
plt.scatter(shuffled_pc_df['PC1'], shuffled_pc_df['PC2'], c=probs[:,1], s=1, cmap='seismic');

_, _, test_hits = transform_data(seq_null_seqlet_hits[keys_for_scoring], scaler, pca)
seq_null_pc_df = pd.DataFrame(data = test_hits, columns=["PC{}".format(i+1) for i in range(test_hits.shape[1])])
#plot_pca(shuffled_pc_df, true_ids=None)

probs = gmm.predict_proba(seq_null_pc_df[['PC1', 'PC2']])
plt.scatter(seq_null_pc_df['PC1'], seq_null_pc_df['PC2'], c=probs[:,1], s=1, cmap='seismic');

_, _, test_hits = transform_data(weight_null_seqlet_hits[keys_for_scoring], scaler, pca)
weight_null_pc_df = pd.DataFrame(data = test_hits, columns=["PC{}".format(i+1) for i in range(test_hits.shape[1])])
#plot_pca(weight_null_pc_df, true_ids=None)

probs = gmm.predict_proba(weight_null_pc_df[['PC1', 'PC2']])
plt.scatter(weight_null_pc_df['PC1'], weight_null_pc_df['PC2'], c=probs[:,1], s=1, cmap='seismic');

_, _, test_hits = transform_data(weightedseq_null_seqlet_hits[keys_for_scoring], scaler, pca)
weightedseq_null_pc_df = pd.DataFrame(data = test_hits, columns=["PC{}".format(i+1) for i in range(test_hits.shape[1])])
#plot_pca(weightedseq_null_pc_df, true_ids=None)

probs = gmm.predict_proba(weightedseq_null_pc_df[['PC1', 'PC2']])
plt.scatter(weightedseq_null_pc_df['PC1'], weightedseq_null_pc_df['PC2'], c=probs[:,1], s=1, cmap='seismic');

pca_seqlet_hits = pc_df[['PC1', 'PC2', 'PC3']]
pca_shuffled_seqlet_hits = shuffled_pc_df[['PC1', 'PC2', 'PC3']]
pca_seq_null_seqlet_hits = seq_null_pc_df[['PC1', 'PC2', 'PC3']]
pca_weight_null_seqlet_hits = weight_null_pc_df[['PC1', 'PC2', 'PC3']]
pca_weightedseq_null_seqlet_hits = weightedseq_null_pc_df[['PC1', 'PC2', 'PC3']]
pca_seqlet_hits['marker'] = 'foreground'
pca_shuffled_seqlet_hits['marker'] = 'suffled'
pca_seq_null_seqlet_hits['marker'] = 'seq_null'
pca_weight_null_seqlet_hits['marker'] = 'weight_null'
pca_weightedseq_null_seqlet_hits['marker'] = 'weightedseq'
pca_test_hits = pd.concat([pca_seqlet_hits,
                       pca_shuffled_seqlet_hits,
                       pca_seq_null_seqlet_hits,
                       pca_weight_null_seqlet_hits,
                       pca_weightedseq_null_seqlet_hits
                      ])

# import seaborn as sns
# sns.pairplot(pca_test_hits, 
#              diag_kind="kde", kind='scatter', hue="marker")

/users/msharmin/anaconda2/envs/basepair/lib/python3.6/site-packages/scipy/stats/stats.py:1713: FutureWarning:

Using a non-tuple sequence for multidimensional indexing is deprecated; use `arr[tuple(seq)]` instead of `arr[seq]`. In the future this will be interpreted as an array index, `arr[np.array(seq)]`, which will result either in an error or a different result.

<seaborn.axisgrid.PairGrid at 0x7f0669a8beb8>

# sns.pairplot(pd.concat([pca_seqlet_hits, pca_shuffled_seqlet_hits]), 
#              diag_kind="kde", kind='scatter', hue="marker")

/users/msharmin/anaconda2/envs/basepair/lib/python3.6/site-packages/scipy/stats/stats.py:1713: FutureWarning:

Using a non-tuple sequence for multidimensional indexing is deprecated; use `arr[tuple(seq)]` instead of `arr[seq]`. In the future this will be interpreted as an array index, `arr[np.array(seq)]`, which will result either in an error or a different result.

<seaborn.axisgrid.PairGrid at 0x7f0683430780>

# sns.pairplot(pd.concat([pca_seqlet_hits, pca_seq_null_seqlet_hits]), 
#              diag_kind="kde", kind='scatter', hue="marker")

/users/msharmin/anaconda2/envs/basepair/lib/python3.6/site-packages/scipy/stats/stats.py:1713: FutureWarning:

Using a non-tuple sequence for multidimensional indexing is deprecated; use `arr[tuple(seq)]` instead of `arr[seq]`. In the future this will be interpreted as an array index, `arr[np.array(seq)]`, which will result either in an error or a different result.

<seaborn.axisgrid.PairGrid at 0x7f013adc8278>

# sns.pairplot(pd.concat([pca_seqlet_hits, pca_weight_null_seqlet_hits]), 
#              diag_kind="kde", kind='scatter', hue="marker")

/users/msharmin/anaconda2/envs/basepair/lib/python3.6/site-packages/scipy/stats/stats.py:1713: FutureWarning:

Using a non-tuple sequence for multidimensional indexing is deprecated; use `arr[tuple(seq)]` instead of `arr[seq]`. In the future this will be interpreted as an array index, `arr[np.array(seq)]`, which will result either in an error or a different result.

<seaborn.axisgrid.PairGrid at 0x7f06833e0978>

# sns.pairplot(pd.concat([pca_seqlet_hits, pca_weightedseq_null_seqlet_hits]), 
#              diag_kind="kde", kind='scatter', hue="marker")

/users/msharmin/anaconda2/envs/basepair/lib/python3.6/site-packages/scipy/stats/stats.py:1713: FutureWarning:

Using a non-tuple sequence for multidimensional indexing is deprecated; use `arr[tuple(seq)]` instead of `arr[seq]`. In the future this will be interpreted as an array index, `arr[np.array(seq)]`, which will result either in an error or a different result.

<seaborn.axisgrid.PairGrid at 0x7f0680a80cf8>

from sklearn.cluster import SpectralClustering
from sklearn.svm import LinearSVC, SVC
from sklearn.cluster import AffinityPropagation
def get_spectral_high_scoring_instances(train_df, keys_to_cluster, test_df=None, clustering=None, cno=None):
    train = train_df[keys_to_cluster]
    
    if clustering is None:
        clustering = SpectralClustering(n_clusters=2, assign_labels="discretize", random_state=0).fit(train.values)
        mean0 = np.mean(train_df[keys_to_cluster[0]][clustering.labels_==0])
        mean1 = np.mean(train_df[keys_to_cluster[0]][clustering.labels_==1])
        cno = 1
        if(mean0 > mean1):
            cno = 0
        df = train_df[clustering.labels_==cno]
    else:
        test = test_df[keys_to_cluster]
        y_tr = clustering.labels_
        #clf = LinearSVC(dual=False).fit(train.values, y_tr)
        clf = SVC().fit(train.values, y_tr)
        batch_size = 1000
        batch_count = int(np.ceil(1.0*test_df.shape[0]/batch_size))
        predicted_labels = clf.predict(test.values)
        predicted_labels = np.array(predicted_labels)
        assert len(predicted_labels)==test_df.shape[0], "not all the values have been predicted"
        df = test_df.loc[predicted_labels==cno, :]
        
    #df = df[df['pwm_jaccard']>0]
    
    return df, (clustering, cno)

# import sys
# from matlas.matches import clustering_method_to_functions#, get_spectral_high_scoring_instances
# from random import sample

# max_instances_to_cluster = min(seqlet_hits.shape[0], 20000) #similar size as the gata motif
# pca_seqlet_hits = pc_df[['PC1', 'PC2']]
# train_hits_forcluster = pca_seqlet_hits.loc[sample(list(seqlet_hits.index), max_instances_to_cluster),:]
# #train_hits_forcluster = pc_df[['PC1', 'PC2']]

# clustering_method = 'spectral'
# thismodule = sys.modules[__name__]
# method_to_call = getattr(thismodule, clustering_method_to_functions[clustering_method])

# #use a subset of the hits to build the cluster
# clustered_seqlet_hits, (clustering, cno) = method_to_call(train_hits_forcluster,
#                                                           keys_to_cluster=['PC1', 'PC2']
#                                                          )

# #use the cluster to predict on the full set of seqlets
# clustered_seqlet_hits2, (_, _) = method_to_call(train_hits_forcluster, #train_df
#                                         ['PC1', 'PC2'], #keys_to_cluster
#                                         pca_seqlet_hits, #test_df
#                                         clustering, #clustering
#                                         cno)

# clustered_seqlet_hits.shape, clustered_seqlet_hits2.shape, clustered_seqlet_hits3.shape

((1275, 2), (7307, 4), (605, 4))

# clustered_seqlet_hits3, (_, _) = method_to_call(train_hits_forcluster, #train_df
#                                         ['PC1', 'PC2'], #keys_to_cluster
#                                         pca_shuffled_seqlet_hits, #test_df
#                                         clustering, #clustering
#                                         cno)

# tp_file = "{}/web_mouse_heme_data/modisco_tracks/binary_model/task_{}-naivegw/mm11_tp_random.txt".format(project_root, task_idx)
# write_tp(shuffled_seqlet_hits.loc[clustered_seqlet_hits3.index,:], tp_file)
# coordinates = load_true_positives(tp_file)
# true_indices = get_tp_indices(shuffled_seqlet_hits, verbose=False)
# plot_pca(shuffled_pc_df, true_indices)

(48842, 8)

# clustered_seqlet_hits3, (_, _) = method_to_call(train_hits_forcluster, #train_df
#                                         ['PC1', 'PC2'], #keys_to_cluster
#                                         pca_seq_null_seqlet_hits, #test_df
#                                         clustering, #clustering
#                                         cno)

# tp_file = "{}/web_mouse_heme_data/modisco_tracks/binary_model/task_{}-naivegw/mm11_tp_random.txt".format(project_root, task_idx)
# write_tp(seqlet_hits.loc[clustered_seqlet_hits3.index,:], tp_file)
# coordinates = load_true_positives(tp_file)
# true_indices = get_tp_indices(seq_null_seqlet_hits, verbose=False)
# plot_pca(seq_null_pc_df, true_indices)

(114461, 8)

# clustered_seqlet_hits3, (_, _) = method_to_call(train_hits_forcluster, #train_df
#                                         ['PC1', 'PC2'], #keys_to_cluster
#                                         pca_weight_null_seqlet_hits, #test_df
#                                         clustering, #clustering
#                                         cno)

# tp_file = "{}/web_mouse_heme_data/modisco_tracks/binary_model/task_{}-naivegw/mm11_tp_random.txt".format(project_root, task_idx)
# write_tp(weight_null_seqlet_hits.loc[clustered_seqlet_hits3.index,:], tp_file)
# coordinates = load_true_positives(tp_file)
# true_indices = get_tp_indices(weight_null_seqlet_hits, verbose=False)
# plot_pca(weight_null_pc_df, true_indices)

(124266, 8)

# clustered_seqlet_hits3, (_, _) = method_to_call(train_hits_forcluster, #train_df
#                                         ['PC1', 'PC2'], #keys_to_cluster
#                                         pca_weightedseq_null_seqlet_hits, #test_df
#                                         clustering, #clustering
#                                         cno)

# tp_file = "{}/web_mouse_heme_data/modisco_tracks/binary_model/task_{}-naivegw/mm11_tp_random.txt".format(project_root, task_idx)
# write_tp(weightedseq_null_seqlet_hits.loc[clustered_seqlet_hits3.index,:], tp_file)
# coordinates = load_true_positives(tp_file)
# true_indices = get_tp_indices(weightedseq_null_seqlet_hits, verbose=False)
# plot_pca(weightedseq_null_pc_df, true_indices)

(123596, 8)