(self, fanouts, metapath,
add_self_loops=True,
max_id=-1,
**kwargs)
| 23 | |
| 24 | class SageDataFlow(UniqueDataFlow): |
| 25 | def __init__(self, fanouts, metapath, |
| 26 | add_self_loops=True, |
| 27 | max_id=-1, |
| 28 | **kwargs): |
| 29 | super(SageDataFlow, self).__init__(num_hops=len(metapath), |
| 30 | add_self_loops=add_self_loops) |
| 31 | self.fanouts = fanouts |
| 32 | self.metapath = metapath |
| 33 | self.max_id = max_id |
| 34 | |
| 35 | def get_neighbors(self, n_id): |
| 36 | neighbors = [] |
nothing calls this directly
no outgoing calls
no test coverage detected