org.apache.druid.java.util.common.logger.Logger.debug()方法的使用及代码示例

x33g5p2x  于2022-01-23 转载在 其他  
字(4.8k)|赞(0)|评价(0)|浏览(124)

本文整理了Java中org.apache.druid.java.util.common.logger.Logger.debug()方法的一些代码示例,展示了Logger.debug()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Logger.debug()方法的具体详情如下:
包路径:org.apache.druid.java.util.common.logger.Logger
类名称:Logger
方法名:debug

Logger.debug介绍

暂无

代码示例

代码示例来源:origin: apache/incubator-druid

@Override
public void removeHistogram(String name)
{
 log.debug("Ignoring remove histogram [%s]", name);
}

代码示例来源:origin: apache/incubator-druid

@Override
 public void updateHistogram(String name, int amount)
 {
  log.debug("Ignoring update histogram [%s]: %d", name, amount);
 }
};

代码示例来源:origin: apache/incubator-druid

@Override
public void lifeCycleStarted(LifeCycle event)
{
 log.debug("Jetty lifeycle started [%s]", event.getClass());
}

代码示例来源:origin: apache/incubator-druid

@Override
public void lifeCycleStarting(LifeCycle event)
{
 log.debug("Jetty lifecycle starting [%s]", event.getClass());
}

代码示例来源:origin: apache/incubator-druid

@Override
 public void lifeCycleStopped(LifeCycle event)
 {
  log.debug("Jetty lifecycle stopped [%s]", event.getClass());
 }
});

代码示例来源:origin: apache/incubator-druid

CacheHandler(NamespaceExtractionCacheManager cacheManager, ConcurrentMap<String, String> cache, Object id)
{
 log.debug("Creating %s", super.toString());
 this.cacheManager = cacheManager;
 this.cache = cache;
 this.id = id;
}

代码示例来源:origin: apache/incubator-druid

@Override
public void close()
{
 if (cachedValues != null) {
  log.debug("Closing column cache");
  cachedValues.clear();
 }
}

代码示例来源:origin: apache/incubator-druid

@LifecycleStart
public void start()
{
 log.debug("Log4j shutter downer is waiting");
}

代码示例来源:origin: apache/incubator-druid

@Override
public void removeCounter(String name)
{
 if (log.isDebugEnabled()) {
  log.debug("Ignoring request to remove [%s]", name);
 }
}

代码示例来源:origin: apache/incubator-druid

@Override
 public void close()
 {
  cacheManager.disposeCache(this);
  // Log statement after disposeCache(), because logging may fail (e. g. in shutdown hooks)
  log.debug("Closed %s", super.toString());
 }
}

代码示例来源:origin: apache/incubator-druid

@Override
public void addCounter(String name)
{
 if (!interesting.apply(name)) {
  return;
 }
 counters.putIfAbsent(name, new AtomicLong(0L));
 if (log.isDebugEnabled()) {
  log.debug("Add Counter [%s]", name);
 }
}

代码示例来源:origin: apache/incubator-druid

@Override
 public RequestLogger get()
 {
  EmittingRequestLogger logger = new EmittingRequestLogger(emitter, feed, requestLogEventBuilderFactory);
  log.debug(new Exception("Stack trace"), "Creating %s at", logger);
  return logger;
 }
}

代码示例来源:origin: apache/incubator-druid

@Override
 public RequestLogger get()
 {
  LoggingRequestLogger logger = new LoggingRequestLogger(mapper, setMDC, setContextMDC);
  log.debug(new Exception("Stack trace"), "Creating %s at", logger);
  return logger;
 }
}

代码示例来源:origin: apache/incubator-druid

public Map<String, Long> to(String key, Map<String, Long> curr)
{
 final Map<String, Long> prev = prevs.put(key, curr);
 if (prev != null) {
  return subtract(curr, prev);
 } else {
  log.debug("No previous data for key[%s]", key);
  return null;
 }
}

代码示例来源:origin: apache/incubator-druid

@Override
public void addMeter(String name)
{
 if (!interesting.apply(name)) {
  return;
 }
 meters.putIfAbsent(name, new AtomicLong(0L));
 if (log.isDebugEnabled()) {
  log.debug("Adding meter [%s]", name);
 }
}

代码示例来源:origin: apache/incubator-druid

private String extractEtagFromResults(
  final byte[] cachedResult
)
{
 if (cachedResult == null) {
  return null;
 }
 log.debug("Fetching result level cache identifier for query: %s", query.getId());
 int etagLength = ByteBuffer.wrap(cachedResult, 0, Integer.BYTES).getInt();
 return StringUtils.fromUtf8(Arrays.copyOfRange(cachedResult, Integer.BYTES, etagLength + Integer.BYTES));
}

代码示例来源:origin: apache/incubator-druid

@Override
public RequestLogger get()
{
 final List<RequestLogger> loggers = new ArrayList<>();
 for (RequestLoggerProvider loggerProvider : loggerProviders) {
  loggers.add(loggerProvider.get());
 }
 ComposingRequestLogger logger = new ComposingRequestLogger(loggers);
 log.debug(new Exception("Stack trace"), "Creating %s at", logger);
 return logger;
}

代码示例来源:origin: apache/incubator-druid

@Override
public RequestLogger get()
{
 FilteredRequestLogger logger = new FilteredRequestLogger(
   delegate.get(),
   queryTimeThresholdMs,
   sqlQueryTimeThresholdMs
 );
 log.debug(new Exception("Stack trace"), "Creating %s at", logger);
 return logger;
}

代码示例来源:origin: apache/incubator-druid

@Override
 public void run()
 {
  LOGGER.debug("Polling and swapping of PollingLookup [%s]", id);
  CacheRefKeeper newCacheKeeper = new CacheRefKeeper(cacheFactory.makeOf(dataFetcher.fetchAll()));
  CacheRefKeeper oldCacheKeeper = refOfCacheKeeper.getAndSet(newCacheKeeper);
  if (oldCacheKeeper != null) {
   oldCacheKeeper.doneWithIt();
  }
 }
};

代码示例来源:origin: apache/incubator-druid

@LifecycleStop
 public void stop()
 {
  if (log4jShutdown != null) {
   log.debug("Shutting down log4j");
   log4jShutdown.stop();
  } else {
   log.warn("Log4j shutdown was registered in lifecycle but no shutdown object exists!");
  }
 }
}

相关文章