query_df = sqlContext.createDataFrame(query, schema=['sequence1', 'index1'])
reference_df = sqlContext.createDataFrame(reference, schema=['sequence2',
    'index2'])
Spark: более эффективное агрегирование для объединения строк из разных строк