private void writeToStreamWriter()

in src/main/java/com/aliyun/odps/kafka/connect/MaxComputeSinkWriter.java [177:182]

• 6 lines of code
• 2 McCabe index (conditional complexity)

  private void writeToStreamWriter() throws IOException {
    streamPack.append(reusedRecord);
    if (streamPack.getDataSize() >= getActualBufferBytes()) {
      flushStreamPackWithRetry(retryTimes);
    }
  }