anchor.diff:  ----
   A = LOAD '/resources/artists.json' USING PigStorage() AS (json:chararray<1>);"
   STORE B INTO 'radio/artists' 
  -    USING org.elasticsearch.pig.EsStorage('es.input.json=true'<2>...);
  +    USING org.elasticsearch.hadoop.pig.EsStorage('es.input.json=true'<2>...);
   ----
   
   <1> Load the (JSON) data as a single field (`json`)
  
positive.code: ----
  A = LOAD '/resources/media.json' USING PigStorage() AS (json:chararray<1>);"
  STORE B INTO 'my-collection/{media_type}'<2>
      USING org.elasticsearch.pig.EsStorage('es.input.json=true');
  ----
  
  <1> Schema declaration for the tuple. Since JSON input is used, the schema is simply a holder to the raw data
  
negative.code: ----
  -- execute Elasticsearch query and load data into Pig
  A = LOAD 'radio/artists'<1> 
      USING org.elasticsearch.hadoop.pig.EsStorage('es.query=?me*'<2>);
  DUMP A;
  ----
  
  