In [1]:
sc.addPyFile('magichour.zip')
In [2]:
from magichour.api.dist.templates.templateGen import templateGenRDD
In [3]:
transformURI = 'hdfs://namenode/magichour/simpleTrans'
support = 1000
logInURI = 'hdfs://namenode/magichour/tbird.500k.gz'
In [4]:
test = templateGenRDD(sc,logInURI,transformURI,support)
In [5]:
for i in test:
print ' '.join(i)
In [ ]: