Package org.apache.accumulo.core.replication

Class ReplicationSchema.StatusSection

java.lang.Object

org.apache.accumulo.core.replication.ReplicationSchema.StatusSection

Enclosing class:

ReplicationSchema

public static class ReplicationSchema.StatusSection
extends Object

Holds replication markers tracking status for files

 
 hdfs://localhost:8020/accumulo/wal/tserver+port/WAL repl:local_table_id []
  -> Status Protobuf
 
 

Field Summary

Fields

Modifier and Type	Field	Description
static org.apache.hadoop.io.Text	NAME

Constructor Summary

Constructors

Constructor	Description
StatusSection()

Method Summary

Modifier and Type	Method	Description
static Mutation	add(Mutation m, TableId tableId, Value v)
static void	getFile(Key k, org.apache.hadoop.io.Text buff)	Extract the file name from the row suffix into the given Text
static TableId	getTableId(Key k)	Extract the table ID from the key (inefficiently if called repeatedly)
static void	limit(ScannerBase scanner)	Limit the scanner to only return Status records

Methods inherited from class java.lang.Object

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

Field Detail

NAME

public static final org.apache.hadoop.io.Text NAME

Constructor Detail

StatusSection

public StatusSection()

Method Detail

getTableId

public static TableId getTableId(Key k)

Extract the table ID from the key (inefficiently if called repeatedly)

Parameters:

k - Key to extract from

Returns:

The table ID

getFile

public static void getFile(Key k,
                           org.apache.hadoop.io.Text buff)

Extract the file name from the row suffix into the given Text

Parameters:

k - Key to extract from

buff - Text to place file name into

limit

public static void limit(ScannerBase scanner)

Limit the scanner to only return Status records

add

public static Mutation add(Mutation m,
                           TableId tableId,
                           Value v)