com.taobao.tddl.dbsync.binlog

类 FileLogFetcher

java.lang.Object

com.taobao.tddl.dbsync.binlog.LogBuffer

com.taobao.tddl.dbsync.binlog.LogFetcher

com.taobao.tddl.dbsync.binlog.FileLogFetcher

所有已实现的接口:

java.io.Closeable, java.lang.AutoCloseable

public final class FileLogFetcher
extends LogFetcher

TODO: Document It!!

 FileLogFetcher fetcher = new FileLogFetcher();
 fetcher.open(file, 0);
 
 while (fetcher.fetch()) {
     LogEvent event;
     do {
         event = decoder.decode(fetcher, context);
 
         // process log event.
     } while (event != null);
 }
 // file ending reached.
 

版本:

1.0

作者:

Changyuan.lh

字段概要

字段

限定符和类型	字段和说明
static byte[]	BINLOG_MAGIC

从类继承的字段 com.taobao.tddl.dbsync.binlog.LogFetcher

BIN_LOG_HEADER_SIZE, DEFAULT_GROWTH_FACTOR, DEFAULT_INITIAL_CAPACITY, factor

从类继承的字段 com.taobao.tddl.dbsync.binlog.LogBuffer

BIGINT_MAX_VALUE, buffer, DIG_BASE, DIG_MAX, DIG_PER_DEC1, DIG_PER_INT32, dig2bytes, ISO_8859_1, limit, NULL_LENGTH, origin, position, powers10, semival, SIZE_OF_INT32

构造器概要

构造器

构造器和说明
FileLogFetcher()
FileLogFetcher(int initialCapacity)
FileLogFetcher(int initialCapacity, float growthFactor)

方法概要

限定符和类型	方法和说明
void	close()
boolean	fetch() Fetches the next frame of binary-log, and fill it in buffer.
void	open(java.io.File file) Open binlog file in local disk to fetch.
void	open(java.io.File file, long filePosition) Open binlog file in local disk to fetch.
void	open(java.lang.String filePath) Open binlog file in local disk to fetch.
void	open(java.lang.String filePath, long filePosition) Open binlog file in local disk to fetch.

从类继承的方法 com.taobao.tddl.dbsync.binlog.LogFetcher

ensureCapacity

从类继承的方法 com.taobao.tddl.dbsync.binlog.LogBuffer

capacity, consume, duplicate, duplicate, duplicate, fillBitmap, fillBitmap, fillBytes, fillBytes, fillOutput, fillOutput, forward, getBeInt16, getBeInt16, getBeInt24, getBeInt24, getBeInt32, getBeInt32, getBeLong48, getBeLong48, getBeLong64, getBeLong64, getBeUint16, getBeUint16, getBeUint24, getBeUint24, getBeUint32, getBeUint32, getBeUlong40, getBeUlong40, getBeUlong48, getBeUlong48, getBeUlong56, getBeUlong56, getBeUlong64, getBeUlong64, getBitmap, getBitmap, getData, getData, getData, getDecimal, getDecimal, getDouble64, getDouble64, getFixString, getFixString, getFixString, getFixString, getFloat32, getFloat32, getFullString, getFullString, getInt16, getInt16, getInt24, getInt24, getInt32, getInt32, getInt8, getInt8, getLong48, getLong48, getLong64, getLong64, getPackedLong, getPackedLong, getString, getString, getString, getString, getUint16, getUint16, getUint24, getUint24, getUint32, getUint32, getUint8, getUint8, getUlong40, getUlong40, getUlong48, getUlong48, getUlong56, getUlong56, getUlong64, getUlong64, hasRemaining, hexdump, hexdump, limit, limit, position, position, remaining, rewind

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

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

字段详细资料

BINLOG_MAGIC

public static final byte[] BINLOG_MAGIC

构造器详细资料

FileLogFetcher

public FileLogFetcher()

FileLogFetcher

public FileLogFetcher(int initialCapacity)

FileLogFetcher

public FileLogFetcher(int initialCapacity,
                      float growthFactor)

方法详细资料

open

public void open(java.io.File file)
          throws java.io.FileNotFoundException,
                 java.io.IOException

Open binlog file in local disk to fetch.

抛出:

java.io.FileNotFoundException

java.io.IOException

open

public void open(java.lang.String filePath)
          throws java.io.FileNotFoundException,
                 java.io.IOException

Open binlog file in local disk to fetch.

抛出:

java.io.FileNotFoundException

java.io.IOException

open

public void open(java.lang.String filePath,
                 long filePosition)
          throws java.io.FileNotFoundException,
                 java.io.IOException

Open binlog file in local disk to fetch.

抛出:

java.io.FileNotFoundException

java.io.IOException

open

public void open(java.io.File file,
                 long filePosition)
          throws java.io.FileNotFoundException,
                 java.io.IOException

Open binlog file in local disk to fetch.

抛出:

java.io.FileNotFoundException

java.io.IOException

fetch

public boolean fetch()
              throws java.io.IOException

Fetches the next frame of binary-log, and fill it in buffer.

指定者:

fetch 在类中 LogFetcher

抛出:

java.io.IOException

另请参阅:

LogFetcher.fetch()

close

public void close()
           throws java.io.IOException

指定者:

close 在接口中 java.io.Closeable

指定者:

close 在接口中 java.lang.AutoCloseable

指定者:

close 在类中 LogFetcher

抛出:

java.io.IOException

另请参阅:

LogFetcher.close()