本文整理了Java中com.metamx.common.logger.Logger.info()
方法的一些代码示例,展示了Logger.info()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Logger.info()
方法的具体详情如下:
包路径:com.metamx.common.logger.Logger
类名称: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;
}
}
内容来源于网络,如有侵权,请联系作者删除!