io.airlift.log.Logger.info()方法的使用及代码示例

x33g5p2x  于2022-01-23 转载在 其他  
字(9.8k)|赞(0)|评价(0)|浏览(332)

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

Logger.info介绍

[英]Logs a message at INFO level.
[中]在信息级别记录消息。

代码示例

代码示例来源：origin: prestodb/presto

  1. @VisibleForTesting
  2. protected void setConfiguredEventListener(String name, Map<String, String> properties)
  3. {
  4.   requireNonNull(name, "name is null");
  5.   requireNonNull(properties, "properties is null");
  6.   log.info("-- Loading event listener --");
  7.   EventListenerFactory eventListenerFactory = eventListenerFactories.get(name);
  8.   checkState(eventListenerFactory != null, "Event listener %s is not registered", name);
  9.   EventListener eventListener = eventListenerFactory.create(ImmutableMap.copyOf(properties));
  10.   this.configuredEventListener.set(Optional.of(eventListener));
  11.   log.info("-- Loaded event listener %s --", name);
  12. }

代码示例来源：origin: prestodb/presto

  1. @VisibleForTesting
  2. public void setConfigurationManager(String name, Map<String, String> properties)
  3. {
  4.   requireNonNull(name, "name is null");
  5.   requireNonNull(properties, "properties is null");
  6.   log.info("-- Loading resource group configuration manager --");
  7.   ResourceGroupConfigurationManagerFactory configurationManagerFactory = configurationManagerFactories.get(name);
  8.   checkState(configurationManagerFactory != null, "Resource group configuration manager %s is not registered", name);
  9.   ResourceGroupConfigurationManager<C> configurationManager = cast(configurationManagerFactory.create(ImmutableMap.copyOf(properties), configurationManagerContext));
  10.   checkState(this.configurationManager.compareAndSet(cast(legacyManager), configurationManager), "configurationManager already set");
  11.   log.info("-- Loaded resource group configuration manager %s --", name);
  12. }

代码示例来源：origin: prestodb/presto

  1. private synchronized void cleanUpExpiredTransactions()
  2. {
  3.   Iterator<Entry<TransactionId, TransactionMetadata>> iterator = transactions.entrySet().iterator();
  4.   while (iterator.hasNext()) {
  5.     Entry<TransactionId, TransactionMetadata> entry = iterator.next();
  6.     if (entry.getValue().isExpired(idleTimeout)) {
  7.       iterator.remove();
  8.       log.info("Removing expired transaction: %s", entry.getKey());
  9.       entry.getValue().asyncAbort();
  10.     }
  11.   }
  12. }

代码示例来源：origin: prestodb/presto

  1. private void loadPlugin(URLClassLoader pluginClassLoader)
  2. {
  3.   ServiceLoader<Plugin> serviceLoader = ServiceLoader.load(Plugin.class, pluginClassLoader);
  4.   List<Plugin> plugins = ImmutableList.copyOf(serviceLoader);
  5.   if (plugins.isEmpty()) {
  6.     log.warn("No service providers of type %s", Plugin.class.getName());
  7.   }
  8.   for (Plugin plugin : plugins) {
  9.     log.info("Installing %s", plugin.getClass().getName());
  10.     installPlugin(plugin);
  11.   }
  12. }

代码示例来源：origin: prestodb/presto

  1. private void loadPlugin(String plugin)
  2.     throws Exception
  3. {
  4.   log.info("-- Loading plugin %s --", plugin);
  5.   URLClassLoader pluginClassLoader = buildClassLoader(plugin);
  6.   try (ThreadContextClassLoader ignored = new ThreadContextClassLoader(pluginClassLoader)) {
  7.     loadPlugin(pluginClassLoader);
  8.   }
  9.   log.info("-- Finished loading plugin %s --", plugin);
  10. }

代码示例来源：origin: prestodb/presto

  1. @Override
  2. public void installPlugin(Plugin plugin)
  3. {
  4.   long start = System.nanoTime();
  5.   for (TestingPrestoServer server : servers) {
  6.     server.installPlugin(plugin);
  7.   }
  8.   log.info("Installed plugin %s in %s", plugin.getClass().getSimpleName(), nanosSince(start).convertToMostSuccinctTimeUnit());
  9. }

代码示例来源：origin: prestodb/presto

  1. public static void copyTable(QueryRunner queryRunner, QualifiedObjectName table, Session session)
  2.   {
  3.     long start = System.nanoTime();
  4.     log.info("Running import for %s", table.getObjectName());
  5.     @Language("SQL") String sql = format("CREATE TABLE %s AS SELECT * FROM %s", table.getObjectName(), table);
  6.     long rows = (Long) queryRunner.execute(session, sql).getMaterializedRows().get(0).getField(0);
  7.     log.info("Imported %s rows for %s in %s", rows, table.getObjectName(), nanosSince(start).convertToMostSuccinctTimeUnit());
  8.   }
  9. }

代码示例来源：origin: prestodb/presto

  1. private JedisPool createConsumer(HostAddress host)
  2.   {
  3.     log.info("Creating new JedisPool for %s", host);
  4.     return new JedisPool(jedisPoolConfig,
  5.         host.getHostText(),
  6.         host.getPort(),
  7.         toIntExact(redisConnectorConfig.getRedisConnectTimeout().toMillis()),
  8.         redisConnectorConfig.getRedisPassword(),
  9.         redisConnectorConfig.getRedisDataBaseIndex());
  10.   }
  11. }

代码示例来源：origin: prestodb/presto

  1. @AfterMethod
  2. public void tearDown(Method method)
  3. {
  4.   assertTrue(Futures.allAsList(futures).isDone(), "Expression test futures are not complete");
  5.   log.info("FINISHED %s in %s verified %s expressions", method.getName(), Duration.nanosSince(start), futures.size());
  6. }

代码示例来源：origin: prestodb/presto

  1. private static void checkConnectivity(CassandraSession session)
  2. {
  3.   ResultSet result = session.execute("SELECT release_version FROM system.local");
  4.   List<Row> rows = result.all();
  5.   assertEquals(rows.size(), 1);
  6.   String version = rows.get(0).getString(0);
  7.   log.info("Cassandra version: %s", version);
  8. }

代码示例来源：origin: prestodb/presto

  1. public static void main(String[] args)
  2.     throws Exception
  3. {
  4.   Logging.initialize();
  5.   Map<String, String> properties = ImmutableMap.of("http-server.http.port", "8080");
  6.   ThriftQueryRunnerWithServers queryRunner = (ThriftQueryRunnerWithServers) createThriftQueryRunner(3, 3, true, properties);
  7.   Thread.sleep(10);
  8.   Logger log = Logger.get(ThriftQueryRunner.class);
  9.   log.info("======== SERVER STARTED ========");
  10.   log.info("\n====\n%s\n====", queryRunner.getCoordinator().getBaseUrl());
  11. }

代码示例来源：origin: prestodb/presto

  1. public static void main(String[] args)
  2.       throws Exception
  3.   {
  4.     Logging.initialize();
  5.     DistributedQueryRunner queryRunner = createQueryRunner(ImmutableMap.of("http-server.http.port", "8080"));
  6.     Thread.sleep(10);
  7.     Logger log = Logger.get(BlackHoleQueryRunner.class);
  8.     log.info("======== SERVER STARTED ========");
  9.     log.info("\n====\n%s\n====", queryRunner.getCoordinator().getBaseUrl());
  10.   }
  11. }

代码示例来源：origin: prestodb/presto

  1. public static void main(String[] args)
  2.       throws Exception
  3.   {
  4.     Logging.initialize();
  5.     DistributedQueryRunner queryRunner = createQueryRunner(ImmutableMap.of("http-server.http.port", "8080"));
  6.     Thread.sleep(10);
  7.     Logger log = Logger.get(MemoryQueryRunner.class);
  8.     log.info("======== SERVER STARTED ========");
  9.     log.info("\n====\n%s\n====", queryRunner.getCoordinator().getBaseUrl());
  10.   }
  11. }

代码示例来源：origin: prestodb/presto

  1. public static void main(String[] args)
  2.       throws Exception
  3.   {
  4.     Logging.initialize();
  5.     DistributedQueryRunner queryRunner = createQueryRunner(ImmutableMap.of("http-server.http.port", "8080"));
  6.     Logger log = Logger.get(GeoQueryRunner.class);
  7.     log.info("======== SERVER STARTED ========");
  8.     log.info("\n====\n%s\n====", queryRunner.getCoordinator().getBaseUrl());
  9.   }
  10. }

代码示例来源：origin: prestodb/presto

  1. public static void main(String[] args)
  2.       throws Exception
  3.   {
  4.     // You need to add "--user user" to your CLI for your queries to work
  5.     Logging.initialize();
  6.     DistributedQueryRunner queryRunner = createQueryRunner(TpchTable.getTables(), ImmutableMap.of("http-server.http.port", "8080"));
  7.     Thread.sleep(10);
  8.     Logger log = Logger.get(DistributedQueryRunner.class);
  9.     log.info("======== SERVER STARTED ========");
  10.     log.info("\n====\n%s\n====", queryRunner.getCoordinator().getBaseUrl());
  11.   }
  12. }

代码示例来源：origin: prestodb/presto

  1. private static void loadTpchTopic(EmbeddedKafka embeddedKafka, TestingPrestoClient prestoClient, TpchTable<?> table)
  2. {
  3.   long start = System.nanoTime();
  4.   log.info("Running import for %s", table.getTableName());
  5.   TestUtils.loadTpchTopic(embeddedKafka, prestoClient, kafkaTopicName(table), new QualifiedObjectName("tpch", TINY_SCHEMA_NAME, table.getTableName().toLowerCase(ENGLISH)));
  6.   log.info("Imported %s in %s", 0, table.getTableName(), nanosSince(start).convertToMostSuccinctTimeUnit());
  7. }

代码示例来源：origin: prestodb/presto

  1. public static void main(String[] args)
  2.       throws Exception
  3.   {
  4.     Logging.initialize();
  5.     DistributedQueryRunner queryRunner = createElasticsearchQueryRunner(EmbeddedElasticsearchNode.createEmbeddedElasticsearchNode(), TpchTable.getTables());
  6.     Thread.sleep(10);
  7.     Logger log = Logger.get(ElasticsearchQueryRunner.class);
  8.     log.info("======== SERVER STARTED ========");
  9.     log.info("\n====\n%s\n====", queryRunner.getCoordinator().getBaseUrl());
  10.   }
  11. }

代码示例来源：origin: prestodb/presto

  1. private static void loadTpchTable(EmbeddedRedis embeddedRedis, TestingPrestoClient prestoClient, TpchTable<?> table, String dataFormat)
  2. {
  3.   long start = System.nanoTime();
  4.   log.info("Running import for %s", table.getTableName());
  5.   RedisTestUtils.loadTpchTable(
  6.       embeddedRedis,
  7.       prestoClient,
  8.       redisTableName(table),
  9.       new QualifiedObjectName("tpch", TINY_SCHEMA_NAME, table.getTableName().toLowerCase(ENGLISH)),
  10.       dataFormat);
  11.   log.info("Imported %s in %s", table.getTableName(), nanosSince(start).convertToMostSuccinctTimeUnit());
  12. }

代码示例来源：origin: prestodb/presto

  1. public static void main(String[] args)
  2.       throws Exception
  3.   {
  4.     Logging.initialize();
  5.     DistributedQueryRunner queryRunner = createKafkaQueryRunner(EmbeddedKafka.createEmbeddedKafka(), TpchTable.getTables());
  6.     Thread.sleep(10);
  7.     Logger log = Logger.get(KafkaQueryRunner.class);
  8.     log.info("======== SERVER STARTED ========");
  9.     log.info("\n====\n%s\n====", queryRunner.getCoordinator().getBaseUrl());
  10.   }
  11. }

代码示例来源：origin: prestodb/presto

  1. private static void loadTpchTopic(EmbeddedElasticsearchNode embeddedElasticsearchNode, TestingPrestoClient prestoClient, TpchTable<?> table)
  2. {
  3.   long start = System.nanoTime();
  4.   LOG.info("Running import for %s", table.getTableName());
  5.   ElasticsearchLoader loader = new ElasticsearchLoader(embeddedElasticsearchNode.getClient(), table.getTableName().toLowerCase(ENGLISH), prestoClient.getServer(), prestoClient.getDefaultSession());
  6.   loader.execute(format("SELECT * from %s", new QualifiedObjectName(TPCH_SCHEMA, TINY_SCHEMA_NAME, table.getTableName().toLowerCase(ENGLISH))));
  7.   LOG.info("Imported %s in %s", table.getTableName(), nanosSince(start).convertToMostSuccinctTimeUnit());
  8. }

内容来源于网络，如有侵权，请联系作者删除！

Logger

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com