df = sc.parallelize([(1, 'foo'), (2, 'x'), (3, 'bar')]).toDF(('k', 'v'))
df.registerTempTable('df')
sqlContext.sql('SELECT * FROM df WHERE v IN {0}'.format(('foo', 'bar'))).count(
    )
Фильтрация Pyspark DataFrame с SQL-подобным предложением IN