-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathconvert_metis.py
52 lines (45 loc) · 1.68 KB
/
convert_metis.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
import argparse
from collections import defaultdict
from tqdm import tqdm
import random
import subprocess
import os
import numpy as np
parser = argparse.ArgumentParser()
parser.add_argument('whole')
parser.add_argument('part')
parser.add_argument('--outdir')
parser.add_argument('--feats')
args = parser.parse_args()
adj_list = defaultdict(set)
n_edges = 0
node2part = {}
part2nodes = defaultdict(list)
assert os.path.exists(args.part)
for node, part in tqdm(enumerate(open(args.part)),desc='Read part graph' ):
part = int(part)
node = str(node)
node2part[node] = part
part2nodes[part].append(node)
npart = len(part2nodes)
part2edges = defaultdict(list)
for line in tqdm(open(args.whole), desc="Read all edges"):
node1, node2 = line.strip().split()
part1, part2 = node2part[node1], node2part[node2]
if part2 == part1:
part2edges[part1].append(line)
if args.outdir is not None:
if not os.path.isdir(args.outdir):
os.makedirs(args.outdir)
if args.feats is not None:
feats = {}
for node, feat in tqdm(enumerate(open(args.feats)), desc="Read feat"):
feats[str(node)] = np.array(list(map(float,feat.split())))
for p, nodes in part2nodes.items():
with open(os.path.join(args.outdir,'part_{}.txt.feat'.format(p)),'w') as f:
for node in tqdm(nodes,desc="Write feat {}".format(p)):
f.write("{} {}\n".format(node, " ".join(map(str, feats[node]))))
for p, edges in part2edges.items():
with open(os.path.join(args.outdir,'part_{}.txt'.format(p)),'w') as f:
for edge in tqdm(edges,desc="Write part {}".format(p)):
f.write(edge)