本文整理了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
暂无
代码示例来源: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);
内容来源于网络,如有侵权,请联系作者删除!