Page History

class ComputeStep:
  @staticmethod
  def createAwaitsList(tupleContainer, tag ):
    # e.g. tupleContainer.add(itemCollection, tagValue)
    # e.g. operation on item collections: anItemCollection.get(aTag)
    # no dependencies, do nothing
    pass

  @staticmethod
  def compute(tag , outPrimes):
    # e.g. operation on input item collections: anItemCollection.get(aTag)
    # e.g. operation on output item collections: anItemCollection.put(aTag, aValue)
    # e.g. operation on tag collections: aTagCollection.putTag(aTag)
    candidate = int(tag)
    if ComputeStep.isPrime(candidate):
      outPrimes.put(str(candidate), candidate)
    return True

  @staticmethod
  def isPrime(n):
    for k in xrange(3, n, 2):
        if n % k == 0:
           return False
    return True