dmlc--dgl
44089c8b4d
* Merge * [Graph][CUDA] Graph on GPU and many refactoring (#1791) * change edge_ids behavior and C++ impl * fix unittests; remove utils.Index in edge_id * pass mx and th tests * pass tf test * add aten::Scatter_ * Add nonzero; impl CSRGetDataAndIndices/CSRSliceMatrix * CSRGetData and CSRGetDataAndIndices passed tests * CSRSliceMatrix basic tests * fix bug in empty slice * CUDA CSRHasDuplicate * has_node; has_edge_between * predecessors, successors * deprecate send/recv; fix send_and_recv * deprecate send/recv; fix send_and_recv * in_edges; out_edges; all_edges; apply_edges * in deg/out deg * subgraph/edge_subgraph * adj * in_subgraph/out_subgraph * sample neighbors * set/get_n/e_repr * wip: working on refactoring all idtypes * pass ndata/edata tests on gpu * fix * stash * workaround nonzero issue * stash * nx conversion * test_hetero_basics except update routines * test_update_routines * test_hetero_basics for pytorch * more fixes * WIP: flatten graph * wip: flatten * test_flatten * test_to_device * fix bug in to_homo * fix bug in CSRSliceMatrix * pass subgraph test * fix send_and_recv * fix filter * test_heterograph * passed all pytorch tests * fix mx unittest * fix pytorch test_nn * fix all unittests for PyTorch * passed all mxnet tests * lint * fix tf nn test * pass all tf tests * lint * lint * change deprecation * try fix compile * lint * update METIDS * fix utest * fix * fix utests * try debug * revert * small fix * fix utests * upd * upd * upd * fix * upd * upd * upd * upd * upd * trigger * +1s * [kernel] Use heterograph index instead of unitgraph index (#1813) * upd * upd * upd * fix * upd * upd * upd * upd * upd * trigger * +1s * [Graph] Mutation for Heterograph (#1818) * mutation add_nodes and add_edges * Add support for remove_edges, remove_nodes, add_selfloop, remove_selfloop * Fix Co-authored-by: Ubuntu <ubuntu@ip-172-31-51-214.ec2.internal> * upd * upd * upd * fix * [Transfom] Mutable transform (#1833) * add nodesy * All three * Fix * lint * Add some test case * Fix * Fix * Fix * Fix * Fix * Fix * fix * triger * Fix * fix Co-authored-by: Ubuntu <ubuntu@ip-172-31-51-214.ec2.internal> * [Graph] Migrate Batch & Readout module to heterograph (#1836) * dgl.batch * unbatch * fix to device * reduce readout; segment reduce * change batch_num_nodes|edges to function * reduce readout/ softmax * broadcast * topk * fix * fix tf and mx * fix some ci * fix batch but unbatch differently * new checkk * upd * upd * upd * idtype behavior; code reorg * idtype behavior; code reorg * wip: test_basics * pass test_basics * WIP: from nx/ to nx * missing files * upd * pass test_basics:test_nx_conversion * Fix test * Fix inplace update * WIP: fixing tests * upd * pass test_transform cpu * pass gpu test_transform * pass test_batched_graph * GPU graph auto cast to int32 * missing file * stash * WIP: rgcn-hetero * Fix two datasety * upd * weird * Fix capsuley * fuck you * fuck matthias * Fix dgmg * fix bug in block degrees; pass rgcn-hetero * rgcn * gat and diffpool fix also fix ppi and tu dataset * Tree LSTM * pointcloud * rrn; wip: sgc * resolve conflicts * upd * sgc and reddit dataset * upd * Fix deepwalk, gindt and gcn * fix datasets and sign * optimization * optimization * upd * upd * Fix GIN * fix bug in add_nodes add_edges; tagcn * adaptive sampling and gcmc * upd * upd * fix geometric * fix * metapath2vec * fix agnn * fix pickling problem of block * fix utests * miss file * linegraph * upd * upd * upd * graphsage * stgcn_wave * fix hgt * on unittests * Fix transformer * Fix HAN * passed pytorch unittests * lint * fix * Fix cluster gcn * cluster-gcn is ready * on fixing block related codes * 2nd order derivative * Revert "2nd order derivative" This reverts commit 523bf6c249bee61b51b1ad1babf42aad4167f206. * passed torch utests again * fix all mxnet unittests * delete some useless tests * pass all tf cpu tests * disable * disable distributed unittest * fix * fix * lint * fix * fix * fix script * fix tutorial * fix apply edges bug * fix 2 basics * fix tutorial Co-authored-by: yzh119 <expye@outlook.com> Co-authored-by: xiang song(charlie.song) <classicxsong@gmail.com> Co-authored-by: Ubuntu <ubuntu@ip-172-31-51-214.ec2.internal> Co-authored-by: Ubuntu <ubuntu@ip-172-31-7-42.us-west-2.compute.internal> Co-authored-by: Ubuntu <ubuntu@ip-172-31-1-5.us-west-2.compute.internal> Co-authored-by: Ubuntu <ubuntu@ip-172-31-68-185.ec2.internal>
74 行
2.3 KiB
Python
74 行
2.3 KiB
Python
import torch
|
|
import torch.nn as nn
|
|
import torch.nn.functional as F
|
|
from dgl.nn.pytorch import KNNGraph, EdgeConv
|
|
|
|
class Model(nn.Module):
|
|
def __init__(self, k, feature_dims, emb_dims, output_classes, input_dims=3,
|
|
dropout_prob=0.5):
|
|
super(Model, self).__init__()
|
|
|
|
self.nng = KNNGraph(k)
|
|
self.conv = nn.ModuleList()
|
|
|
|
self.num_layers = len(feature_dims)
|
|
for i in range(self.num_layers):
|
|
self.conv.append(EdgeConv(
|
|
feature_dims[i - 1] if i > 0 else input_dims,
|
|
feature_dims[i],
|
|
batch_norm=True))
|
|
|
|
self.proj = nn.Linear(sum(feature_dims), emb_dims[0])
|
|
|
|
self.embs = nn.ModuleList()
|
|
self.bn_embs = nn.ModuleList()
|
|
self.dropouts = nn.ModuleList()
|
|
|
|
self.num_embs = len(emb_dims) - 1
|
|
for i in range(1, self.num_embs + 1):
|
|
self.embs.append(nn.Linear(
|
|
# * 2 because of concatenation of max- and mean-pooling
|
|
emb_dims[i - 1] if i > 1 else (emb_dims[i - 1] * 2),
|
|
emb_dims[i]))
|
|
self.bn_embs.append(nn.BatchNorm1d(emb_dims[i]))
|
|
self.dropouts.append(nn.Dropout(dropout_prob))
|
|
|
|
self.proj_output = nn.Linear(emb_dims[-1], output_classes)
|
|
|
|
def forward(self, x):
|
|
hs = []
|
|
batch_size, n_points, x_dims = x.shape
|
|
h = x
|
|
|
|
for i in range(self.num_layers):
|
|
g = self.nng(h).to(h.device)
|
|
h = h.view(batch_size * n_points, -1)
|
|
h = self.conv[i](g, h)
|
|
h = F.leaky_relu(h, 0.2)
|
|
h = h.view(batch_size, n_points, -1)
|
|
hs.append(h)
|
|
|
|
h = torch.cat(hs, 2)
|
|
h = self.proj(h)
|
|
h_max, _ = torch.max(h, 1)
|
|
h_avg = torch.mean(h, 1)
|
|
h = torch.cat([h_max, h_avg], 1)
|
|
|
|
for i in range(self.num_embs):
|
|
h = self.embs[i](h)
|
|
h = self.bn_embs[i](h)
|
|
h = F.leaky_relu(h, 0.2)
|
|
h = self.dropouts[i](h)
|
|
|
|
h = self.proj_output(h)
|
|
return h
|
|
|
|
|
|
def compute_loss(logits, y, eps=0.2):
|
|
num_classes = logits.shape[1]
|
|
one_hot = torch.zeros_like(logits).scatter_(1, y.view(-1, 1), 1)
|
|
one_hot = one_hot * (1 - eps) + (1 - one_hot) * eps / (num_classes - 1)
|
|
log_prob = F.log_softmax(logits, 1)
|
|
loss = -(one_hot * log_prob).sum(1).mean()
|
|
return loss
|