Package org.apache.accumulo.core.replication

Class ReplicationSchema.WorkSection

java.lang.Object

org.apache.accumulo.core.replication.ReplicationSchema.WorkSection

Enclosing class:

ReplicationSchema

public static class ReplicationSchema.WorkSection
extends Object

Portion of a file that must be replication to the given target: peer and some identifying location on that peer, e.g. remote table ID

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

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
WorkSection()

Method Summary

Modifier and Type	Method	Description
static Mutation	add(Mutation m, org.apache.hadoop.io.Text serializedTarget, Value v)
static void	getFile(Key k, org.apache.hadoop.io.Text buff)
static ReplicationTarget	getTarget(Key k, org.apache.hadoop.io.Text buff)
static void	limit(ScannerBase scanner)	Limit the scanner to only pull replication work 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

WorkSection

public WorkSection()

Method Detail

getFile

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

getTarget

public static ReplicationTarget getTarget(Key k,
                                          org.apache.hadoop.io.Text buff)

limit

public static void limit(ScannerBase scanner)

Limit the scanner to only pull replication work records

add

public static Mutation add(Mutation m,
                           org.apache.hadoop.io.Text serializedTarget,
                           Value v)