http://git-wip-us.apache.org/repos/asf/hadoop/blob/87700d45/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetMountTableEntriesRequestPBImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetMountTableEntriesRequestPBImpl.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetMountTableEntriesRequestPBImpl.java deleted file mode 100644 index 3e0d1a6..0000000 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetMountTableEntriesRequestPBImpl.java +++ /dev/null @@ -1,76 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hdfs.server.federation.store.protocol.impl.pb; - -import java.io.IOException; - -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetMountTableEntriesRequestProto; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetMountTableEntriesRequestProtoOrBuilder; -import org.apache.hadoop.hdfs.server.federation.store.protocol.GetMountTableEntriesRequest; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.PBRecord; - -import com.google.protobuf.Message; - -/** - * Protobuf implementation of the state store API object - * GetMountTableEntriesRequest. - */ -public class GetMountTableEntriesRequestPBImpl - extends GetMountTableEntriesRequest implements PBRecord { - - private FederationProtocolPBTranslator<GetMountTableEntriesRequestProto, - GetMountTableEntriesRequestProto.Builder, - GetMountTableEntriesRequestProtoOrBuilder> translator = - new FederationProtocolPBTranslator<GetMountTableEntriesRequestProto, - GetMountTableEntriesRequestProto.Builder, - GetMountTableEntriesRequestProtoOrBuilder>( - GetMountTableEntriesRequestProto.class); - - public GetMountTableEntriesRequestPBImpl() { - } - - public GetMountTableEntriesRequestPBImpl( - GetMountTableEntriesRequestProto proto) { - this.translator.setProto(proto); - } - - @Override - public GetMountTableEntriesRequestProto getProto() { - return this.translator.build(); - } - - @Override - public void setProto(Message proto) { - this.translator.setProto(proto); - } - - @Override - public void readInstance(String base64String) throws IOException { - this.translator.readInstance(base64String); - } - - @Override - public String getSrcPath() { - return this.translator.getProtoOrBuilder().getSrcPath(); - } - - @Override - public void setSrcPath(String path) { - this.translator.getBuilder().setSrcPath(path); - } -} \ No newline at end of file
http://git-wip-us.apache.org/repos/asf/hadoop/blob/87700d45/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetMountTableEntriesResponsePBImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetMountTableEntriesResponsePBImpl.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetMountTableEntriesResponsePBImpl.java deleted file mode 100644 index 9d64bc9..0000000 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetMountTableEntriesResponsePBImpl.java +++ /dev/null @@ -1,104 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hdfs.server.federation.store.protocol.impl.pb; - -import java.io.IOException; -import java.util.ArrayList; -import java.util.List; - -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetMountTableEntriesResponseProto; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetMountTableEntriesResponseProtoOrBuilder; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.MountTableRecordProto; -import org.apache.hadoop.hdfs.server.federation.store.protocol.GetMountTableEntriesResponse; -import org.apache.hadoop.hdfs.server.federation.store.records.MountTable; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.MountTablePBImpl; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.PBRecord; - -import com.google.protobuf.Message; - -/** - * Protobuf implementation of the state store API object - * GetMountTableEntriesResponse. - */ -public class GetMountTableEntriesResponsePBImpl - extends GetMountTableEntriesResponse implements PBRecord { - - private FederationProtocolPBTranslator<GetMountTableEntriesResponseProto, - GetMountTableEntriesResponseProto.Builder, - GetMountTableEntriesResponseProtoOrBuilder> translator = - new FederationProtocolPBTranslator<GetMountTableEntriesResponseProto, - GetMountTableEntriesResponseProto.Builder, - GetMountTableEntriesResponseProtoOrBuilder>( - GetMountTableEntriesResponseProto.class); - - public GetMountTableEntriesResponsePBImpl() { - } - - public GetMountTableEntriesResponsePBImpl( - GetMountTableEntriesResponseProto proto) { - this.translator.setProto(proto); - } - - @Override - public GetMountTableEntriesResponseProto getProto() { - return this.translator.build(); - } - - @Override - public void setProto(Message proto) { - this.translator.setProto(proto); - } - - @Override - public void readInstance(String base64String) throws IOException { - this.translator.readInstance(base64String); - } - - @Override - public List<MountTable> getEntries() throws IOException { - List<MountTableRecordProto> entries = - this.translator.getProtoOrBuilder().getEntriesList(); - List<MountTable> ret = new ArrayList<MountTable>(); - for (MountTableRecordProto entry : entries) { - MountTable record = new MountTablePBImpl(entry); - ret.add(record); - } - return ret; - } - - @Override - public void setEntries(List<MountTable> records) throws IOException { - this.translator.getBuilder().clearEntries(); - for (MountTable entry : records) { - if (entry instanceof MountTablePBImpl) { - MountTablePBImpl entryPB = (MountTablePBImpl)entry; - this.translator.getBuilder().addEntries(entryPB.getProto()); - } - } - } - - @Override - public long getTimestamp() { - return this.translator.getProtoOrBuilder().getTimestamp(); - } - - @Override - public void setTimestamp(long time) { - this.translator.getBuilder().setTimestamp(time); - } -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/hadoop/blob/87700d45/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetNamenodeRegistrationsRequestPBImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetNamenodeRegistrationsRequestPBImpl.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetNamenodeRegistrationsRequestPBImpl.java deleted file mode 100644 index 4f7fee1..0000000 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetNamenodeRegistrationsRequestPBImpl.java +++ /dev/null @@ -1,87 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hdfs.server.federation.store.protocol.impl.pb; - -import java.io.IOException; - -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetNamenodeRegistrationsRequestProto; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetNamenodeRegistrationsRequestProtoOrBuilder; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.NamenodeMembershipRecordProto; -import org.apache.hadoop.hdfs.server.federation.store.protocol.GetNamenodeRegistrationsRequest; -import org.apache.hadoop.hdfs.server.federation.store.records.MembershipState; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.MembershipStatePBImpl; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.PBRecord; - -import com.google.protobuf.Message; - -/** - * Protobuf implementation of the state store API object - * GetNamenodeRegistrationsRequest. - */ -public class GetNamenodeRegistrationsRequestPBImpl - extends GetNamenodeRegistrationsRequest implements PBRecord { - - private FederationProtocolPBTranslator<GetNamenodeRegistrationsRequestProto, - GetNamenodeRegistrationsRequestProto.Builder, - GetNamenodeRegistrationsRequestProtoOrBuilder> translator = - new FederationProtocolPBTranslator< - GetNamenodeRegistrationsRequestProto, - GetNamenodeRegistrationsRequestProto.Builder, - GetNamenodeRegistrationsRequestProtoOrBuilder>( - GetNamenodeRegistrationsRequestProto.class); - - public GetNamenodeRegistrationsRequestPBImpl() { - } - - public GetNamenodeRegistrationsRequestPBImpl( - GetNamenodeRegistrationsRequestProto proto) { - this.translator.setProto(proto); - } - - @Override - public GetNamenodeRegistrationsRequestProto getProto() { - return this.translator.build(); - } - - @Override - public void setProto(Message proto) { - this.translator.setProto(proto); - } - - @Override - public void readInstance(String base64String) throws IOException { - this.translator.readInstance(base64String); - } - - @Override - public MembershipState getPartialMembership() { - GetNamenodeRegistrationsRequestProtoOrBuilder proto = - this.translator.getProtoOrBuilder(); - if (!proto.hasMembership()){ - return null; - } - NamenodeMembershipRecordProto memberProto = proto.getMembership(); - return new MembershipStatePBImpl(memberProto); - } - - @Override - public void setPartialMembership(MembershipState member) { - MembershipStatePBImpl memberPB = (MembershipStatePBImpl)member; - this.translator.getBuilder().setMembership(memberPB.getProto()); - } -} http://git-wip-us.apache.org/repos/asf/hadoop/blob/87700d45/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetNamenodeRegistrationsResponsePBImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetNamenodeRegistrationsResponsePBImpl.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetNamenodeRegistrationsResponsePBImpl.java deleted file mode 100644 index f6be11d..0000000 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetNamenodeRegistrationsResponsePBImpl.java +++ /dev/null @@ -1,99 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hdfs.server.federation.store.protocol.impl.pb; - -import java.io.IOException; -import java.util.ArrayList; -import java.util.List; - -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetNamenodeRegistrationsResponseProto; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetNamenodeRegistrationsResponseProtoOrBuilder; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.NamenodeMembershipRecordProto; -import org.apache.hadoop.hdfs.server.federation.store.protocol.GetNamenodeRegistrationsResponse; -import org.apache.hadoop.hdfs.server.federation.store.records.MembershipState; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.MembershipStatePBImpl; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.PBRecord; - -import com.google.protobuf.Message; - -/** - * Protobuf implementation of the state store API object - * GetNamenodeRegistrationsResponse. - */ -public class GetNamenodeRegistrationsResponsePBImpl - extends GetNamenodeRegistrationsResponse implements PBRecord { - - private FederationProtocolPBTranslator<GetNamenodeRegistrationsResponseProto, - GetNamenodeRegistrationsResponseProto.Builder, - GetNamenodeRegistrationsResponseProtoOrBuilder> translator = - new FederationProtocolPBTranslator< - GetNamenodeRegistrationsResponseProto, - GetNamenodeRegistrationsResponseProto.Builder, - GetNamenodeRegistrationsResponseProtoOrBuilder>( - GetNamenodeRegistrationsResponseProto.class); - - public GetNamenodeRegistrationsResponsePBImpl() { - } - - public GetNamenodeRegistrationsResponsePBImpl( - GetNamenodeRegistrationsResponseProto proto) { - this.translator.setProto(proto); - } - - @Override - public GetNamenodeRegistrationsResponseProto getProto() { - return this.translator.build(); - } - - @Override - public void setProto(Message proto) { - this.translator.setProto(proto); - } - - @Override - public void readInstance(String base64String) throws IOException { - this.translator.readInstance(base64String); - } - - @Override - public List<MembershipState> getNamenodeMemberships() - throws IOException { - - List<MembershipState> ret = new ArrayList<MembershipState>(); - List<NamenodeMembershipRecordProto> memberships = - this.translator.getProtoOrBuilder().getNamenodeMembershipsList(); - for (NamenodeMembershipRecordProto memberProto : memberships) { - MembershipState membership = new MembershipStatePBImpl(memberProto); - ret.add(membership); - } - - return ret; - } - - @Override - public void setNamenodeMemberships(List<MembershipState> records) - throws IOException { - for (MembershipState member : records) { - if (member instanceof MembershipStatePBImpl) { - MembershipStatePBImpl memberPB = (MembershipStatePBImpl)member; - this.translator.getBuilder().addNamenodeMemberships( - memberPB.getProto()); - } - } - } -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/hadoop/blob/87700d45/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetNamespaceInfoRequestPBImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetNamespaceInfoRequestPBImpl.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetNamespaceInfoRequestPBImpl.java deleted file mode 100644 index 5f3e186..0000000 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetNamespaceInfoRequestPBImpl.java +++ /dev/null @@ -1,60 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hdfs.server.federation.store.protocol.impl.pb; - -import java.io.IOException; - -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetNamespaceInfoRequestProto; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetNamespaceInfoRequestProto.Builder; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetNamespaceInfoRequestProtoOrBuilder; -import org.apache.hadoop.hdfs.server.federation.store.protocol.GetNamespaceInfoRequest; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.PBRecord; - -import com.google.protobuf.Message; - -/** - * Protobuf implementation of the state store API object - * GetNamespaceInfoRequest. - */ -public class GetNamespaceInfoRequestPBImpl extends GetNamespaceInfoRequest - implements PBRecord { - - private FederationProtocolPBTranslator<GetNamespaceInfoRequestProto, - Builder, GetNamespaceInfoRequestProtoOrBuilder> translator = - new FederationProtocolPBTranslator<GetNamespaceInfoRequestProto, - Builder, GetNamespaceInfoRequestProtoOrBuilder>( - GetNamespaceInfoRequestProto.class); - - public GetNamespaceInfoRequestPBImpl() { - } - - @Override - public GetNamespaceInfoRequestProto getProto() { - return this.translator.build(); - } - - @Override - public void setProto(Message protocol) { - this.translator.setProto(protocol); - } - - @Override - public void readInstance(String base64String) throws IOException { - this.translator.readInstance(base64String); - } -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/hadoop/blob/87700d45/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetNamespaceInfoResponsePBImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetNamespaceInfoResponsePBImpl.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetNamespaceInfoResponsePBImpl.java deleted file mode 100644 index be1b184..0000000 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetNamespaceInfoResponsePBImpl.java +++ /dev/null @@ -1,95 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hdfs.server.federation.store.protocol.impl.pb; - -import java.io.IOException; -import java.util.HashSet; -import java.util.List; -import java.util.Set; - -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.FederationNamespaceInfoProto; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetNamespaceInfoResponseProto; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetNamespaceInfoResponseProtoOrBuilder; -import org.apache.hadoop.hdfs.server.federation.resolver.FederationNamespaceInfo; -import org.apache.hadoop.hdfs.server.federation.store.protocol.GetNamespaceInfoResponse; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.PBRecord; - -import com.google.protobuf.Message; - -/** - * Protobuf implementation of the state store API object - * GetNamespaceInfoResponse. - */ -public class GetNamespaceInfoResponsePBImpl - extends GetNamespaceInfoResponse implements PBRecord { - - private FederationProtocolPBTranslator<GetNamespaceInfoResponseProto, - GetNamespaceInfoResponseProto.Builder, - GetNamespaceInfoResponseProtoOrBuilder> translator = - new FederationProtocolPBTranslator<GetNamespaceInfoResponseProto, - GetNamespaceInfoResponseProto.Builder, - GetNamespaceInfoResponseProtoOrBuilder>( - GetNamespaceInfoResponseProto.class); - - public GetNamespaceInfoResponsePBImpl() { - } - - @Override - public GetNamespaceInfoResponseProto getProto() { - return this.translator.build(); - } - - @Override - public void setProto(Message protocol) { - this.translator.setProto(protocol); - } - - @Override - public void readInstance(String base64String) throws IOException { - this.translator.readInstance(base64String); - } - - @Override - public Set<FederationNamespaceInfo> getNamespaceInfo() { - - Set<FederationNamespaceInfo> ret = new HashSet<FederationNamespaceInfo>(); - List<FederationNamespaceInfoProto> namespaceList = - this.translator.getProtoOrBuilder().getNamespaceInfosList(); - for (FederationNamespaceInfoProto ns : namespaceList) { - FederationNamespaceInfo info = new FederationNamespaceInfo( - ns.getBlockPoolId(), ns.getClusterId(), ns.getNameserviceId()); - ret.add(info); - } - return ret; - } - - @Override - public void setNamespaceInfo(Set<FederationNamespaceInfo> namespaceInfo) { - int index = 0; - for (FederationNamespaceInfo item : namespaceInfo) { - FederationNamespaceInfoProto.Builder itemBuilder = - FederationNamespaceInfoProto.newBuilder(); - itemBuilder.setClusterId(item.getClusterId()); - itemBuilder.setBlockPoolId(item.getBlockPoolId()); - itemBuilder.setNameserviceId(item.getNameserviceId()); - this.translator.getBuilder().addNamespaceInfos(index, - itemBuilder.build()); - index++; - } - } -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/hadoop/blob/87700d45/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetRouterRegistrationRequestPBImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetRouterRegistrationRequestPBImpl.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetRouterRegistrationRequestPBImpl.java deleted file mode 100644 index 19bf4ec..0000000 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetRouterRegistrationRequestPBImpl.java +++ /dev/null @@ -1,70 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hdfs.server.federation.store.protocol.impl.pb; - -import java.io.IOException; - -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetRouterRegistrationRequestProto; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetRouterRegistrationRequestProto.Builder; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetRouterRegistrationRequestProtoOrBuilder; -import org.apache.hadoop.hdfs.server.federation.store.protocol.GetRouterRegistrationRequest; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.PBRecord; - -import com.google.protobuf.Message; - -/** - * Protobuf implementation of the state store API object - * GetRouterRegistrationRequest. - */ -public class GetRouterRegistrationRequestPBImpl - extends GetRouterRegistrationRequest implements PBRecord { - - private FederationProtocolPBTranslator<GetRouterRegistrationRequestProto, - Builder, GetRouterRegistrationRequestProtoOrBuilder> translator = - new FederationProtocolPBTranslator<GetRouterRegistrationRequestProto, - Builder, GetRouterRegistrationRequestProtoOrBuilder>( - GetRouterRegistrationRequestProto.class); - - public GetRouterRegistrationRequestPBImpl() { - } - - @Override - public GetRouterRegistrationRequestProto getProto() { - return this.translator.build(); - } - - @Override - public void setProto(Message proto) { - this.translator.setProto(proto); - } - - @Override - public void readInstance(String base64String) throws IOException { - this.translator.readInstance(base64String); - } - - @Override - public String getRouterId() { - return this.translator.getProtoOrBuilder().getRouterId(); - } - - @Override - public void setRouterId(String routerId) { - this.translator.getBuilder().setRouterId(routerId); - } -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/hadoop/blob/87700d45/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetRouterRegistrationResponsePBImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetRouterRegistrationResponsePBImpl.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetRouterRegistrationResponsePBImpl.java deleted file mode 100644 index ae17e92..0000000 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetRouterRegistrationResponsePBImpl.java +++ /dev/null @@ -1,79 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hdfs.server.federation.store.protocol.impl.pb; - -import java.io.IOException; - -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetRouterRegistrationResponseProto; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetRouterRegistrationResponseProto.Builder; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetRouterRegistrationResponseProtoOrBuilder; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.RouterRecordProto; -import org.apache.hadoop.hdfs.server.federation.store.protocol.GetRouterRegistrationResponse; -import org.apache.hadoop.hdfs.server.federation.store.records.RouterState; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.PBRecord; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.RouterStatePBImpl; - -import com.google.protobuf.Message; - -/** - * Protobuf implementation of the state store API object - * GetRouterRegistrationResponse. - */ -public class GetRouterRegistrationResponsePBImpl - extends GetRouterRegistrationResponse implements PBRecord { - - private FederationProtocolPBTranslator<GetRouterRegistrationResponseProto, - Builder, GetRouterRegistrationResponseProtoOrBuilder> translator = - new FederationProtocolPBTranslator< - GetRouterRegistrationResponseProto, Builder, - GetRouterRegistrationResponseProtoOrBuilder>( - GetRouterRegistrationResponseProto.class); - - public GetRouterRegistrationResponsePBImpl() { - } - - @Override - public GetRouterRegistrationResponseProto getProto() { - return this.translator.build(); - } - - @Override - public void setProto(Message protocol) { - this.translator.setProto(protocol); - } - - @Override - public void readInstance(String base64String) throws IOException { - this.translator.readInstance(base64String); - } - - @Override - public RouterState getRouter() { - RouterRecordProto proto = this.translator.getProtoOrBuilder().getRouter(); - return new RouterStatePBImpl(proto); - } - - @Override - public void setRouter(RouterState router) { - if (router instanceof RouterStatePBImpl) { - RouterStatePBImpl routerPB = (RouterStatePBImpl)router; - RouterRecordProto routerProto = routerPB.getProto(); - this.translator.getBuilder().setRouter(routerProto); - } - } -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/hadoop/blob/87700d45/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetRouterRegistrationsRequestPBImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetRouterRegistrationsRequestPBImpl.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetRouterRegistrationsRequestPBImpl.java deleted file mode 100644 index 4b48682..0000000 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetRouterRegistrationsRequestPBImpl.java +++ /dev/null @@ -1,61 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hdfs.server.federation.store.protocol.impl.pb; - -import java.io.IOException; - -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetRouterRegistrationsRequestProto; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetRouterRegistrationsRequestProto.Builder; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetRouterRegistrationsRequestProtoOrBuilder; -import org.apache.hadoop.hdfs.server.federation.store.protocol.GetRouterRegistrationsRequest; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.PBRecord; - -import com.google.protobuf.Message; - -/** - * Protobuf implementation of the state store API object - * GetRouterRegistrationsRequest. - */ -public class GetRouterRegistrationsRequestPBImpl - extends GetRouterRegistrationsRequest implements PBRecord { - - private FederationProtocolPBTranslator<GetRouterRegistrationsRequestProto, - Builder, GetRouterRegistrationsRequestProtoOrBuilder> translator = - new FederationProtocolPBTranslator< - GetRouterRegistrationsRequestProto, Builder, - GetRouterRegistrationsRequestProtoOrBuilder>( - GetRouterRegistrationsRequestProto.class); - - public GetRouterRegistrationsRequestPBImpl() { - } - - @Override - public GetRouterRegistrationsRequestProto getProto() { - return this.translator.build(); - } - - @Override - public void setProto(Message proto) { - this.translator.setProto(proto); - } - - @Override - public void readInstance(String base64String) throws IOException { - this.translator.readInstance(base64String); - } -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/hadoop/blob/87700d45/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetRouterRegistrationsResponsePBImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetRouterRegistrationsResponsePBImpl.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetRouterRegistrationsResponsePBImpl.java deleted file mode 100644 index 2d597fb..0000000 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetRouterRegistrationsResponsePBImpl.java +++ /dev/null @@ -1,102 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hdfs.server.federation.store.protocol.impl.pb; - -import java.io.IOException; -import java.util.ArrayList; -import java.util.List; - -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetRouterRegistrationsResponseProto; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetRouterRegistrationsResponseProto.Builder; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetRouterRegistrationsResponseProtoOrBuilder; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.RouterRecordProto; -import org.apache.hadoop.hdfs.server.federation.store.protocol.GetRouterRegistrationsResponse; -import org.apache.hadoop.hdfs.server.federation.store.records.RouterState; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.PBRecord; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.RouterStatePBImpl; - -import com.google.protobuf.Message; - -/** - * Protobuf implementation of the state store API object - * GetRouterRegistrationsResponse. - */ -public class GetRouterRegistrationsResponsePBImpl - extends GetRouterRegistrationsResponse implements PBRecord { - - private FederationProtocolPBTranslator<GetRouterRegistrationsResponseProto, - Builder, GetRouterRegistrationsResponseProtoOrBuilder> translator = - new FederationProtocolPBTranslator< - GetRouterRegistrationsResponseProto, Builder, - GetRouterRegistrationsResponseProtoOrBuilder>( - GetRouterRegistrationsResponseProto.class); - - public GetRouterRegistrationsResponsePBImpl() { - - } - - @Override - public GetRouterRegistrationsResponseProto getProto() { - return this.translator.build(); - } - - @Override - public void setProto(Message proto) { - this.translator.setProto(proto); - } - - @Override - public void readInstance(String base64String) throws IOException { - this.translator.readInstance(base64String); - } - - @Override - public List<RouterState> getRouters() throws IOException { - - List<RouterState> ret = new ArrayList<RouterState>(); - List<RouterRecordProto> memberships = - this.translator.getProtoOrBuilder().getRoutersList(); - for (RouterRecordProto memberProto : memberships) { - RouterState membership = new RouterStatePBImpl(memberProto); - ret.add(membership); - } - return ret; - } - - @Override - public void setRouters(List<RouterState> records) throws IOException { - - this.translator.getBuilder().clearRouters(); - for (RouterState router : records) { - if (router instanceof RouterStatePBImpl) { - RouterStatePBImpl routerPB = (RouterStatePBImpl) router; - this.translator.getBuilder().addRouters(routerPB.getProto()); - } - } - } - - @Override - public long getTimestamp() { - return this.translator.getProtoOrBuilder().getTimestamp(); - } - - @Override - public void setTimestamp(long time) { - this.translator.getBuilder().setTimestamp(time); - } -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/hadoop/blob/87700d45/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetSafeModeRequestPBImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetSafeModeRequestPBImpl.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetSafeModeRequestPBImpl.java deleted file mode 100644 index 1a4f63b..0000000 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetSafeModeRequestPBImpl.java +++ /dev/null @@ -1,62 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hdfs.server.federation.store.protocol.impl.pb; - -import java.io.IOException; - -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetSafeModeRequestProto; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetSafeModeRequestProto.Builder; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetSafeModeRequestProtoOrBuilder; -import org.apache.hadoop.hdfs.server.federation.store.protocol.GetSafeModeRequest; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.PBRecord; - -import com.google.protobuf.Message; - -/** - * Protobuf implementation of the state store API object - * GetSafeModeRequest. - */ -public class GetSafeModeRequestPBImpl extends GetSafeModeRequest - implements PBRecord { - - private FederationProtocolPBTranslator<GetSafeModeRequestProto, - Builder, GetSafeModeRequestProtoOrBuilder> translator = - new FederationProtocolPBTranslator<>(GetSafeModeRequestProto.class); - - public GetSafeModeRequestPBImpl() { - } - - public GetSafeModeRequestPBImpl(GetSafeModeRequestProto proto) { - this.translator.setProto(proto); - } - - @Override - public GetSafeModeRequestProto getProto() { - return translator.build(); - } - - @Override - public void setProto(Message proto) { - this.translator.setProto(proto); - } - - @Override - public void readInstance(String base64String) throws IOException { - this.translator.readInstance(base64String); - } -} http://git-wip-us.apache.org/repos/asf/hadoop/blob/87700d45/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetSafeModeResponsePBImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetSafeModeResponsePBImpl.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetSafeModeResponsePBImpl.java deleted file mode 100644 index 77fbeca..0000000 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/GetSafeModeResponsePBImpl.java +++ /dev/null @@ -1,73 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hdfs.server.federation.store.protocol.impl.pb; - -import java.io.IOException; - -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetSafeModeResponseProto; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetSafeModeResponseProto.Builder; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.GetSafeModeResponseProtoOrBuilder; -import org.apache.hadoop.hdfs.server.federation.store.protocol.GetSafeModeResponse; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.PBRecord; - -import com.google.protobuf.Message; - -/** - * Protobuf implementation of the state store API object - * GetSafeModeResponse. - */ -public class GetSafeModeResponsePBImpl extends GetSafeModeResponse - implements PBRecord { - - private FederationProtocolPBTranslator<GetSafeModeResponseProto, - Builder, GetSafeModeResponseProtoOrBuilder> translator = - new FederationProtocolPBTranslator<>( - GetSafeModeResponseProto.class); - - public GetSafeModeResponsePBImpl() { - } - - public GetSafeModeResponsePBImpl(GetSafeModeResponseProto proto) { - this.translator.setProto(proto); - } - - @Override - public GetSafeModeResponseProto getProto() { - return translator.build(); - } - - @Override - public void setProto(Message proto) { - this.translator.setProto(proto); - } - - @Override - public void readInstance(String base64String) throws IOException { - this.translator.readInstance(base64String); - } - - @Override - public boolean isInSafeMode() { - return this.translator.getProtoOrBuilder().getIsInSafeMode(); - } - - @Override - public void setSafeMode(boolean isInSafeMode) { - this.translator.getBuilder().setIsInSafeMode(isInSafeMode); - } -} http://git-wip-us.apache.org/repos/asf/hadoop/blob/87700d45/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/LeaveSafeModeRequestPBImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/LeaveSafeModeRequestPBImpl.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/LeaveSafeModeRequestPBImpl.java deleted file mode 100644 index 075099b..0000000 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/LeaveSafeModeRequestPBImpl.java +++ /dev/null @@ -1,62 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hdfs.server.federation.store.protocol.impl.pb; - -import java.io.IOException; - -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.LeaveSafeModeRequestProto; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.LeaveSafeModeRequestProto.Builder; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.LeaveSafeModeRequestProtoOrBuilder; -import org.apache.hadoop.hdfs.server.federation.store.protocol.LeaveSafeModeRequest; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.PBRecord; - -import com.google.protobuf.Message; - -/** - * Protobuf implementation of the state store API object - * LeaveSafeModeRequest. - */ -public class LeaveSafeModeRequestPBImpl extends LeaveSafeModeRequest - implements PBRecord { - - private FederationProtocolPBTranslator<LeaveSafeModeRequestProto, - Builder, LeaveSafeModeRequestProtoOrBuilder> translator = - new FederationProtocolPBTranslator<>(LeaveSafeModeRequestProto.class); - - public LeaveSafeModeRequestPBImpl() { - } - - public LeaveSafeModeRequestPBImpl(LeaveSafeModeRequestProto proto) { - this.translator.setProto(proto); - } - - @Override - public LeaveSafeModeRequestProto getProto() { - return translator.build(); - } - - @Override - public void setProto(Message proto) { - this.translator.setProto(proto); - } - - @Override - public void readInstance(String base64String) throws IOException { - this.translator.readInstance(base64String); - } -} http://git-wip-us.apache.org/repos/asf/hadoop/blob/87700d45/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/LeaveSafeModeResponsePBImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/LeaveSafeModeResponsePBImpl.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/LeaveSafeModeResponsePBImpl.java deleted file mode 100644 index 79f65fe..0000000 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/LeaveSafeModeResponsePBImpl.java +++ /dev/null @@ -1,73 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hdfs.server.federation.store.protocol.impl.pb; - -import java.io.IOException; - -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.LeaveSafeModeResponseProto; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.LeaveSafeModeResponseProto.Builder; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.LeaveSafeModeResponseProtoOrBuilder; -import org.apache.hadoop.hdfs.server.federation.store.protocol.LeaveSafeModeResponse; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.PBRecord; - -import com.google.protobuf.Message; - -/** - * Protobuf implementation of the state store API object - * LeaveSafeModeResponse. - */ -public class LeaveSafeModeResponsePBImpl extends LeaveSafeModeResponse - implements PBRecord { - - private FederationProtocolPBTranslator<LeaveSafeModeResponseProto, - Builder, LeaveSafeModeResponseProtoOrBuilder> translator = - new FederationProtocolPBTranslator<>( - LeaveSafeModeResponseProto.class); - - public LeaveSafeModeResponsePBImpl() { - } - - public LeaveSafeModeResponsePBImpl(LeaveSafeModeResponseProto proto) { - this.translator.setProto(proto); - } - - @Override - public LeaveSafeModeResponseProto getProto() { - return translator.build(); - } - - @Override - public void setProto(Message proto) { - this.translator.setProto(proto); - } - - @Override - public void readInstance(String base64String) throws IOException { - this.translator.readInstance(base64String); - } - - @Override - public boolean getStatus() { - return this.translator.getProtoOrBuilder().getStatus(); - } - - @Override - public void setStatus(boolean result) { - this.translator.getBuilder().setStatus(result); - } -} http://git-wip-us.apache.org/repos/asf/hadoop/blob/87700d45/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/NamenodeHeartbeatRequestPBImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/NamenodeHeartbeatRequestPBImpl.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/NamenodeHeartbeatRequestPBImpl.java deleted file mode 100644 index d1fc73f..0000000 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/NamenodeHeartbeatRequestPBImpl.java +++ /dev/null @@ -1,93 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hdfs.server.federation.store.protocol.impl.pb; - -import java.io.IOException; - -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.NamenodeHeartbeatRequestProto; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.NamenodeHeartbeatRequestProto.Builder; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.NamenodeHeartbeatRequestProtoOrBuilder; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.NamenodeMembershipRecordProto; -import org.apache.hadoop.hdfs.server.federation.store.driver.StateStoreSerializer; -import org.apache.hadoop.hdfs.server.federation.store.protocol.NamenodeHeartbeatRequest; -import org.apache.hadoop.hdfs.server.federation.store.records.MembershipState; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.MembershipStatePBImpl; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.PBRecord; - -import com.google.protobuf.Message; - -/** - * Protobuf implementation of the state store API object - * NamenodeHeartbeatRequest. - */ -public class NamenodeHeartbeatRequestPBImpl - extends NamenodeHeartbeatRequest implements PBRecord { - - private FederationProtocolPBTranslator<NamenodeHeartbeatRequestProto, Builder, - NamenodeHeartbeatRequestProtoOrBuilder> translator = - new FederationProtocolPBTranslator<NamenodeHeartbeatRequestProto, - Builder, - NamenodeHeartbeatRequestProtoOrBuilder>( - NamenodeHeartbeatRequestProto.class); - - public NamenodeHeartbeatRequestPBImpl() { - } - - @Override - public NamenodeHeartbeatRequestProto getProto() { - return this.translator.build(); - } - - @Override - public void setProto(Message proto) { - this.translator.setProto(proto); - } - - @Override - public void readInstance(String base64String) throws IOException { - this.translator.readInstance(base64String); - } - - @Override - public MembershipState getNamenodeMembership() throws IOException { - NamenodeMembershipRecordProto membershipProto = - this.translator.getProtoOrBuilder().getNamenodeMembership(); - MembershipState membership = - StateStoreSerializer.newRecord(MembershipState.class); - if (membership instanceof MembershipStatePBImpl) { - MembershipStatePBImpl membershipPB = (MembershipStatePBImpl)membership; - membershipPB.setProto(membershipProto); - return membershipPB; - } else { - throw new IOException("Cannot get membership from request"); - } - } - - @Override - public void setNamenodeMembership(MembershipState membership) - throws IOException { - if (membership instanceof MembershipStatePBImpl) { - MembershipStatePBImpl membershipPB = (MembershipStatePBImpl)membership; - NamenodeMembershipRecordProto membershipProto = - (NamenodeMembershipRecordProto)membershipPB.getProto(); - this.translator.getBuilder().setNamenodeMembership(membershipProto); - } else { - throw new IOException("Cannot set mount table entry"); - } - } -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/hadoop/blob/87700d45/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/NamenodeHeartbeatResponsePBImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/NamenodeHeartbeatResponsePBImpl.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/NamenodeHeartbeatResponsePBImpl.java deleted file mode 100644 index c243a6f..0000000 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/NamenodeHeartbeatResponsePBImpl.java +++ /dev/null @@ -1,71 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hdfs.server.federation.store.protocol.impl.pb; - -import java.io.IOException; - -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.NamenodeHeartbeatResponseProto; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.NamenodeHeartbeatResponseProtoOrBuilder; -import org.apache.hadoop.hdfs.server.federation.store.protocol.NamenodeHeartbeatResponse; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.PBRecord; - -import com.google.protobuf.Message; - -/** - * Protobuf implementation of the state store API object - * NamenodeHeartbeatResponse. - */ -public class NamenodeHeartbeatResponsePBImpl extends NamenodeHeartbeatResponse - implements PBRecord { - - private FederationProtocolPBTranslator<NamenodeHeartbeatResponseProto, - NamenodeHeartbeatResponseProto.Builder, - NamenodeHeartbeatResponseProtoOrBuilder> translator = - new FederationProtocolPBTranslator<NamenodeHeartbeatResponseProto, - NamenodeHeartbeatResponseProto.Builder, - NamenodeHeartbeatResponseProtoOrBuilder>( - NamenodeHeartbeatResponseProto.class); - - public NamenodeHeartbeatResponsePBImpl() { - } - - @Override - public NamenodeHeartbeatResponseProto getProto() { - return this.translator.build(); - } - - @Override - public void setProto(Message proto) { - this.translator.setProto(proto); - } - - @Override - public void readInstance(String base64String) throws IOException { - this.translator.readInstance(base64String); - } - - @Override - public boolean getResult() { - return this.translator.getProtoOrBuilder().getStatus(); - } - - @Override - public void setResult(boolean result) { - this.translator.getBuilder().setStatus(result); - } -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/hadoop/blob/87700d45/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/RemoveMountTableEntryRequestPBImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/RemoveMountTableEntryRequestPBImpl.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/RemoveMountTableEntryRequestPBImpl.java deleted file mode 100644 index 7f7c998..0000000 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/RemoveMountTableEntryRequestPBImpl.java +++ /dev/null @@ -1,76 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hdfs.server.federation.store.protocol.impl.pb; - -import java.io.IOException; - -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.RemoveMountTableEntryRequestProto; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.RemoveMountTableEntryRequestProtoOrBuilder; -import org.apache.hadoop.hdfs.server.federation.store.protocol.RemoveMountTableEntryRequest; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.PBRecord; - -import com.google.protobuf.Message; - -/** - * Protobuf implementation of the state store API object - * RemoveMountTableEntryRequest. - */ -public class RemoveMountTableEntryRequestPBImpl - extends RemoveMountTableEntryRequest implements PBRecord { - - private FederationProtocolPBTranslator<RemoveMountTableEntryRequestProto, - RemoveMountTableEntryRequestProto.Builder, - RemoveMountTableEntryRequestProtoOrBuilder> translator = - new FederationProtocolPBTranslator<RemoveMountTableEntryRequestProto, - RemoveMountTableEntryRequestProto.Builder, - RemoveMountTableEntryRequestProtoOrBuilder>( - RemoveMountTableEntryRequestProto.class); - - public RemoveMountTableEntryRequestPBImpl() { - } - - public RemoveMountTableEntryRequestPBImpl( - RemoveMountTableEntryRequestProto proto) { - this.setProto(proto); - } - - @Override - public RemoveMountTableEntryRequestProto getProto() { - return this.translator.build(); - } - - @Override - public void setProto(Message proto) { - this.translator.setProto(proto); - } - - @Override - public void readInstance(String base64String) throws IOException { - this.translator.readInstance(base64String); - } - - @Override - public String getSrcPath() { - return this.translator.getProtoOrBuilder().getSrcPath(); - } - - @Override - public void setSrcPath(String path) { - this.translator.getBuilder().setSrcPath(path); - } -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/hadoop/blob/87700d45/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/RemoveMountTableEntryResponsePBImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/RemoveMountTableEntryResponsePBImpl.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/RemoveMountTableEntryResponsePBImpl.java deleted file mode 100644 index 0c943ac..0000000 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/RemoveMountTableEntryResponsePBImpl.java +++ /dev/null @@ -1,76 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hdfs.server.federation.store.protocol.impl.pb; - -import java.io.IOException; - -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.RemoveMountTableEntryResponseProto; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.RemoveMountTableEntryResponseProto.Builder; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.RemoveMountTableEntryResponseProtoOrBuilder; -import org.apache.hadoop.hdfs.server.federation.store.protocol.RemoveMountTableEntryResponse; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.PBRecord; - -import com.google.protobuf.Message; - -/** - * Protobuf implementation of the state store API object - * RemoveMountTableEntryResponse. - */ -public class RemoveMountTableEntryResponsePBImpl - extends RemoveMountTableEntryResponse implements PBRecord { - - private FederationProtocolPBTranslator<RemoveMountTableEntryResponseProto, - Builder, RemoveMountTableEntryResponseProtoOrBuilder> translator = - new FederationProtocolPBTranslator<RemoveMountTableEntryResponseProto, - RemoveMountTableEntryResponseProto.Builder, - RemoveMountTableEntryResponseProtoOrBuilder>( - RemoveMountTableEntryResponseProto.class); - - public RemoveMountTableEntryResponsePBImpl() { - } - - public RemoveMountTableEntryResponsePBImpl( - RemoveMountTableEntryResponseProto proto) { - this.setProto(proto); - } - - @Override - public RemoveMountTableEntryResponseProto getProto() { - return this.translator.build(); - } - - @Override - public void setProto(Message proto) { - this.translator.setProto(proto); - } - - @Override - public void readInstance(String base64String) throws IOException { - this.translator.readInstance(base64String); - } - - @Override - public boolean getStatus() { - return this.translator.getProtoOrBuilder().getStatus(); - } - - @Override - public void setStatus(boolean result) { - this.translator.getBuilder().setStatus(result); - } -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/hadoop/blob/87700d45/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/RouterHeartbeatRequestPBImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/RouterHeartbeatRequestPBImpl.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/RouterHeartbeatRequestPBImpl.java deleted file mode 100644 index cc2be04..0000000 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/RouterHeartbeatRequestPBImpl.java +++ /dev/null @@ -1,78 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hdfs.server.federation.store.protocol.impl.pb; - -import java.io.IOException; - -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.RouterHeartbeatRequestProto; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.RouterHeartbeatRequestProto.Builder; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.RouterHeartbeatRequestProtoOrBuilder; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.RouterRecordProto; -import org.apache.hadoop.hdfs.server.federation.store.protocol.RouterHeartbeatRequest; -import org.apache.hadoop.hdfs.server.federation.store.records.RouterState; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.PBRecord; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.RouterStatePBImpl; - -import com.google.protobuf.Message; - -/** - * Protobuf implementation of the state store API object - * RouterHeartbeatRequest. - */ -public class RouterHeartbeatRequestPBImpl extends RouterHeartbeatRequest - implements PBRecord { - - private FederationProtocolPBTranslator<RouterHeartbeatRequestProto, Builder, - RouterHeartbeatRequestProtoOrBuilder> translator = - new FederationProtocolPBTranslator<RouterHeartbeatRequestProto, - Builder, RouterHeartbeatRequestProtoOrBuilder>( - RouterHeartbeatRequestProto.class); - - public RouterHeartbeatRequestPBImpl() { - } - - @Override - public RouterHeartbeatRequestProto getProto() { - return this.translator.build(); - } - - @Override - public void setProto(Message proto) { - this.translator.setProto(proto); - } - - @Override - public void readInstance(String base64String) throws IOException { - this.translator.readInstance(base64String); - } - - @Override - public RouterState getRouter() throws IOException { - RouterRecordProto routerProto = - this.translator.getProtoOrBuilder().getRouter(); - return new RouterStatePBImpl(routerProto); - } - - @Override - public void setRouter(RouterState routerState) { - if (routerState instanceof RouterStatePBImpl) { - RouterStatePBImpl routerStatePB = (RouterStatePBImpl)routerState; - this.translator.getBuilder().setRouter(routerStatePB.getProto()); - } - } -} http://git-wip-us.apache.org/repos/asf/hadoop/blob/87700d45/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/RouterHeartbeatResponsePBImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/RouterHeartbeatResponsePBImpl.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/RouterHeartbeatResponsePBImpl.java deleted file mode 100644 index ac534fd..0000000 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/RouterHeartbeatResponsePBImpl.java +++ /dev/null @@ -1,70 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hdfs.server.federation.store.protocol.impl.pb; - -import java.io.IOException; - -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.RouterHeartbeatResponseProto; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.RouterHeartbeatResponseProto.Builder; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.RouterHeartbeatResponseProtoOrBuilder; -import org.apache.hadoop.hdfs.server.federation.store.protocol.RouterHeartbeatResponse; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.PBRecord; - -import com.google.protobuf.Message; - -/** - * Protobuf implementation of the state store API object - * RouterHeartbeatResponse. - */ -public class RouterHeartbeatResponsePBImpl extends RouterHeartbeatResponse - implements PBRecord { - - private FederationProtocolPBTranslator<RouterHeartbeatResponseProto, Builder, - RouterHeartbeatResponseProtoOrBuilder> translator = - new FederationProtocolPBTranslator<RouterHeartbeatResponseProto, - Builder, RouterHeartbeatResponseProtoOrBuilder>( - RouterHeartbeatResponseProto.class); - - public RouterHeartbeatResponsePBImpl() { - } - - @Override - public RouterHeartbeatResponseProto getProto() { - return this.translator.build(); - } - - @Override - public void setProto(Message proto) { - this.translator.setProto(proto); - } - - @Override - public void readInstance(String base64String) throws IOException { - this.translator.readInstance(base64String); - } - - @Override - public boolean getStatus() { - return this.translator.getProtoOrBuilder().getStatus(); - } - - @Override - public void setStatus(boolean result) { - this.translator.getBuilder().setStatus(result); - } -} http://git-wip-us.apache.org/repos/asf/hadoop/blob/87700d45/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/UpdateMountTableEntryRequestPBImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/UpdateMountTableEntryRequestPBImpl.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/UpdateMountTableEntryRequestPBImpl.java deleted file mode 100644 index 621bb3a..0000000 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/UpdateMountTableEntryRequestPBImpl.java +++ /dev/null @@ -1,96 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hdfs.server.federation.store.protocol.impl.pb; - -import java.io.IOException; - -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.MountTableRecordProto; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.UpdateMountTableEntryRequestProto; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.UpdateMountTableEntryRequestProtoOrBuilder; -import org.apache.hadoop.hdfs.server.federation.store.driver.StateStoreSerializer; -import org.apache.hadoop.hdfs.server.federation.store.protocol.UpdateMountTableEntryRequest; -import org.apache.hadoop.hdfs.server.federation.store.records.MountTable; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.MountTablePBImpl; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.PBRecord; - -import com.google.protobuf.Message; - -/** - * Protobuf implementation of the state store API object - * UpdateMountTableEntryRequest. - */ -public class UpdateMountTableEntryRequestPBImpl - extends UpdateMountTableEntryRequest implements PBRecord { - - private FederationProtocolPBTranslator<UpdateMountTableEntryRequestProto, - UpdateMountTableEntryRequestProto.Builder, - UpdateMountTableEntryRequestProtoOrBuilder> translator = - new FederationProtocolPBTranslator<UpdateMountTableEntryRequestProto, - UpdateMountTableEntryRequestProto.Builder, - UpdateMountTableEntryRequestProtoOrBuilder>( - UpdateMountTableEntryRequestProto.class); - - public UpdateMountTableEntryRequestPBImpl() { - } - - public UpdateMountTableEntryRequestPBImpl( - UpdateMountTableEntryRequestProto proto) { - this.translator.setProto(proto); - } - - @Override - public UpdateMountTableEntryRequestProto getProto() { - return this.translator.build(); - } - - @Override - public void setProto(Message proto) { - this.translator.setProto(proto); - } - - @Override - public void readInstance(String base64String) throws IOException { - this.translator.readInstance(base64String); - } - - @Override - public MountTable getEntry() throws IOException { - MountTableRecordProto statsProto = - this.translator.getProtoOrBuilder().getEntry(); - MountTable stats = StateStoreSerializer.newRecord(MountTable.class); - if (stats instanceof MountTablePBImpl) { - MountTablePBImpl entryPB = (MountTablePBImpl)stats; - entryPB.setProto(statsProto); - return entryPB; - } else { - throw new IOException("Cannot get stats for the membership"); - } - } - - @Override - public void setEntry(MountTable mount) throws IOException { - if (mount instanceof MountTablePBImpl) { - MountTablePBImpl mountPB = (MountTablePBImpl)mount; - MountTableRecordProto mountProto = - (MountTableRecordProto)mountPB.getProto(); - this.translator.getBuilder().setEntry(mountProto); - } else { - throw new IOException("Cannot set mount table entry"); - } - } -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/hadoop/blob/87700d45/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/UpdateMountTableEntryResponsePBImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/UpdateMountTableEntryResponsePBImpl.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/UpdateMountTableEntryResponsePBImpl.java deleted file mode 100644 index 5d566d6..0000000 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/federation/store/protocol/impl/pb/UpdateMountTableEntryResponsePBImpl.java +++ /dev/null @@ -1,76 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hdfs.server.federation.store.protocol.impl.pb; - -import java.io.IOException; - -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.UpdateMountTableEntryResponseProto; -import org.apache.hadoop.hdfs.federation.protocol.proto.HdfsServerFederationProtos.UpdateMountTableEntryResponseProtoOrBuilder; -import org.apache.hadoop.hdfs.server.federation.store.protocol.UpdateMountTableEntryResponse; -import org.apache.hadoop.hdfs.server.federation.store.records.impl.pb.PBRecord; - -import com.google.protobuf.Message; - -/** - * Protobuf implementation of the state store API object - * UpdateMountTableEntryResponse. - */ -public class UpdateMountTableEntryResponsePBImpl - extends UpdateMountTableEntryResponse implements PBRecord { - - private FederationProtocolPBTranslator<UpdateMountTableEntryResponseProto, - UpdateMountTableEntryResponseProto.Builder, - UpdateMountTableEntryResponseProtoOrBuilder> translator = - new FederationProtocolPBTranslator<UpdateMountTableEntryResponseProto, - UpdateMountTableEntryResponseProto.Builder, - UpdateMountTableEntryResponseProtoOrBuilder>( - UpdateMountTableEntryResponseProto.class); - - public UpdateMountTableEntryResponsePBImpl() { - } - - public UpdateMountTableEntryResponsePBImpl( - UpdateMountTableEntryResponseProto proto) { - this.setProto(proto); - } - - @Override - public UpdateMountTableEntryResponseProto getProto() { - return this.translator.build(); - } - - @Override - public void setProto(Message proto) { - this.translator.setProto(proto); - } - - @Override - public void readInstance(String base64String) throws IOException { - this.translator.readInstance(base64String); - } - - @Override - public boolean getStatus() { - return this.translator.getProtoOrBuilder().getStatus(); - } - - @Override - public void setStatus(boolean result) { - this.translator.getBuilder().setStatus(result); - } -} --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org
