test_class.declarator: esConfig
test_class.modifier: @Mock
      private
test_class.original_string: @Mock
      private EsConfig esConfig;
test_class.type: EsConfig
test_class.var_name: esConfig
test_class.declarator: getRequest
test_class.modifier: @Mock
      private
test_class.original_string: @Mock
      private ElasticsearchGetRequest getRequest;
test_class.type: ElasticsearchGetRequest
test_class.var_name: getRequest
test_class.declarator: output
test_class.modifier: @Mock
      private
test_class.original_string: @Mock
      private EsLookupResultOutput output;
test_class.type: EsLookupResultOutput
test_class.var_name: output
test_class.declarator: tuple
test_class.modifier: @Mock
      private
test_class.original_string: @Mock
      private Tuple tuple;
test_class.type: Tuple
test_class.var_name: tuple
test_class.declarator: request
test_class.modifier: @Mock
      private
test_class.original_string: @Mock
      private GetRequest request;
test_class.type: GetRequest
test_class.var_name: request
test_class.declarator: client
test_class.modifier: @Mock
      private
test_class.original_string: @Mock
      private Client client;
test_class.type: Client
test_class.var_name: client
test_class.declarator: originalClient
test_class.modifier: private
test_class.original_string: private Client originalClient;
test_class.type: Client
test_class.var_name: originalClient
test_class.file: storm/storm-elasticsearch/src/test/java/org/apache/storm/elasticsearch/bolt/EsLookupBoltTest.java
test_class.identifier: EsLookupBoltTest
test_class.superclass: extends AbstractEsBoltTest<EsLookupBolt>
test_case.body: @Test
      public void fieldsAreDeclaredThroughProvidedOutput() throws Exception {
          Fields fields = new Fields(UUID.randomUUID().toString());
          when(output.fields()).thenReturn(fields);
          OutputFieldsDeclarer declarer = mock(OutputFieldsDeclarer.class);
          bolt.declareOutputFields(declarer);
  
          ArgumentCaptor<Fields> declaredFields = ArgumentCaptor.forClass(Fields.class);
          verify(declarer).declare(declaredFields.capture());
  
          assertThat(declaredFields.getValue(), is(fields));
      }
test_case.class_method_signature: EsLookupBoltTest.fieldsAreDeclaredThroughProvidedOutput()
test_case.full_signature: @Test public void fieldsAreDeclaredThroughProvidedOutput()
test_case.identifier: fieldsAreDeclaredThroughProvidedOutput
test_case.invocations: toString randomUUID thenReturn when fields mock declareOutputFields forClass declare verify capture assertThat getValue is
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void fieldsAreDeclaredThroughProvidedOutput()
focal_class.declarator: getRequest
focal_class.modifier: private final
focal_class.original_string: private final ElasticsearchGetRequest getRequest;
focal_class.type: ElasticsearchGetRequest
focal_class.var_name: getRequest
focal_class.declarator: output
focal_class.modifier: private final
focal_class.original_string: private final EsLookupResultOutput output;
focal_class.type: EsLookupResultOutput
focal_class.var_name: output
focal_class.file: storm/storm-elasticsearch/src/main/java/org/apache/storm/elasticsearch/bolt/EsLookupBolt.java
focal_class.identifier: EsLookupBolt
focal_class.class_method_signature: EsLookupBolt.EsLookupBolt(EsConfig esConfig, ElasticsearchGetRequest getRequest, EsLookupResultOutput output)
focal_class.full_signature: public  EsLookupBolt(EsConfig esConfig, ElasticsearchGetRequest getRequest, EsLookupResultOutput output)
focal_class.identifier: EsLookupBolt
focal_class.modifiers: public
focal_class.parameters: (EsConfig esConfig, ElasticsearchGetRequest getRequest, EsLookupResultOutput output)
focal_class.signature:  EsLookupBolt(EsConfig esConfig, ElasticsearchGetRequest getRequest, EsLookupResultOutput output)
focal_class.class_method_signature: EsLookupBolt.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: EsLookupBolt.lookupValuesInEs(Tuple tuple)
focal_class.full_signature: private Collection<Values> lookupValuesInEs(Tuple tuple)
focal_class.identifier: lookupValuesInEs
focal_class.modifiers: private
focal_class.parameters: (Tuple tuple)
focal_class.return: Collection<Values>
focal_class.signature: Collection<Values> lookupValuesInEs(Tuple tuple)
focal_class.class_method_signature: EsLookupBolt.tryEmitAndAck(Collection<Values> values, Tuple tuple)
focal_class.full_signature: private void tryEmitAndAck(Collection<Values> values, Tuple tuple)
focal_class.identifier: tryEmitAndAck
focal_class.modifiers: private
focal_class.parameters: (Collection<Values> values, Tuple tuple)
focal_class.return: void
focal_class.signature: void tryEmitAndAck(Collection<Values> values, Tuple tuple)
focal_class.class_method_signature: EsLookupBolt.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: @Override
      public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) {
          outputFieldsDeclarer.declare(output.fields());
      }
focal_method.class_method_signature: EsLookupBolt.declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer)
focal_method.full_signature: @Override public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer)
focal_method.identifier: declareOutputFields
focal_method.invocations: declare fields
focal_method.modifiers: @Override public
focal_method.parameters: (OutputFieldsDeclarer outputFieldsDeclarer)
focal_method.return: void
focal_method.signature: void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer)