Java 类org.apache.hadoop.hdfs.server.namenode.FSEditLogOp.Writer 实例源码

项目：hadoop 文件：BookKeeperEditLogOutputStream.java

/**
 * Construct an edit log output stream which writes to a ledger.

 */
protected BookKeeperEditLogOutputStream(Configuration conf, LedgerHandle lh)
    throws IOException {
  super();

  bufCurrent = new DataOutputBuffer();
  outstandingRequests = new AtomicInteger(0);
  syncLatch = null;
  this.lh = lh;
  this.writer = new Writer(bufCurrent);
  this.transmissionThreshold
    = conf.getInt(BookKeeperJournalManager.BKJM_OUTPUT_BUFFER_SIZE,
                  BookKeeperJournalManager.BKJM_OUTPUT_BUFFER_SIZE_DEFAULT);
}

项目：aliyun-oss-hadoop-fs 文件：BookKeeperEditLogOutputStream.java

/**
 * Construct an edit log output stream which writes to a ledger.

 */
protected BookKeeperEditLogOutputStream(Configuration conf, LedgerHandle lh)
    throws IOException {
  super();

  bufCurrent = new DataOutputBuffer();
  outstandingRequests = new AtomicInteger(0);
  syncLatch = null;
  this.lh = lh;
  this.writer = new Writer(bufCurrent);
  this.transmissionThreshold
    = conf.getInt(BookKeeperJournalManager.BKJM_OUTPUT_BUFFER_SIZE,
                  BookKeeperJournalManager.BKJM_OUTPUT_BUFFER_SIZE_DEFAULT);
}

项目：big-c 文件：BookKeeperEditLogOutputStream.java

/**
 * Construct an edit log output stream which writes to a ledger.

 */
protected BookKeeperEditLogOutputStream(Configuration conf, LedgerHandle lh)
    throws IOException {
  super();

  bufCurrent = new DataOutputBuffer();
  outstandingRequests = new AtomicInteger(0);
  syncLatch = null;
  this.lh = lh;
  this.writer = new Writer(bufCurrent);
  this.transmissionThreshold
    = conf.getInt(BookKeeperJournalManager.BKJM_OUTPUT_BUFFER_SIZE,
                  BookKeeperJournalManager.BKJM_OUTPUT_BUFFER_SIZE_DEFAULT);
}

项目：hadoop-2.6.0-cdh5.4.3 文件：BookKeeperEditLogOutputStream.java

/**
 * Construct an edit log output stream which writes to a ledger.

 */
protected BookKeeperEditLogOutputStream(Configuration conf, LedgerHandle lh)
    throws IOException {
  super();

  bufCurrent = new DataOutputBuffer();
  outstandingRequests = new AtomicInteger(0);
  syncLatch = null;
  this.lh = lh;
  this.writer = new Writer(bufCurrent);
  this.transmissionThreshold
    = conf.getInt(BookKeeperJournalManager.BKJM_OUTPUT_BUFFER_SIZE,
                  BookKeeperJournalManager.BKJM_OUTPUT_BUFFER_SIZE_DEFAULT);
}

项目：hadoop-EAR 文件：JournalSet.java

@Override
public void write(final FSEditLogOp op)
    throws IOException {    
  // serialize operation first
  Writer.writeOp(op, tempWriteBuffer);
  writeRawOp(tempWriteBuffer.getBytes(), 0, tempWriteBuffer.size(), op.txid);
}

项目：hadoop-plus 文件：BookKeeperEditLogOutputStream.java

/**
 * Construct an edit log output stream which writes to a ledger.

 */
protected BookKeeperEditLogOutputStream(Configuration conf, LedgerHandle lh)
    throws IOException {
  super();

  bufCurrent = new DataOutputBuffer();
  outstandingRequests = new AtomicInteger(0);
  syncLatch = null;
  this.lh = lh;
  this.writer = new Writer(bufCurrent);
  this.transmissionThreshold
    = conf.getInt(BookKeeperJournalManager.BKJM_OUTPUT_BUFFER_SIZE,
                  BookKeeperJournalManager.BKJM_OUTPUT_BUFFER_SIZE_DEFAULT);
}

项目：FlexMap 文件：BookKeeperEditLogOutputStream.java

/**
 * Construct an edit log output stream which writes to a ledger.

 */
protected BookKeeperEditLogOutputStream(Configuration conf, LedgerHandle lh)
    throws IOException {
  super();

  bufCurrent = new DataOutputBuffer();
  outstandingRequests = new AtomicInteger(0);
  syncLatch = null;
  this.lh = lh;
  this.writer = new Writer(bufCurrent);
  this.transmissionThreshold
    = conf.getInt(BookKeeperJournalManager.BKJM_OUTPUT_BUFFER_SIZE,
                  BookKeeperJournalManager.BKJM_OUTPUT_BUFFER_SIZE_DEFAULT);
}

项目：hadoop-TCP 文件：BookKeeperEditLogOutputStream.java

/**
 * Construct an edit log output stream which writes to a ledger.

 */
protected BookKeeperEditLogOutputStream(Configuration conf, LedgerHandle lh)
    throws IOException {
  super();

  bufCurrent = new DataOutputBuffer();
  outstandingRequests = new AtomicInteger(0);
  syncLatch = null;
  this.lh = lh;
  this.writer = new Writer(bufCurrent);
  this.transmissionThreshold
    = conf.getInt(BookKeeperJournalManager.BKJM_OUTPUT_BUFFER_SIZE,
                  BookKeeperJournalManager.BKJM_OUTPUT_BUFFER_SIZE_DEFAULT);
}

项目：hardfs 文件：BookKeeperEditLogOutputStream.java

/**
 * Construct an edit log output stream which writes to a ledger.

 */
protected BookKeeperEditLogOutputStream(Configuration conf, LedgerHandle lh)
    throws IOException {
  super();

  bufCurrent = new DataOutputBuffer();
  outstandingRequests = new AtomicInteger(0);
  syncLatch = null;
  this.lh = lh;
  this.writer = new Writer(bufCurrent);
  this.transmissionThreshold
    = conf.getInt(BookKeeperJournalManager.BKJM_OUTPUT_BUFFER_SIZE,
                  BookKeeperJournalManager.BKJM_OUTPUT_BUFFER_SIZE_DEFAULT);
}

项目：hadoop-on-lustre2 文件：BookKeeperEditLogOutputStream.java

/**
 * Construct an edit log output stream which writes to a ledger.

 */
protected BookKeeperEditLogOutputStream(Configuration conf, LedgerHandle lh)
    throws IOException {
  super();

  bufCurrent = new DataOutputBuffer();
  outstandingRequests = new AtomicInteger(0);
  syncLatch = null;
  this.lh = lh;
  this.writer = new Writer(bufCurrent);
  this.transmissionThreshold
    = conf.getInt(BookKeeperJournalManager.BKJM_OUTPUT_BUFFER_SIZE,
                  BookKeeperJournalManager.BKJM_OUTPUT_BUFFER_SIZE_DEFAULT);
}

项目：hadoop 文件：EditsDoubleBuffer.java

public TxnBuffer(int initBufferSize) {
  super(initBufferSize);
  writer = new FSEditLogOp.Writer(this);
  reset();
}

项目：aliyun-oss-hadoop-fs 文件：EditsDoubleBuffer.java

public TxnBuffer(int initBufferSize) {
  super(initBufferSize);
  writer = new FSEditLogOp.Writer(this);
  reset();
}

项目：big-c 文件：EditsDoubleBuffer.java

public TxnBuffer(int initBufferSize) {
  super(initBufferSize);
  writer = new FSEditLogOp.Writer(this);
  reset();
}

项目：hadoop-2.6.0-cdh5.4.3 文件：EditsDoubleBuffer.java

public TxnBuffer(int initBufferSize) {
  super(initBufferSize);
  writer = new FSEditLogOp.Writer(this);
  reset();
}

项目：hadoop-EAR 文件：EditsDoubleBuffer.java

public TxnBuffer(int initBufferSize) {
  super(initBufferSize);
  writer = new FSEditLogOp.Writer(this);
  reset();
}

项目：hadoop-plus 文件：EditsDoubleBuffer.java

public TxnBuffer(int initBufferSize) {
  super(initBufferSize);
  writer = new FSEditLogOp.Writer(this);
  reset();
}

项目：FlexMap 文件：EditsDoubleBuffer.java

public TxnBuffer(int initBufferSize) {
  super(initBufferSize);
  writer = new FSEditLogOp.Writer(this);
  reset();
}

项目：hadoop-TCP 文件：EditsDoubleBuffer.java

public TxnBuffer(int initBufferSize) {
  super(initBufferSize);
  writer = new FSEditLogOp.Writer(this);
  reset();
}

项目：hardfs 文件：EditsDoubleBuffer.java

public TxnBuffer(int initBufferSize) {
  super(initBufferSize);
  writer = new FSEditLogOp.Writer(this);
  reset();
}

项目：hadoop-on-lustre2 文件：EditsDoubleBuffer.java

public TxnBuffer(int initBufferSize) {
  super(initBufferSize);
  writer = new FSEditLogOp.Writer(this);
  reset();
}

项目：RDFS 文件：EditsDoubleBuffer.java

public TxnBuffer(int initBufferSize) {
  super(initBufferSize);
  writer = new FSEditLogOp.Writer(this);
  reset();
}