annotate cmpb2016/appending.py @ 3:32d2f321b0e9 draft

Deleted selected files
author chmaramis
date Sun, 18 Mar 2018 07:05:15 -0400
parents 8be019b173e6
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
0
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
1 # -*- coding: utf-8 -*-
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
2 """
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
3 Created on Wed Nov 05 14:17:24 2014
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
4
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
5 @author: chmaramis
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
6 """
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
7
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
8 import numpy as np
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
9 from pandas import *
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
10 from numpy import nan as NA
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
11 import sys
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
12 import time
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
13
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
14 def appending(arg):
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
15
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
16 appfr = DataFrame()
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
17 for path in arg:
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
18 frame = DataFrame()
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
19 tp = read_csv(path, iterator=True, chunksize=1000,sep='\t', index_col=0 )
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
20 frame = concat([chunk for chunk in tp])
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
21 appfr = appfr.append(frame)
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
22 appfr = appfr[frame.columns]
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
23 appfr.index = range(1,len(appfr)+1)
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
24 return appfr
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
25
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
26 if __name__ == '__main__':
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
27
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
28 start=time.time()
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
29
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
30 # Parse input arguments
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
31 arg=sys.argv[2:]
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
32 lastEl = sys.argv[1]
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
33
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
34 # Execute basic function
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
35 appfr = appending(arg)
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
36
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
37 # Save output to CSV files
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
38 if not appfr.empty:
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
39 appfr.to_csv(lastEl, sep= '\t')
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
40
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
41 # Print execution time
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
42 stop=time.time()
8be019b173e6 Uploaded included tools
chmaramis
parents:
diff changeset
43 print('Runtime:' + str(stop-start))