test_class.file: storm/storm-elasticsearch/src/test/java/org/apache/storm/elasticsearch/bolt/EsPercolateBoltTest.java
test_class.identifier: EsPercolateBoltTest
test_class.superclass: extends AbstractEsBoltIntegrationTest<EsPercolateBolt>
test_case.body: @Test
      public void testEsPercolateBolt()
              throws Exception {
          String source = "{\"user\":\"user1\"}";
          String index = "index1";
          String type = ".percolator";
  
          node.client().prepareIndex("index1", ".percolator")
                  .setId("1")
                  .setSource("{\"query\":{\"match\":{\"user\":\"user1\"}}}").
                  execute().actionGet();
          Tuple tuple = EsTestUtil.generateTestTuple(source, index, type, null);
  
          bolt.execute(tuple);
  
          verify(outputCollector).ack(tuple);
          verify(outputCollector).emit(new Values(source, any(PercolateResponse.Match.class)));
      }
test_case.class_method_signature: EsPercolateBoltTest.testEsPercolateBolt()
test_case.full_signature: @Test public void testEsPercolateBolt()
test_case.identifier: testEsPercolateBolt
test_case.invocations: actionGet execute setSource setId prepareIndex client generateTestTuple execute ack verify emit verify any
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testEsPercolateBolt()
focal_class.declarator: tupleMapper
focal_class.modifier: private final
focal_class.original_string: private final EsTupleMapper tupleMapper;
focal_class.type: EsTupleMapper
focal_class.var_name: tupleMapper
focal_class.file: storm/storm-elasticsearch/src/main/java/org/apache/storm/elasticsearch/bolt/EsPercolateBolt.java
focal_class.identifier: EsPercolateBolt
focal_class.class_method_signature: EsPercolateBolt.EsPercolateBolt(EsConfig esConfig, EsTupleMapper tupleMapper)
focal_class.full_signature: public  EsPercolateBolt(EsConfig esConfig, EsTupleMapper tupleMapper)
focal_class.identifier: EsPercolateBolt
focal_class.modifiers: public
focal_class.parameters: (EsConfig esConfig, EsTupleMapper tupleMapper)
focal_class.signature:  EsPercolateBolt(EsConfig esConfig, EsTupleMapper tupleMapper)
focal_class.class_method_signature: EsPercolateBolt.prepare(Map map, TopologyContext topologyContext, OutputCollector outputCollector)
focal_class.full_signature: @Override public void prepare(Map map, TopologyContext topologyContext, OutputCollector outputCollector)
focal_class.identifier: prepare
focal_class.modifiers: @Override public
focal_class.parameters: (Map map, TopologyContext topologyContext, OutputCollector outputCollector)
focal_class.return: void
focal_class.signature: void prepare(Map map, TopologyContext topologyContext, OutputCollector outputCollector)
focal_class.class_method_signature: EsPercolateBolt.execute(Tuple tuple)
focal_class.full_signature: @Override public void execute(Tuple tuple)
focal_class.identifier: execute
focal_class.modifiers: @Override public
focal_class.parameters: (Tuple tuple)
focal_class.return: void
focal_class.signature: void execute(Tuple tuple)
focal_class.class_method_signature: EsPercolateBolt.declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer)
focal_class.full_signature: @Override public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer)
focal_class.identifier: declareOutputFields
focal_class.modifiers: @Override public
focal_class.parameters: (OutputFieldsDeclarer outputFieldsDeclarer)
focal_class.return: void
focal_class.signature: void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer)
focal_class.superclass: extends AbstractEsBolt
focal_method.body: public EsPercolateBolt(EsConfig esConfig, EsTupleMapper tupleMapper) {
          super(esConfig);
          this.tupleMapper = checkNotNull(tupleMapper);
      }
focal_method.class_method_signature: EsPercolateBolt.EsPercolateBolt(EsConfig esConfig, EsTupleMapper tupleMapper)
focal_method.full_signature: public  EsPercolateBolt(EsConfig esConfig, EsTupleMapper tupleMapper)
focal_method.identifier: EsPercolateBolt
focal_method.modifiers: public
focal_method.parameters: (EsConfig esConfig, EsTupleMapper tupleMapper)
focal_method.signature:  EsPercolateBolt(EsConfig esConfig, EsTupleMapper tupleMapper)