In [1]:

    

from collections import defaultdict


    

In [2]:

    

sc.addPyFile('magichour.zip')


    

In [3]:

    

from magichour.api.dist.events.eventGen import eventGenRDD


    

In [4]:

    

t = 'hdfs://namenode/magichour/tbird.500.templateEvalRDD'
minSupport = 0.2
numPartitions = 10
windowLen=120
transactions = sc.pickleFile(t)


    

In [5]:

    

test = eventGenRDD(sc,transactions,minSupport,numPartitions,windowLen)


    

In [7]:

    

test


    

In [ ]: