public ElasticSearchClient getLocalClient()

in flume-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/ElasticSearchClientFactory.java [66:77]

• 12 lines of code
• 6 McCabe index (conditional complexity)

  public ElasticSearchClient getLocalClient(String clientType,
                                            ElasticSearchEventSerializer serializer,
                                            ElasticSearchIndexRequestBuilderFactory indexBuilder)
      throws NoSuchClientTypeException {
    if (clientType.equalsIgnoreCase(TransportClient) && serializer != null) {
      return new ElasticSearchTransportClient(serializer);
    } else if (clientType.equalsIgnoreCase(TransportClient) && indexBuilder != null)  {
      return new ElasticSearchTransportClient(indexBuilder);
    } else if (clientType.equalsIgnoreCase(RestClient)) {
    }
    throw new NoSuchClientTypeException();
  }