Field Detail

• sinkWriter

  private final RegionReplicaReplicationEndpoint.RegionReplicaSinkWriter sinkWriter

• tableDescriptors

  private final TableDescriptors tableDescriptors

• memstoreReplicationEnabled

  private final com.google.common.cache.Cache<TableName,Boolean> memstoreReplicationEnabled

Constructor Detail

• RegionReplicaReplicationEndpoint.RegionReplicaOutputSink

  public RegionReplicaReplicationEndpoint.RegionReplicaOutputSink(WALSplitter.PipelineController controller,
                                                          TableDescriptors tableDescriptors,
                                                          WALSplitter.EntryBuffers entryBuffers,
                                                          ClusterConnection connection,
                                                          ExecutorService pool,
                                                          int numWriters,
                                                          int operationTimeout)

Method Detail

• append

  public void append(WALSplitter.RegionEntryBuffer buffer)
              throws IOException

  Specified by:

  append in class WALSplitter.OutputSink

  Parameters:

  buffer - A WAL Edit Entry

  Throws:

  IOException

• flush

  public boolean flush()
                throws IOException

  Description copied from class: WALSplitter.OutputSink
  WriterThread call this function to help flush internal remaining edits in buffer before close

  Overrides:

  flush in class WALSplitter.OutputSink

  Returns:

  true when underlying sink has something to flush

  Throws:

  IOException

• keepRegionEvent

  public boolean keepRegionEvent(WAL.Entry entry)

  Description copied from class: WALSplitter.OutputSink
  Some WALEdit's contain only KV's for account on what happened to a region. Not all sinks will want to get all of those edits.

  Specified by:

  keepRegionEvent in class WALSplitter.OutputSink

  Returns:

  Return true if this sink wants to accept this region-level WALEdit.

• finishWritingAndClose

  public List<org.apache.hadoop.fs.Path> finishWritingAndClose()
                                                        throws IOException

  Specified by:

  finishWritingAndClose in class WALSplitter.OutputSink

  Throws:

  IOException

• getOutputCounts

  public Map<byte[],Long> getOutputCounts()

  Specified by:

  getOutputCounts in class WALSplitter.OutputSink

  Returns:

  a map from encoded region ID to the number of edits written out for that region.

• getNumberOfRecoveredRegions

  public int getNumberOfRecoveredRegions()

  Specified by:

  getNumberOfRecoveredRegions in class WALSplitter.OutputSink

  Returns:

  number of regions we've recovered

• getSkippedEditsCounter

  AtomicLong getSkippedEditsCounter()

• requiresReplication

  private boolean requiresReplication(TableName tableName,
                            List<WAL.Entry> entries)
                               throws IOException

  returns true if the specified entry must be replicated. We should always replicate meta operations (e.g. flush) and use the user HTD flag to decide whether or not replicate the memstore.

  Throws:

  IOException