Преобразовать список пар ключ-значение в каждой строке СДР в один ключ-значение в каждой строке

Немного связано ... если вы просто пытаетесь дезинфицировать определенную переменную, вы можете использовать PDO :: quote . Например, для поиска нескольких частичных условий LIKE, если вы застряли в ограниченной структуре, например CakePHP:

$pdo = $this->getDataSource()->getConnection();
$results = $this->find('all', array(
    'conditions' => array(
        'Model.name LIKE ' . $pdo->quote("%{$keyword1}%"),
        'Model.name LIKE ' . $pdo->quote("%{$keyword2}%"),
    ),
);

-2
задан user3607109 24 February 2019 в 17:04
поделиться

1 ответ

rdd.flatMap(identity) преобразует RDD[List[(String, String)]] в RDD[(String, String)].

scala> val rdd = sc.parallelize(List(List(("a","b"),("b","c")), List(("d","e"))))
...
rdd: org.apache.spark.rdd.RDD[List[(String, String)]] = ParallelCollectionRDD[2] at parallelize at <console>:13
scala> rdd.flatMap(identity)
res2: org.apache.spark.rdd.RDD[(String, String)] = MapPartitionsRDD[3] at flatMap at <console>:14
scala> res2.collect()
...
res3: Array[(String, String)] = Array((a,b), (b,c), (d,e))

Это будет работать так же для любого RDD[List[T]], независимо от формы T. Может помочь больше, если вы поделитесь немного большей информацией о том, что вы пытаетесь сделать.

0
ответ дан ariskk 24 February 2019 в 17:04
поделиться
Другие вопросы по тегам:

Похожие вопросы: