com.metamx.common.logger.Logger.info()方法的使用及代码示例

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

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

Logger.info介绍

暂无

代码示例

代码示例来源:origin: com.metamx/server-metrics

@Override
 public boolean doMonitor(ServiceEmitter emitter)
 {
  log.info("I am watching...");
  return true;
 }
}

代码示例来源:origin: com.metamx/java-util

@Override
public void start() throws Exception
{
 log.info("Starting object[%s]", o);
 startMethod.invoke(o);
}

代码示例来源:origin: metamx/java-util

@Override
public void start() throws Exception
{
 log.info("Starting object[%s]", o);
 startMethod.invoke(o);
}

代码示例来源:origin: com.n3twork.druid/druid-processing

@Override
 public ByteBuffer get()
 {
  log.info("Allocating new littleEndByteBuf[%,d]", counter.incrementAndGet());
  return ByteBuffer.allocateDirect(0xFFFF).order(ByteOrder.LITTLE_ENDIAN);
 }
}

代码示例来源:origin: com.n3twork.druid/druid-processing

@Override
 public ByteBuffer get()
 {
  log.info("Allocating new bigEndByteBuf[%,d]", counter.incrementAndGet());
  return ByteBuffer.allocateDirect(0xFFFF).order(ByteOrder.BIG_ENDIAN);
 }
}

代码示例来源:origin: com.metamx/java-util

@Override
public void start() throws Exception
{
 for (Method method : o.getClass().getMethods()) {
  if (method.getAnnotation(LifecycleStart.class) != null) {
   log.info("Invoking start method[%s] on object[%s].", method, o);
   method.invoke(o);
  }
 }
}

代码示例来源:origin: com.metamx/java-util

@Override
@LifecycleStart
public void start()
{
 log.info("Starting Composing Emitter.");
 for (Emitter e : emitters) {
  log.info("Starting emitter %s.", e.getClass().getName());
  e.start();
 }
}

代码示例来源:origin: com.metamx/emitter

@Override
@LifecycleStart
public void start()
{
 log.info("Starting Composing Emitter.");
 for (Emitter e : emitters) {
  log.info("Starting emitter %s.", e.getClass().getName());
  e.start();
 }
}

代码示例来源:origin: com.n3twork.druid/druid-indexing-hadoop

@Override
 public Job addInputPaths(HadoopDruidIndexerConfig config, Job job) throws IOException
 {
  log.info("Adding paths[%s]", paths);
  FileInputFormat.addInputPaths(job, paths);
  return job;
 }
}

代码示例来源:origin: com.metamx/java-util

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

private void createPath(String parentPath)
 {
  try {
   curator.create().creatingParentsIfNeeded().forPath(parentPath);
   parentsIBuilt.add(parentPath);
  }
  catch (Exception e) {
   log.info(e, "Problem creating parentPath[%s], someone else created it first?", parentPath);
  }
 }
}

代码示例来源:origin: metamx/java-util

@Override
@LifecycleStart
public void start()
{
 log.info("Starting Composing Emitter.");
 for (Emitter e : emitters) {
  log.info("Starting emitter %s.", e.getClass().getName());
  e.start();
 }
}

代码示例来源:origin: com.n3twork.druid/druid-indexing-service

@Override
 public TaskStatus run(TaskToolbox toolbox) throws Exception
 {
  log.info("Subs are good!  Italian BMT and Meatball are probably my favorite.");
  convertSegment(toolbox, segment);
  return success();
 }
}

代码示例来源:origin: metamx/java-util

@Override
 public void run()
 {
  log.info("Running shutdown hook");
  stop();
 }
}

代码示例来源:origin: com.n3twork.druid/druid-common

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: com.n3twork.druid/druid-indexing-service

@Override
public void pushTaskLog(final String taskid, File file) throws IOException
{
 if (!config.getDirectory().exists()) {
  config.getDirectory().mkdir();
 }
 final File outputFile = fileForTask(taskid);
 Files.copy(file, outputFile);
 log.info("Wrote task log to: %s", outputFile);
}

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

@Override
 public void close() throws IOException
 {
  log.info("Closing connection to RabbitMQ");
  channel.close();
  connection.close();
 }
};

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

@LifecycleStop
public void stop()
{
 synchronized (lock) {
  if (!started) {
   return;
  }
  log.info("Stopping %s with config[%s]", getClass(), config);
  announcer.unannounce(makeAnnouncementPath());
  started = false;
 }
}

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

public void unannounceSegment(DataSegment segment) throws IOException
{
 final String path = makeServedSegmentPath(segment);
 log.info("Unannouncing segment[%s] at path[%s]", segment.getIdentifier(), path);
 announcer.unannounce(path);
}

代码示例来源:origin: com.n3twork.druid/druid-indexing-service

@Override
 public Task apply(DataSegment segment)
 {
  final Integer segmentVersion = segment.getBinaryVersion();
  if (!CURR_VERSION_INTEGER.equals(segmentVersion)) {
   return new SubTask(getGroupId(), segment);
  }
  log.info("Skipping[%s], already version[%s]", segment.getIdentifier(), segmentVersion);
  return null;
 }
}

相关文章