Uses of Class
org.apache.accumulo.server.replication.proto.Replication.Status

Packages that use Replication.Status

Package	Description
org.apache.accumulo.server.replication
org.apache.accumulo.server.replication.proto
org.apache.accumulo.server.util

Uses of Replication.Status in org.apache.accumulo.server.replication

Methods in org.apache.accumulo.server.replication that return Replication.Status

Modifier and Type	Method and Description
Replication.Status	StatusCombiner.StatusEncoder.decode(byte[] b)
protected Replication.Status	StatusCombiner.StatusEncoder.decodeUnchecked(byte[] b, int offset, int len)
static Replication.Status	StatusUtil.fileClosed()
static Replication.Status	StatusUtil.fileCreated(long timeCreated)
static Replication.Status	StatusUtil.fromValue(Value v)
static Replication.Status	StatusUtil.ingestedUntil(long recordsIngested) Creates a Replication.Status for newly-created data that must be replicated
static Replication.Status	StatusUtil.ingestedUntil(Replication.Status.Builder builder, long recordsIngested)
static Replication.Status	StatusUtil.openWithUnknownLength()
static Replication.Status	StatusUtil.openWithUnknownLength(long timeCreated)
Replication.Status	ReplicaSystem.replicate(org.apache.hadoop.fs.Path p, Replication.Status status, ReplicationTarget target, ReplicaSystemHelper helper) Replicate the given status to the target peer
static Replication.Status	StatusUtil.replicated(long recordsReplicated)
static Replication.Status	StatusUtil.replicated(Replication.Status.Builder builder, long recordsReplicated)
static Replication.Status	StatusUtil.replicatedAndIngested(long recordsReplicated, long recordsIngested) Creates a @{link Status} for a file which has new data and data which has been replicated
static Replication.Status	StatusUtil.replicatedAndIngested(Replication.Status.Builder builder, long recordsReplicated, long recordsIngested) Same as StatusUtil.replicatedAndIngested(long, long) but uses the provided Replication.Status.Builder
Replication.Status	StatusCombiner.typedReduce(Key key, Iterator<Replication.Status> iter)

Methods in org.apache.accumulo.server.replication with parameters of type Replication.Status

Modifier and Type	Method and Description
void	StatusCombiner.combine(Replication.Status.Builder combined, Replication.Status status) Update a Replication.Status.Builder with another Replication.Status
byte[]	StatusCombiner.StatusEncoder.encode(Replication.Status v)
String	StatusFormatter.formatEntry(Key key, Replication.Status status, DateFormat timestampFormat)
static boolean	StatusUtil.isFullyReplicated(Replication.Status status) Is the given Status fully replicated but potentially not yet safe for deletion
static boolean	StatusUtil.isSafeForRemoval(Replication.Status status) Is the given Status fully replicated and is its file ready for deletion on the source
static boolean	StatusUtil.isWorkRequired(Replication.Status status) Given the Replication.Status, is there replication work to be done
void	ReplicaSystemHelper.recordNewStatus(org.apache.hadoop.fs.Path filePath, Replication.Status status, ReplicationTarget target) Record the updated Status for this file and target
Replication.Status	ReplicaSystem.replicate(org.apache.hadoop.fs.Path p, Replication.Status status, ReplicationTarget target, ReplicaSystemHelper helper) Replicate the given status to the target peer

Method parameters in org.apache.accumulo.server.replication with type arguments of type Replication.Status

Modifier and Type	Method and Description
Replication.Status	StatusCombiner.typedReduce(Key key, Iterator<Replication.Status> iter)

Uses of Replication.Status in org.apache.accumulo.server.replication.proto

Fields in org.apache.accumulo.server.replication.proto with type parameters of type Replication.Status

Modifier and Type	Field and Description
static com.google.protobuf.Parser<Replication.Status>	Replication.Status.PARSER

Methods in org.apache.accumulo.server.replication.proto that return Replication.Status

Modifier and Type	Method and Description
Replication.Status	Replication.Status.Builder.build()
Replication.Status	Replication.Status.Builder.buildPartial()
static Replication.Status	Replication.Status.getDefaultInstance()
Replication.Status	Replication.Status.getDefaultInstanceForType()
Replication.Status	Replication.Status.Builder.getDefaultInstanceForType()
static Replication.Status	Replication.Status.parseDelimitedFrom(InputStream input)
static Replication.Status	Replication.Status.parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Replication.Status	Replication.Status.parseFrom(byte[] data)
static Replication.Status	Replication.Status.parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Replication.Status	Replication.Status.parseFrom(com.google.protobuf.ByteString data)
static Replication.Status	Replication.Status.parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Replication.Status	Replication.Status.parseFrom(com.google.protobuf.CodedInputStream input)
static Replication.Status	Replication.Status.parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static Replication.Status	Replication.Status.parseFrom(InputStream input)
static Replication.Status	Replication.Status.parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)

Methods in org.apache.accumulo.server.replication.proto that return types with arguments of type Replication.Status

Modifier and Type	Method and Description
com.google.protobuf.Parser<Replication.Status>	Replication.Status.getParserForType()

Methods in org.apache.accumulo.server.replication.proto with parameters of type Replication.Status

Modifier and Type	Method and Description
Replication.Status.Builder	Replication.Status.Builder.mergeFrom(Replication.Status other)
static Replication.Status.Builder	Replication.Status.newBuilder(Replication.Status prototype)

Uses of Replication.Status in org.apache.accumulo.server.util

Methods in org.apache.accumulo.server.util with parameters of type Replication.Status

Modifier and Type	Method and Description
static void	ReplicationTableUtil.updateFiles(ClientContext context, KeyExtent extent, String file, Replication.Status stat) Write replication ingest entries for each provided file with the given Replication.Status.