ElasticSearch-Sparkでエンティティのインデックスを取得する方法

Question

elasticsearch-hadoop/sparkライブラリを使用して、SparkRDDをElasticSearchクエリから作成しています。

esRDD方法は、生（ElasticSearch用語で_source、）文書および（ESで_id）文書のIDを返しますが、私はまた、このようなElasticSearch指標として、返されたドキュメントに関する追加情報を必要とし、各文書が来るタイプ（この情報は常にES REST APIから入手できます）。

esRDDメソッドで返されたRDDのドキュメントのインデックスとタイプ情報を取得するにはどうすればよいですか？

EDIT
esRDDに私の呼び出しはこのようになります。すなわち、私は、複数のインデックスを照会しています：

sparkContext.esRDD("index*/entities", query) 

と実際のインデックスが "index1の"、 "INDEX2" です は、私は、そうなど、結果のRDDの各エンティティがどの特定のインデックスから来たのか知りたい。

Answer 1

は場合誰もが将来的にこの時つまずく：

溶液をtrueにes.read.metadata設定を設定することであった（hereを参照します）。これは、esRDDの各文書に_metadataフィールドを追加します。このフィールドには、文書のインデックス、タイプ、ID、バージョンなどの情報が含まれます。