private static CredentialsProvider getCredentialsProvider()

in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/utils/RestClientUtils.java [72:84]

13 lines of code
3 McCabe index (conditional complexity)


    private static CredentialsProvider getCredentialsProvider(
            NetworkClientConfig networkClientConfig) {
        CredentialsProvider credentialsProvider = null;
        if (networkClientConfig.getPassword() != null
                && networkClientConfig.getUsername() != null) {
            credentialsProvider = new BasicCredentialsProvider();
            credentialsProvider.setCredentials(
                    AuthScope.ANY,
                    new UsernamePasswordCredentials(
                            networkClientConfig.getUsername(), networkClientConfig.getPassword()));
        }
        return credentialsProvider;
    }