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

Open

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

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 setFieldValue has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

  private static <T> void setFieldValue(final T object, final Field field, final Object value, final TimeUnit precision,
                                        final TypeMapper typeMapper)

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 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 adaptValue has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

  private static Object adaptValue(final Class<?> fieldType, final Object value, final TimeUnit precision,
                                   final String fieldName, final String className) {

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

Open

  public Call<ResponseBody> writePoints(@Query(DB) String database,
      @Query(RP) String retentionPolicy, @Query(PRECISION) String precision,
      @Query(CONSISTENCY) String consistency, @Body RequestBody batchPoints);

Method put has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

  void put(final AbstractBatchEntry batchEntry) {
    try {
        if (this.dropActionsOnQueueExhaustion) {
          if (!this.queue.offer(batchEntry)) {
            this.droppedActionHandler.accept(batchEntry.getPoint());

• Read up
  Read up

Method field has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

    @SuppressWarnings("checkstyle:finalparameters")
    @Deprecated
    public Builder field(final String field, Object value) {
      if (value instanceof Number) {
        if (value instanceof Byte) {

• Read up
  Read up

Avoid too many return statements within this method.

Open

        return Boolean.valueOf(String.valueOf(value));

Avoid too many return statements within this method.

Open

        return ((Double) value).longValue();

Avoid too many return statements within this method.

Open

        return false;

Avoid too many return statements within this method.

Open

        return false;

Avoid too many return statements within this method.

Open

        return Enum.valueOf((Class<Enum>) fieldType, String.valueOf(value));

Avoid too many return statements within this method.

Open

        return value;

Avoid too many return statements within this method.

Open

      return new AuthorizationFailedException(errorMessage);

Avoid too many return statements within this method.

Open

          return Instant.ofEpochMilli(toMillis(((Integer) value).longValue(), precision));

Avoid too many return statements within this method.

Open

      return false;

Avoid too many return statements within this method.

Open

    return true;