Skip to content

feat(hstore): Hstore support bulkload #2685

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 8 commits into
base: master
Choose a base branch
from
Open

feat(hstore): Hstore support bulkload #2685

Changes from 1 commit
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
15e2ec0
bulkload 代码初版
haohao0103 Oct 10, 2024
410de31
bulkload 代码初版
haohao0103 Oct 11, 2024
2bd1259
#2669
haohao0103 Oct 17, 2024
14cfff5
#2669
haohao0103 Oct 17, 2024
64bb121
#2669
haohao0103 Oct 18, 2024
2d1a22d
#2669
haohao0103 Oct 18, 2024
e74b598
#2669
haohao0103 Oct 18, 2024
b1c6c9a
#2669
haohao0103 Oct 18, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
#2669 
Hstore bulkload
  • Loading branch information
@haohao0103
haohao0103 committed Oct 18, 2024
commit b1c6c9af5514b272190bbd35f6ad4db783a17b7f
21 changes: 7 additions & 14 deletions hugegraph-pd/hg-pd-service/src/main/java/org/apache/hugegraph/pd/rest/PartitionAPI.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -36,8 +36,7 @@
import org.apache.hugegraph.pd.service.PDRestService;
import org.apache.hugegraph.pd.util.DateUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.ParameterizedTypeReference;
import org.springframework.http.HttpMethod;
import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
Expand Down Expand Up @@ -285,21 +284,15 @@ public RestApiResponse getPartitions() {
}

@GetMapping(value = "/partitionsAndGraphId", produces = MediaType.APPLICATION_JSON_VALUE)
public Map<Long, Long> getPartitionsAndGraphId(@RequestParam String graphName) {
public ResponseEntity<?> getPartitionsAndGraphId(@RequestParam String graphName) {
log.info("getPartGraphId: " + graphName);
if (isLeader()) {
return getPartGraphId(graphName);
Map<Long, Long> result = getPartGraphId(graphName);
return ResponseEntity.ok(result);
} else {
String leaderAddress = RaftEngine.getInstance().getLeader().getIp();
String url = "http://" + leaderAddress+":8620" + "/v1/partitionsAndGraphId" ;
String urlWithParams = UriComponentsBuilder.fromHttpUrl(url).queryParam("graphName", graphName).toUriString();
ResponseEntity<HashMap<Long, Long>> responseEntity = restTemplate.exchange(
urlWithParams,
HttpMethod.GET,
null,
new ParameterizedTypeReference<HashMap<Long, Long>>() {}
);
return responseEntity.getBody();
String message = "This node is not the leader. Please contact the leader at: " + RaftEngine.getInstance().getLeader().getIp();
log.warn("This node is not the leader. Please contact the leader at: {}",message);
return ResponseEntity.status(HttpStatus.FORBIDDEN).body(Collections.singletonMap("error", message));
}
}

Expand Down
Loading