Skip to content

Commit

Permalink
Improve some comments (#472)
Browse files Browse the repository at this point in the history
Change-Id: I237f3e4175eec538aff01c521ec6e93cc8c2fc87
  • Loading branch information
Linary authored and zhoney committed Apr 19, 2019
1 parent 2418d51 commit d8d8fe2
Show file tree
Hide file tree
Showing 7 changed files with 16 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -129,13 +129,13 @@ public List<Shard> getSplits(long splitPartitions, long splitSize) {
/**
* Get splits of a table in specified range
* NOTE: maybe we don't need this method
* @param start, end: the specified range
* @param start: the start of range
* @param end: the end of range
* @param splitPartitions: expected partitions count per split
* @param splitSize: expected size(bytes) per split,
* splitPartitions will be ignored if splitSize is passed
* @return a list of Shard
*/

public List<Shard> getSplits(String start, String end,
int splitPartitions, int splitSize) {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -186,9 +186,6 @@ public EventHub indexEventHub() {
return this.indexEventHub;
}

/**
* @SuppressWarnings("UnstableApiUsage")
*/
public RateLimiter rateLimiter() {
return this.rateLimiter;
}
Expand Down Expand Up @@ -574,8 +571,7 @@ public Id[] mapVlName2Id(String[] vertexLabels) {

/**
* Stop all the daemon threads
* @param timout seconds
* @throws InterruptedException when be interrupted
* @param timeout seconds
*/
public static void shutdown(long timeout) {
try {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -38,6 +38,7 @@ public final class IdHolder {

/**
* For non-paging situation
* @param ids all ids
*/
public IdHolder(Set<Id> ids) {
this.query = null;
Expand All @@ -52,6 +53,8 @@ public IdHolder(Set<Id> ids) {

/**
* For paging situation
* @param query original query
* @param idsFetcher function to fetch one page ids
*/
public IdHolder(ConditionQuery query,
Function<ConditionQuery, PageIds> idsFetcher) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -141,6 +141,9 @@ public void updateEdgeIndex(HugeEdge edge, boolean removed) {

/**
* Update index(user properties) of vertex or edge
* @param ilId the id of index label
* @param element the properties owner
* @param removed remove or add index
*/
protected void updateIndex(Id ilId, HugeElement element, boolean removed) {
SchemaTransaction schema = graph().schemaTransaction();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -66,6 +66,8 @@ protected static void removeIndexLabelFromBaseLabel(SchemaTransaction tx,
/**
* Use reflection to call SchemaTransaction.removeSchema(),
* which is protected
* @param tx The remove operation actual executer
* @param schema the schema to be removed
*/
protected static void removeSchema(SchemaTransaction tx,
SchemaElement schema) {
Expand All @@ -86,6 +88,8 @@ protected static void removeSchema(SchemaTransaction tx,
/**
* Use reflection to call SchemaTransaction.updateSchema(),
* which is protected
* @param tx The update operation actual executer
* @param schema the schema to be update
*/
protected static void updateSchema(SchemaTransaction tx,
SchemaElement schema) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -108,6 +108,7 @@ public Class<?> clazz() {
/**
* Check type of the value valid
* @param value the property value to be checked data type
* @param <V> the property value original data type
* @return true if the value is or can convert to the data type,
* otherwise false
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -89,7 +89,7 @@ public int test(String[] args) throws Exception {

/**
* Multi-threaded and multi-commits and batch insertion test
* @param graph
* @param graph graph
* @param threadCount
* The count of threads that perform the insert operation at the
* same time
Expand All @@ -98,7 +98,7 @@ public int test(String[] args) throws Exception {
* @param multiple
* The coefficient to multiple number of vertices(100) and edges(100)
* for each transaction commit
* @throws InterruptedException
* @throws Exception execute may throw Exception
*/
public void testInsertPerf(GraphManager graph,
int threadCount,
Expand Down

0 comments on commit d8d8fe2

Please sign in to comment.