in spark-doris-connector/src/main/java/org/apache/doris/spark/load/CachedDorisStreamLoadClient.java [34:48]
static {
dorisStreamLoadLoadingCache = CacheBuilder.newBuilder()
.expireAfterWrite(cacheExpireTimeout, TimeUnit.SECONDS)
.removalListener(removalNotification -> {
//do nothing
})
.build(
new CacheLoader<SparkSettings, DorisStreamLoad>() {
@Override
public DorisStreamLoad load(SparkSettings sparkSettings) {
return new DorisStreamLoad(sparkSettings);
}
}
);
}