本文整理了Java中org.apache.druid.java.util.common.logger.Logger
类的一些代码示例,展示了Logger
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Logger
类的具体详情如下:
包路径:org.apache.druid.java.util.common.logger.Logger
类名称:Logger
暂无
代码示例来源:origin: apache/incubator-druid
@Override
public void killAll()
{
log.info("Noop: No task logs are deleted.");
}
代码示例来源:origin: apache/incubator-druid
@Override
public void shutdownCompleted(ShutdownSignalException cause)
{
log.warn(cause, "Channel closed!");
}
}
代码示例来源:origin: apache/incubator-druid
@Override
public void onException(Exception ex)
{
log.error(ex, "Got exception");
}
代码示例来源: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
public void unregister(String serviceName)
{
log.info("Unregistering EventReceiverFirehoseMetric for service [%s]", serviceName);
if (metrics.remove(serviceName) == null) {
log.warn("Unregistering a non-exist service. Service [%s] never exists.", serviceName);
}
}
}
代码示例来源:origin: apache/incubator-druid
@Override
public void stop()
{
log.info("Closing object[%s]", o);
try {
o.close();
}
catch (Exception e) {
log.error(e, "Exception when closing object [%s]", o);
}
}
}
代码示例来源:origin: apache/incubator-druid
@Override
public void removeHistogram(String name)
{
log.debug("Ignoring remove histogram [%s]", name);
}
代码示例来源:origin: apache/incubator-druid
@Override
public void close()
{
long mergeBufferTotalSize = 0;
for (Pair<ByteBuffer, Integer> bufferAllocation : directBufferAllocations) {
log.debug("Freeing dictionary merging direct buffer with size[%,d]", bufferAllocation.rhs);
mergeBufferTotalSize += bufferAllocation.rhs;
ByteBufferUtils.free(bufferAllocation.lhs);
}
log.info("Freed [%,d] bytes of dictionary merging direct buffers", mergeBufferTotalSize);
}
}
代码示例来源:origin: apache/incubator-druid
@SuppressWarnings("MalformedFormatString")
@Test
public void testLegacyLogging()
{
final Logger log = new Logger(LoggerTest.class);
final Throwable throwable = new Throwable();
// These should show up in an IDE as deprecated, but shouldn't actually fail.
log.error("foo", throwable);
log.warn("foo", throwable);
}
}
代码示例来源: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!");
}
}
}
代码示例来源:origin: apache/incubator-druid
@SuppressWarnings("MalformedFormatString")
@Test
public void testLogWithCrazyMessages()
{
final String message = "this % might %d kill %*.s the %s parser";
final Logger log = new Logger(LoggerTest.class);
log.warn(message);
}
代码示例来源:origin: apache/incubator-druid
public LoggingEmitter(LoggingEmitterConfig config, ObjectMapper jsonMapper)
{
this(new Logger(config.getLoggerClass()), Level.toLevel(config.getLogLevel()), jsonMapper);
}
代码示例来源:origin: apache/incubator-druid
@Override
public void stop()
{
log.info("Stopping object[%s]", o);
try {
stopMethod.invoke(o);
}
catch (Exception e) {
log.error(e, "Unable to invoke stopMethod() on %s", o.getClass());
}
}
}
代码示例来源:origin: apache/incubator-druid
private void poll()
{
for (Map.Entry<String, ConfigHolder> entry : watchedConfigs.entrySet()) {
try {
if (entry.getValue().swapIfNew(dbConnector.lookup(configTable, "name", "payload", entry.getKey()))) {
log.info("New value for key[%s] seen.", entry.getKey());
}
}
catch (Exception e) {
log.warn(e, "Exception when checking property[%s]", entry.getKey());
}
}
}
代码示例来源:origin: apache/incubator-druid
@Override
public void removeMeter(String name)
{
if (!interesting.apply(name)) {
return;
}
if (log.isDebugEnabled()) {
log.debug("Ignoring request to remove meter [%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 pushTaskLog(String taskid, File logFile)
{
log.info("Not pushing logs for task: %s", taskid);
}
代码示例来源:origin: apache/incubator-druid
@Override
public void abortTask(TaskAttemptContext taskContext)
{
log.warn("Aborting task. Nothing to clean up.");
}
};
代码示例来源:origin: apache/incubator-druid
@Override
public void exceptionCaught(ClientResponse<StatusResponseHolder> clientResponse, Throwable e)
{
// Its safe to Ignore as the ClientResponse returned in handleChunk were unfinished
log.error(e, "exceptionCaught in CommonCacheNotifier ResponseHandler.");
}
}
代码示例来源:origin: apache/incubator-druid
private void deleteAllSegmentFiles(Injector injector)
{
try {
log.info("===========================================================================");
log.info("Deleting all Segment Files.");
log.info("===========================================================================");
DataSegmentKiller segmentKiller = injector.getInstance(DataSegmentKiller.class);
segmentKiller.killAll();
}
catch (Exception ex) {
log.error(ex, "Failed to cleanup Segment Files.");
}
}
内容来源于网络,如有侵权,请联系作者删除!