io.druid.java.util.common.logger.Logger.isDebugEnabled()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(6.2k)|赞(0)|评价(0)|浏览(186)

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

Logger.isDebugEnabled介绍

暂无

代码示例

代码示例来源:origin: io.druid/druid-server

@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: io.druid/druid-server

@Override
public void removeMeter(String name)
{
 if (!interesting.apply(name)) {
  return;
 }
 if (log.isDebugEnabled()) {
  log.debug("Ignoring request to remove meter [%s]", name);
 }
}

代码示例来源:origin: io.druid/druid-server

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

代码示例来源:origin: io.druid/druid-server

@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: io.druid/druid-server

@Override
public void incrementCounter(String name)
{
 if (!interesting.apply(name)) {
  return;
 }
 AtomicLong counter = counters.get(name);
 if (counter == null) {
  counters.putIfAbsent(name, new AtomicLong(0));
  counter = counters.get(name);
 }
 counter.incrementAndGet();
 if (log.isDebugEnabled()) {
  log.debug("Increment [%s]", name);
 }
}

代码示例来源:origin: io.druid/druid-server

@Override
public void decrementCounter(String name)
{
 if (!interesting.apply(name)) {
  return;
 }
 AtomicLong counter = counters.get(name);
 if (counter == null) {
  counters.putIfAbsent(name, new AtomicLong(0));
  counter = counters.get(name);
 }
 counter.decrementAndGet();
 if (log.isDebugEnabled()) {
  log.debug("Decrement [%s]", name);
 }
}

代码示例来源:origin: io.druid/druid-server

@Override
public void decrementCounter(String name, int amount)
{
 if (!interesting.apply(name)) {
  return;
 }
 AtomicLong counter = counters.get(name);
 if (counter == null) {
  counters.putIfAbsent(name, new AtomicLong(0L));
  counter = counters.get(name);
 }
 counter.addAndGet(-amount);
 if (log.isDebugEnabled()) {
  log.debug("Decrement [%s] %d", name, amount);
 }
}

代码示例来源:origin: io.druid/druid-server

@Override
public void incrementCounter(String name, int amount)
{
 if (!interesting.apply(name)) {
  return;
 }
 AtomicLong counter = counters.get(name);
 if (counter == null) {
  counters.putIfAbsent(name, new AtomicLong(0));
  counter = counters.get(name);
 }
 counter.addAndGet(amount);
 if (log.isDebugEnabled()) {
  log.debug("Increment [%s] %d", name, amount);
 }
}

代码示例来源:origin: io.druid/druid-server

@Override
public void markMeter(String name)
{
 if (!interesting.apply(name)) {
  return;
 }
 AtomicLong meter = meters.get(name);
 if (meter == null) {
  meters.putIfAbsent(name, new AtomicLong(0L));
  meter = meters.get(name);
 }
 meter.incrementAndGet();
 if (log.isDebugEnabled()) {
  log.debug("Increment counter [%s]", name);
 }
}

代码示例来源:origin: io.druid/druid-services

if (log.isTraceEnabled() || log.isDebugEnabled()) {
 return new DefaultTeslaAether(
   localRepository,

代码示例来源:origin: io.druid/java-util

private static void debugLogState(String name, long state)
 {
  if (log.isDebugEnabled()) {
   log.debug(
     "%s[bufferWatermark=%d, parties=%d, isSealed=%s]",
     name,
     bufferWatermark(state),
     parties(state),
     isSealed(state)
   );
  }
 }
}

代码示例来源:origin: io.druid/java-util

if (log.isDebugEnabled()) {
 log.debug(message, started.get());

代码示例来源:origin: io.druid/java-util

if (log.isDebugEnabled()) {
 log.debug(message, jsonMapper.writeValueAsString(event));

代码示例来源:origin: io.druid/java-util

if (log.isDebugEnabled()) {
 log.debug(message, started.get());

代码示例来源:origin: io.druid/druid-server

@Override
 public void log(Request request, Response response)
 {
  if (logger.isDebugEnabled()) {
   logger.debug(
     "%s %s %s %s",
     request.getRemoteAddr(),
     request.getMethod(),
     request.getHttpURI().toString(),
     request.getProtocol()
   );
  }
 }
}

代码示例来源:origin: io.druid/druid-server

@Override
 public DruidCoordinatorRuntimeParams run(DruidCoordinatorRuntimeParams params)
 {
  log.info("Starting coordination. Getting available segments.");

  // Display info about all available segments
  final Set<DataSegment> availableSegments = coordinator.getOrderedAvailableDataSegments();
  if (log.isDebugEnabled()) {
   log.debug("Available DataSegments");
   for (DataSegment dataSegment : availableSegments) {
    log.debug("  %s", dataSegment);
   }
  }

  log.info("Found [%,d] available segments.", availableSegments.size());

  return params.buildFromExisting()
         .withAvailableSegments(availableSegments)
         .build();
 }
}

代码示例来源:origin: io.druid/java-util

@Override
public void channelDisconnected(ChannelHandlerContext context, ChannelStateEvent event) throws Exception
{
 if (log.isDebugEnabled()) {
  log.debug("[%s] Channel disconnected", requestDesc);
 }
 // response is non-null if we received initial chunk and then exception occurs
 if (response != null) {
  handler.exceptionCaught(response, new ChannelException("Channel disconnected"));
 }
 channel.close();
 channelResourceContainer.returnResource();
 if (!retVal.isDone()) {
  log.warn("[%s] Channel disconnected before response complete", requestDesc);
  retVal.setException(new ChannelException("Channel disconnected"));
 }
 context.sendUpstream(event);
}

代码示例来源:origin: io.druid/java-util

@Override
public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception
 if (log.isDebugEnabled()) {
  log.debug("[%s] messageReceived: %s", requestDesc, e.getMessage());
   if (log.isDebugEnabled()) {
    log.debug("[%s] Got response: %s", requestDesc, httpResponse.getStatus());
   if (log.isDebugEnabled()) {
    log.debug(
      "[%s] Got chunk: %sB, last=%s",

代码示例来源:origin: io.druid/java-util

@Override
public void exceptionCaught(ChannelHandlerContext context, ExceptionEvent event) throws Exception
{
 if (log.isDebugEnabled()) {
  final Throwable cause = event.getCause();
  if (cause == null) {
   log.debug("[%s] Caught exception", requestDesc);
  } else {
   log.debug(cause, "[%s] Caught exception", requestDesc);
  }
 }
 retVal.setException(event.getCause());
 // response is non-null if we received initial chunk and then exception occurs
 if (response != null) {
  handler.exceptionCaught(response, event.getCause());
 }
 removeHandlers();
 try {
  channel.close();
 }
 catch (Exception e) {
  // ignore
 }
 finally {
  channelResourceContainer.returnResource();
 }
 context.sendUpstream(event);
}

代码示例来源:origin: io.druid/java-util

if (log.isDebugEnabled()) {
 log.debug("[%s] starting", requestDesc);

相关文章