import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;
-import javax.annotation.Nonnull;
+import org.eclipse.jdt.annotation.NonNull;
/**
* Represents the persisted snapshot state for the ShardManager.
*
* @author Thomas Pantelis
*/
-public class ShardManagerSnapshot implements Serializable {
- private static final long serialVersionUID = 1L;
-
+public final class ShardManagerSnapshot implements Serializable {
private static final class Proxy implements Externalizable {
private static final long serialVersionUID = 1L;
}
@Override
- public void writeExternal(ObjectOutput out) throws IOException {
+ public void writeExternal(final ObjectOutput out) throws IOException {
out.writeInt(snapshot.shardList.size());
for (String shard: snapshot.shardList) {
out.writeObject(shard);
}
@Override
- public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException {
+ public void readExternal(final ObjectInput in) throws IOException, ClassNotFoundException {
int size = in.readInt();
- List<String> shardList = new ArrayList<>(size);
+ List<String> localShardList = new ArrayList<>(size);
for (int i = 0; i < size; i++) {
- shardList.add((String) in.readObject());
+ localShardList.add((String) in.readObject());
}
- snapshot = new ShardManagerSnapshot(shardList);
+ snapshot = new ShardManagerSnapshot(localShardList);
}
private Object readResolve() {
}
}
+ private static final long serialVersionUID = 1L;
+
private final List<String> shardList;
- public ShardManagerSnapshot(@Nonnull final List<String> shardList) {
+ public ShardManagerSnapshot(final @NonNull List<String> shardList) {
this.shardList = ImmutableList.copyOf(shardList);
}
public List<String> getShardList() {
- return this.shardList;
+ return shardList;
}
private Object writeReplace() {