private MaxComputeSinkWriter genSinkWriter()

in src/main/java/com/aliyun/odps/kafka/connect/MaxComputeSinkTask.java [267:277]

• 11 lines of code
• 1 McCabe index (conditional complexity)

  private MaxComputeSinkWriter genSinkWriter(TopicPartition partition) {
    return new MaxComputeSinkWriter(config,
                                    project,
                                    table,
                                    converterBuilder.build(),
                                    bufferSizeKB,
                                    partitionWindowType,
                                    tz, useStreamTunnel,
                                    retryTimes,
                                    tunnelEndpoint);
  }