File InfluxDBImpl.java has 805 lines of code (exceeds 250 allowed). Consider refactoring.

Open

package org.influxdb.impl;

import com.squareup.moshi.JsonAdapter;
import com.squareup.moshi.Moshi;
import okhttp3.Headers;

InfluxDBImpl has 62 methods (exceeds 20 allowed). Consider refactoring.

Open

public class InfluxDBImpl implements InfluxDB {

  private static final String APPLICATION_MSGPACK = "application/x-msgpack";

  static final okhttp3.MediaType MEDIA_TYPE_STRING = MediaType.parse("text/plain");

Method query has 63 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  @Override
  public void query(final Query query, final int chunkSize, final BiConsumer<Cancellable, QueryResult> onNext,
                    final Runnable onComplete, final Consumer<Throwable> onFailure) {
    Call<ResponseBody> call;
    if (query instanceof BoundParameterQuery) {

Method query has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  @Override
  public void query(final Query query, final Consumer<QueryResult> onSuccess, final Consumer<Throwable> onFailure) {
    final Call<QueryResult> call = callQuery(query);
    call.enqueue(new Callback<QueryResult>() {
      @Override

Method enableBatch has 8 arguments (exceeds 4 allowed). Consider refactoring.

Open

  private InfluxDB enableBatch(final int actions, final int flushDuration, final int jitterDuration,
                               final TimeUnit durationTimeUnit, final ThreadFactory threadFactory,
                               final BiConsumer<Iterable<Point>, Throwable> exceptionHandler,
                               final boolean dropActionsOnQueueExhaustion, final Consumer<Point> droppedActionHandler) {

Method createRetentionPolicy has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

  public void createRetentionPolicy(final String rpName, final String database, final String duration,
                                    final String shardDuration, final int replicationFactor, final boolean isDefault) {

Method enableBatch has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

  public InfluxDB enableBatch(final int actions, final int flushDuration, final TimeUnit flushDurationTimeUnit,
                              final ThreadFactory threadFactory,
                              final BiConsumer<Iterable<Point>, Throwable> exceptionHandler,
                              final ConsistencyLevel consistency) {

Method query has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

  @Override
  public QueryResult query(final Query query, final TimeUnit timeUnit) {
    Call<QueryResult> call;
    if (query instanceof BoundParameterQuery) {
        BoundParameterQuery boundParameterQuery = (BoundParameterQuery) query;

• Read up
  Read up

Method query has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

  @Override
  public void query(final Query query, final int chunkSize, final BiConsumer<Cancellable, QueryResult> onNext,
                    final Runnable onComplete, final Consumer<Throwable> onFailure) {
    Call<ResponseBody> call;
    if (query instanceof BoundParameterQuery) {

• Read up
  Read up

Method write has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

  public void write(final String database, final String retentionPolicy, final ConsistencyLevel consistency,
          final TimeUnit precision, final String records) {

Method query has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

  public void query(final Query query, final int chunkSize, final BiConsumer<Cancellable, QueryResult> onNext,
                    final Runnable onComplete, final Consumer<Throwable> onFailure) {

Method write has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

  public void write(final String database, final String retentionPolicy, final ConsistencyLevel consistency,
          final TimeUnit precision, final List<String> records) {

Method enableBatch has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

  public InfluxDB enableBatch(final int actions, final int flushDuration, final TimeUnit flushDurationTimeUnit,
                              final ThreadFactory threadFactory,
                              final BiConsumer<Iterable<Point>, Throwable> exceptionHandler) {

Method createRetentionPolicy has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

  public void createRetentionPolicy(final String rpName, final String database, final String duration,
                                    final int replicationFactor, final boolean isDefault) {

Method createRetentionPolicy has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

  public void createRetentionPolicy(final String rpName, final String database, final String duration,
                                    final String shardDuration, final int replicationFactor) {

Method ping has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

  @Override
  public Pong ping() {
    final long started = System.currentTimeMillis();
    Call<ResponseBody> call = this.influxDBService.ping();
    try {

• Read up
  Read up

Method initialDatagramSocket has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

  private void initialDatagramSocket() {
    if (datagramSocket == null) {
        synchronized (InfluxDBImpl.class) {
            if (datagramSocket == null) {
                try {

• Read up
  Read up

Method process has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    @Override
    public void process(final ResponseBody chunkedBody, final Cancellable cancellable,
                        final BiConsumer<Cancellable, QueryResult> consumer, final Runnable onComplete)
            throws IOException {
      try {

• Read up
  Read up