スパークによるDEAP（遺伝的アルゴリズムライブラリ）の使用

Question

スパーククラスタにDEAP（http://deap.readthedocs.io/en/master/）を使用して、フィットネス評価関数をマップすることは可能ですか？私はGAを実行したいが、フィットネス機能はかなり長く、スパーククラスターに分散する計画だった。

Answer 1

DEAPのドキュメントのUsing Multiple Processorsセクションを参照してください。これはexampleです。彼らはの地図をDEAP toolboxの地図の機能で置き換える方法を説明します。

from pyspark import SparkContext 

sc = SparkContext(appName="DEAP") 

def sparkMap(algorithm, population): 
    return sc.parallelize(population).map(algorithm) 

toolbox.register("map", sparkMap) 

：適応度評価関数をマップするためにpysparkを使用するには

、あなたはそのような何かを行うことができます