public long getTotalBytes()

in src/main/java/com/aliyun/odps/kafka/connect/MaxComputeSinkWriter.java [259:269]

• 9 lines of code
• 3 McCabe index (conditional complexity)

  public long getTotalBytes() {
    if (writer != null) {
      try {
        return totalBytesByClosedSessions + ((TunnelBufferedWriter) writer).getTotalBytes();
      } catch (IOException e) {
        // Writer has been closed, ignore
      }
    }

    return totalBytesByClosedSessions;
  }