in flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/writer/KuduWriterConfig.java [48:64]
private KuduWriterConfig(
String masters,
FlushMode flushMode,
long operationTimeout,
int maxBufferSize,
int flushInterval,
boolean ignoreNotFound,
boolean ignoreDuplicate) {
this.masters = checkNotNull(masters, "Kudu masters cannot be null");
this.flushMode = checkNotNull(flushMode, "Kudu flush mode cannot be null");
this.operationTimeout = operationTimeout;
this.maxBufferSize = maxBufferSize;
this.flushInterval = flushInterval;
this.ignoreNotFound = ignoreNotFound;
this.ignoreDuplicate = ignoreDuplicate;
}