BatchOptions has 21 methods (exceeds 20 allowed). Consider refactoring.

Open

public final class BatchOptions implements Cloneable {

  // default values here are consistent with Telegraf
  public static final int DEFAULT_BATCH_ACTIONS_LIMIT = 1000;
  public static final int DEFAULT_BATCH_INTERVAL_DURATION = 1000;

BatchPoints has 21 methods (exceeds 20 allowed). Consider refactoring.

Open

public class BatchPoints {
  private String database;
  private String retentionPolicy;
  private Map<String, String> tags;
  private List<Point> points;

Method buildQueryString has 53 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  @Override
  public StringBuilder buildQueryString(final StringBuilder builder) {
    builder.append("SELECT ");

    if (isDistinct) {

Method appendName has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

  public static StringBuilder appendName(final Object name, final StringBuilder stringBuilder) {
    if (name instanceof String) {
      appendName((String) name, stringBuilder);
    } else if (name instanceof Column) {
      appendName(((Column) name).getName(), stringBuilder);

• Read up
  Read up

Method setField has a Cognitive Complexity of 15 (exceeds 5 allowed). Consider refactoring.

Open

    private void setField(
            final Class<?> fieldType,
            final String columnName,
            final Object value) {
      if (boolean.class.isAssignableFrom(fieldType) || Boolean.class.isAssignableFrom(fieldType)) {

• Read up
  Read up

Method write has 46 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  void write() {
    List<Point> currentBatch = null;
    try {
      if (this.queue.isEmpty()) {
        BatchProcessor.this.batchWriter.write(Collections.emptyList());

Method concatenatedFields has a Cognitive Complexity of 14 (exceeds 5 allowed). Consider refactoring.

Open

  private int concatenatedFields(final StringBuilder sb) {
    int fieldCount = 0;
    for (Entry<String, Object> field : this.fields.entrySet()) {
      Object value = field.getValue();
      if (value == null || isNotFinite(value)) {

• Read up
  Read up

Method adaptValue has 42 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  private static Object adaptValue(final Class<?> fieldType, final Object value, final TimeUnit precision,
                                   final String fieldName, final String className) {
    try {
      if (String.class.isAssignableFrom(fieldType)) {
        return String.valueOf(value);

Method equals has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

  @SuppressWarnings("checkstyle:needbraces")
  @Override
  public boolean equals(final Object obj) {
    if (this == obj)
      return true;

• Read up
  Read up

Method addFieldsFromPOJO has 36 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public Builder addFieldsFromPOJO(final Object pojo) {

      Class<?> clazz = pojo.getClass();
      Measurement measurement = clazz.getAnnotation(Measurement.class);
      boolean allFields = measurement != null && measurement.allFields();

Method addFieldByAttribute has 36 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    private void addFieldByAttribute(final Object pojo, final Field field, final boolean tag,
                                     final String fieldName, final TypeMapper typeMapper) {
      try {
        Object fieldValue = field.get(pojo);

Method appendValue has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

  public static StringBuilder appendValue(final Object value, final StringBuilder stringBuilder) {
    if (value instanceof Appendable) {
      Appendable appendable = (Appendable) value;
      appendable.appendTo(stringBuilder);
    } else if (value instanceof Function) {

• Read up
  Read up

Method write has 35 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  @Override
  public synchronized void write(final Collection<BatchPoints> collection) {
    // empty the cached data first
    ListIterator<BatchPoints> batchQueueIterator = batchQueue.listIterator();
    while (batchQueueIterator.hasNext()) {

Method cacheMeasurementClass has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  void cacheMeasurementClass(final Class<?>... classVarAgrs) {
    for (Class<?> clazz : classVarAgrs) {
      if (CLASS_INFO_CACHE.containsKey(clazz.getName())) {
        continue;
      }

Method formatedTime has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

  private void formatedTime(final StringBuilder sb, final TimeUnit precision) {
    if (this.time == null) {
      return;
    }
    TimeUnit converterPrecision = precision;

• Read up
  Read up

Method parseSeriesAs has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  <T> List<T> parseSeriesAs(final QueryResult.Series series, final Class<T> clazz, final List<T> result,
                            final TimeUnit precision) {
    int columnSize = series.getColumns().size();

    ClassInfo classInfo = CLASS_INFO_CACHE.get(clazz.getName());

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

Open

  private void formatedTime(final StringBuilder sb, final TimeUnit precision) {
    if (this.time == null) {
      return;
    }
    TimeUnit converterPrecision = precision;

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 concatenatedFields has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  private int concatenatedFields(final StringBuilder sb) {
    int fieldCount = 0;
    for (Entry<String, Object> field : this.fields.entrySet()) {
      Object value = field.getValue();
      if (value == null || isNotFinite(value)) {

Method appendName has 29 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  public static StringBuilder appendName(final Object name, final StringBuilder stringBuilder) {
    if (name instanceof String) {
      appendName((String) name, stringBuilder);
    } else if (name instanceof Column) {
      appendName(((Column) name).getName(), stringBuilder);