com.alibaba.schedulerx.worker.logcollector

类 LogCollector

java.lang.Object

com.alibaba.schedulerx.worker.logcollector.LogCollector

直接已知子类:

DefaultLogCollector, SlsLogCollector

public abstract class LogCollector
extends Object

作者:

xiaomeng.hxm

字段概要

字段

限定符和类型	字段和说明
static char	END_OF_LOG

构造器概要

构造器

构造器和说明
LogCollector()

方法概要

限定符和类型	方法和说明
void	collect(String line, com.alibaba.schedulerx.common.domain.StreamType streamType, boolean isEnd)
void	collect(String key, String line)
void	collect(String key, String line, com.alibaba.schedulerx.common.domain.StreamType streamType, boolean isEnd)
void	collect(String key, String line, Throwable t)
abstract void	collect(String key, String line, Throwable t, com.alibaba.schedulerx.common.domain.StreamType streamType, boolean isEnd)
void	collectStderr(String line)
void	collectStderr(String line, boolean isEnd)
void	collectStdout(String line)
void	collectStdout(String line, boolean isEnd)
void	delete()
com.alibaba.schedulerx.common.domain.LogReadResult	readChars(long offset, int size, com.alibaba.schedulerx.common.domain.StreamType streamType)
List<String>	readLines(long lineOffset, int lineNumber, com.alibaba.schedulerx.common.domain.StreamType streamType)
List<String>	tailLines(int lineNumber, com.alibaba.schedulerx.common.domain.StreamType streamType)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

END_OF_LOG

public static char END_OF_LOG

构造器详细资料

LogCollector

public LogCollector()

方法详细资料

collectStdout

public void collectStdout(String line)

collectStderr

public void collectStderr(String line)

collectStdout

public void collectStdout(String line,
                          boolean isEnd)

collectStderr

public void collectStderr(String line,
                          boolean isEnd)

collect

public void collect(String key,
                    String line)

collect

public void collect(String key,
                    String line,
                    Throwable t)

collect

public void collect(String line,
                    com.alibaba.schedulerx.common.domain.StreamType streamType,
                    boolean isEnd)

collect

public void collect(String key,
                    String line,
                    com.alibaba.schedulerx.common.domain.StreamType streamType,
                    boolean isEnd)

collect

public abstract void collect(String key,
                             String line,
                             Throwable t,
                             com.alibaba.schedulerx.common.domain.StreamType streamType,
                             boolean isEnd)

readLines

public List<String> readLines(long lineOffset,
                              int lineNumber,
                              com.alibaba.schedulerx.common.domain.StreamType streamType)
                       throws IOException

抛出:

IOException

readChars

public com.alibaba.schedulerx.common.domain.LogReadResult readChars(long offset,
                                                                    int size,
                                                                    com.alibaba.schedulerx.common.domain.StreamType streamType)
                                                             throws IOException

抛出:

IOException

tailLines

public List<String> tailLines(int lineNumber,
                              com.alibaba.schedulerx.common.domain.StreamType streamType)
                       throws IOException

抛出:

IOException

delete

public void delete()
            throws IOException

抛出:

IOException