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

Logger.info介绍

暂无

代码示例

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

public HybridCache(HybridCacheConfig config, Cache level1, Cache level2)
{
 this.config = config;
 log.info("Config: %s", config);
 this.level1 = level1;
 this.level2 = level2;
}

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

@Inject
public LocalDataSegmentPusher(LocalDataSegmentPusherConfig config, ObjectMapper jsonMapper)
{
 this.config = config;
 this.jsonMapper = jsonMapper;
 log.info("Configured local filesystem as deep storage");
}

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

@Override
 public void stop()
 {
  log.info("Stopping Curator");
  framework.close();
 }
}

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

@JsonCreator
public TwitterSpritzerFirehoseFactory(
  @JsonProperty("maxEventCount") Integer maxEventCount,
  @JsonProperty("maxRunMinutes") Integer maxRunMinutes
)
{
 this.maxEventCount = maxEventCount;
 this.maxRunMinutes = maxRunMinutes;
 log.info("maxEventCount=" + ((maxEventCount <= 0) ? "no limit" : maxEventCount));
 log.info("maxRunMinutes=" + ((maxRunMinutes <= 0) ? "no limit" : maxRunMinutes));
}

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

@Override
public void killAll() throws IOException
{
 log.info("Deleting all segment files from local dir [%s].", storageDirectory.getAbsolutePath());
 FileUtils.deleteDirectory(storageDirectory);
}

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

@Override
public void onSuccess(IIRCState aObject)
{
 log.info("irc connection to server [%s] established", host);
 for (String chan : channels) {
  log.info("Joining channel %s", chan);
  irc.joinChannel(chan);
 }
}

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

private DataSegment createDescriptorFile(DataSegment segment, File dest) throws IOException
 {
  log.info("Creating descriptor file at[%s]", dest);
  // Avoid using Guava in DataSegmentPushers because they might be used with very diverse Guava versions in
  // runtime, and because Guava deletes methods over time, that causes incompatibilities.
  Files.write(
    dest.toPath(), jsonMapper.writeValueAsBytes(segment), StandardOpenOption.CREATE, StandardOpenOption.SYNC
  );
  return segment;
 }
}

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

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

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

@Override
public boolean registerSegmentHandoffCallback(
  SegmentDescriptor descriptor, Executor exec, Runnable handOffRunnable
)
{
 log.info("Adding SegmentHandoffCallback for dataSource[%s] Segment[%s]", dataSource, descriptor);
 Pair<Executor, Runnable> prev = handOffCallbacks.putIfAbsent(
   descriptor,
   new Pair<>(exec, handOffRunnable)
 );
 return prev == null;
}

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

@Override
 public BufferRecycler get()
 {
  log.info("Allocating new bufferRecycler[%,d]", counter.incrementAndGet());
  return new BufferRecycler();
 }
}

代码示例来源：origin: io.druid/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: io.druid/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: io.druid/druid-integration-tests

public void testQueriesFromFile(String url, String filePath, int timesToRun) throws Exception
{
 LOG.info("Starting query tests for [%s]", filePath);
 List<QueryWithResults> queries =
   jsonMapper.readValue(
     TestQueryHelper.class.getResourceAsStream(filePath),
     new TypeReference<List<QueryWithResults>>()
     {
     }
   );
 testQueries(url, queries, timesToRun);
}

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

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

private boolean checkModuleClass(Class<?> moduleClass)
{
 String moduleClassName = moduleClass.getCanonicalName();
 if (moduleClassName != null && modulesConfig.getExcludeList().contains(moduleClassName)) {
  log.info("Not loading module [%s] because it is present in excludeList", moduleClassName);
  return false;
 }
 return true;
}

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

@Override
public void start()
{
 try {
  log.info("Starting Derby Metadata Storage");
  server.start(null);
 }
 catch (Exception e) {
  throw Throwables.propagate(e);
 }
}

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

@Override
 public void stop()
 {
  try {
   log.info("Stopping Jetty Server...");
   server.stop();
  }
  catch (Exception e) {
   log.warn(e, "Unable to stop Jetty server.");
  }
 }
}

代码示例来源：origin: io.druid/druid-indexing-service

@Override
public void killAll() throws IOException
{
 log.info("Deleting all task logs from local dir [%s].", config.getDirectory().getAbsolutePath());
 FileUtils.deleteDirectory(config.getDirectory());
}

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

@Override
 public void start() throws Exception
 {
  log.info("Poll the list of zookeeper servers for initial ensemble");
  this.pollForInitialEnsemble();
  super.start();
 }
};

代码示例来源：origin: io.druid/druid-indexing-service

@LifecycleStop
public void stop() throws Exception
{
 log.info("Stopping WorkerCuratorCoordinator for worker[%s]", worker.getHost());
 synchronized (lock) {
  if (!started) {
   return;
  }
  announcer.stop();
  started = false;
 }
}