test_class.file: storm/storm-elasticsearch/src/test/java/org/apache/storm/elasticsearch/bolt/EsIndexBoltTest.java
test_class.identifier: EsIndexBoltTest
test_class.superclass: extends AbstractEsBoltIntegrationTest<EsIndexBolt>
test_case.body: @Test
      public void testEsIndexBolt()
              throws Exception {
          String index = "index1";
          String type = "type1";
  
          Tuple tuple = createTestTuple(index, type);
  
          bolt.execute(tuple);
  
          verify(outputCollector).ack(tuple);
  
          node.client().admin().indices().prepareRefresh(index).execute().actionGet();
          CountResponse resp = node.client().prepareCount(index)
                  .setQuery(new TermQueryBuilder("_type", type))
                  .execute().actionGet();
  
          Assert.assertEquals(1, resp.getCount());
      }
test_case.class_method_signature: EsIndexBoltTest.testEsIndexBolt()
test_case.full_signature: @Test public void testEsIndexBolt()
test_case.identifier: testEsIndexBolt
test_case.invocations: createTestTuple execute ack verify actionGet execute prepareRefresh indices admin client actionGet execute setQuery prepareCount client assertEquals getCount
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testEsIndexBolt()
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/EsIndexBolt.java
focal_class.identifier: EsIndexBolt
focal_class.class_method_signature: EsIndexBolt.EsIndexBolt(EsConfig esConfig, EsTupleMapper tupleMapper)
focal_class.full_signature: public  EsIndexBolt(EsConfig esConfig, EsTupleMapper tupleMapper)
focal_class.identifier: EsIndexBolt
focal_class.modifiers: public
focal_class.parameters: (EsConfig esConfig, EsTupleMapper tupleMapper)
focal_class.signature:  EsIndexBolt(EsConfig esConfig, EsTupleMapper tupleMapper)
focal_class.class_method_signature: EsIndexBolt.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: EsIndexBolt.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: EsIndexBolt.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 EsIndexBolt(EsConfig esConfig, EsTupleMapper tupleMapper) {
          super(esConfig);
          this.tupleMapper = checkNotNull(tupleMapper);
      }
focal_method.class_method_signature: EsIndexBolt.EsIndexBolt(EsConfig esConfig, EsTupleMapper tupleMapper)
focal_method.full_signature: public  EsIndexBolt(EsConfig esConfig, EsTupleMapper tupleMapper)
focal_method.identifier: EsIndexBolt
focal_method.modifiers: public
focal_method.parameters: (EsConfig esConfig, EsTupleMapper tupleMapper)
focal_method.signature:  EsIndexBolt(EsConfig esConfig, EsTupleMapper tupleMapper)