public PersistableEvent()

in flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/PersistableEvent.java [38:61]

• 22 lines of code
• 5 McCabe index (conditional complexity)

  public PersistableEvent(String channel, Event event) {
    this.channel = channel;

    byte[] givenPayload = event.getBody();
    if (givenPayload.length < ConfigurationConstants.PAYLOAD_LENGTH_THRESHOLD) {
      basePayload = Arrays.copyOf(givenPayload, givenPayload.length);
      spillPayload = null;
    } else {
      basePayload = Arrays.copyOfRange(givenPayload, 0,
          ConfigurationConstants.PAYLOAD_LENGTH_THRESHOLD);
      spillPayload = Arrays.copyOfRange(givenPayload,
          ConfigurationConstants.PAYLOAD_LENGTH_THRESHOLD, givenPayload.length);
    }

    Map<String, String> headerMap = event.getHeaders();
    if (headerMap != null && headerMap.size() > 0) {
      headers = new ArrayList<HeaderEntry>();
      for (Map.Entry<String, String> entry : headerMap.entrySet()) {
        String name = entry.getKey();
        String value = entry.getValue();
        headers.add(new HeaderEntry(name, value));
      }
    }
  }