computer/computer-core/src/main/java/org/apache/hugegraph/computer/core/worker/WorkerService.java (8 lines): - line 95: // TODO: what will happen if init() called by multiple threads? - line 126: // TODO: shall we call close() here? - line 167: // TODO: why checkInited() here, if init throws exception, how to close the resource? - line 186: * TODO: close the connection to other workers. - line 187: * TODO: stop the connection to the master - line 188: * TODO: stop the data transportation server. - line 241: // TODO: determine superstep if fail over is enabled. - line 248: // TODO: Get superstepStat from bsp service. computer/computer-core/src/main/java/org/apache/hugegraph/computer/core/master/MasterService.java (4 lines): - line 147: // TODO: check the logic of close carefully later - line 210: * TODO: Get input splits from HugeGraph if resume from - line 226: // TODO: Get superstepStat from bsp service. - line 336: * TODO: determines which superstep to start from if failover is vermeer/apps/master/bl/server_manager.go (3 lines): - line 81: // TODO: handle nil - line 86: // TODO: handle nil - line 94: // TODO: handle nil computer/computer-core/src/main/java/org/apache/hugegraph/computer/core/receiver/MessageRecvPartition.java (3 lines): - line 113: * TODO: create iterator directly from buffers if there is no - line 135: // TODO: count the message received - line 200: * TODO Restore genOutputFileNames(sqrt(outputFiles.size())) computer/computer-core/src/main/java/org/apache/hugegraph/computer/core/bsp/BspBase.java (2 lines): - line 98: // TODO: create from factory. the type of bsp can be get from config - line 133: // TODO: replace event.code() with event.name() computer/computer-algorithm/src/main/java/org/apache/hugegraph/computer/algorithm/sampling/RandomWalk.java (2 lines): - line 257: // TODO: use primitive array instead, like DoubleArray, - line 268: // TODO: improve to avoid OOM computer/computer-core/src/main/java/org/apache/hugegraph/computer/core/sender/QueuedMessageSender.java (2 lines): - line 52: // TODO: pass send-executor in and share executor with others - line 176: // TODO: should handle this in main workflow thread computer/computer-core/src/main/java/org/apache/hugegraph/computer/core/compute/ComputeManager.java (2 lines): - line 86: // TODO: parallel input process - line 195: // TODO: Write results back parallel computer/computer-k8s/src/main/java/org/apache/hugegraph/computer/k8s/driver/KubernetesDriver.java (2 lines): - line 397: // TODO: implement - line 417: // TODO: implement vermeer/apps/master/tasks/task_util.go (2 lines): - line 90: // TODO: status->state, make sure that the enums for graph states are clear. - line 91: // TODO: escape the check when creating the task computer/computer-api/src/main/java/org/apache/hugegraph/computer/core/config/ComputerOptions.java (2 lines): - line 821: // TODO: Test to get an best value - line 975: // TODO: test if the default value is appropriate. computer/computer-core/src/main/java/org/apache/hugegraph/computer/core/sender/MessageQueue.java (2 lines): - line 37: // TODO: replace with disruptor queue - line 45: * TODO: Try to optimize, don't signal every time when the queue vermeer/apps/graphio/load_graph.go (1 line): - line 472: // TODO: why not a pointer? computer/computer-test/src/main/java/org/apache/hugegraph/computer/core/allocator/DefaultAllocatorTest.java (1 line): - line 163: // TODO: Assert something computer/computer-core/src/main/java/org/apache/hugegraph/computer/core/allocator/DefaultAllocator.java (1 line): - line 50: // TODO: Add more params for Recycler computer/computer-core/src/main/java/org/apache/hugegraph/computer/core/receiver/MessageRecvBuffers.java (1 line): - line 54: * TODO: don't not use copy, add a new class computer/computer-algorithm/src/main/java/org/apache/hugegraph/computer/algorithm/path/rings/filter/SpreadFilter.java (1 line): - line 54: // TODO: Use a better scheme to parse expressions with only $element computer/computer-algorithm/src/main/java/org/apache/hugegraph/computer/algorithm/centrality/degree/DegreeCentrality.java (1 line): - line 58: * TODO: Here we use doubleValue type now, we will use BigDecimal computer/computer-api/src/main/java/org/apache/hugegraph/computer/core/util/JsonUtilExt.java (1 line): - line 28: // TODO: move to org.apache.hugegraph.util.JsonUtil later computer/computer-algorithm/src/main/java/org/apache/hugegraph/computer/algorithm/community/cc/ClusteringCoefficientOutput.java (1 line): - line 54: /* TODO: enhance it computer/computer-core/src/main/java/org/apache/hugegraph/computer/core/snapshot/SnapshotManager.java (1 line): - line 147: // TODO: Do not need to send control message to all workers computer/computer-test/src/main/java/org/apache/hugegraph/computer/core/sender/MessageSendManagerTest.java (1 line): - line 26: // TODO: Supplement vermeer/apps/master/services/router.go (1 line): - line 112: // TODO: add dashboard router vermeer/apps/master/access/access_manager.go (1 line): - line 32: // TODO: user name? computer/computer-core/src/main/java/org/apache/hugegraph/computer/core/network/netty/codec/FrameDecoder.java (1 line): - line 70: // TODO: improve it use shared memory computer/computer-api/src/main/java/org/apache/hugegraph/computer/core/graph/value/ListValue.java (1 line): - line 55: // TODO: try to reduce call ComputerContext.instance() directly. computer/computer-core/src/main/java/org/apache/hugegraph/computer/core/sort/flusher/CombineSubKvInnerSortFlusher.java (1 line): - line 64: // TODO: use byte buffer store all value pointer to avoid big collection computer/computer-test/src/main/java/org/apache/hugegraph/computer/core/worker/WorkerServiceTest.java (1 line): - line 238: * TODO: Complete this test case after data transport manager is computer/computer-algorithm/src/main/java/org/apache/hugegraph/computer/algorithm/community/kcore/Kcore.java (1 line): - line 64: * TODO: send int type message at phase 1, it's different from id computer/computer-core/src/main/java/org/apache/hugegraph/computer/core/sender/MultiQueue.java (1 line): - line 30: // TODO: use ReadWriteLock to optimize vermeer/apps/master/bl/task_canceler.go (1 line): - line 65: // TODO: to implement computer/computer-api/src/main/java/org/apache/hugegraph/computer/core/util/BytesUtil.java (1 line): - line 53: // TODO: use google comparator(unsafe) to improve perf vermeer/apps/worker/compute_bl.go (1 line): - line 258: // TODO: wait for all compute done vermeer/apps/master/graphs/graph_persistence.go (1 line): - line 78: // TODO: double check within lock computer/computer-core/src/main/java/org/apache/hugegraph/computer/core/network/netty/BufAllocatorFactory.java (1 line): - line 26: // TODO: Pooled allocators computer/computer-algorithm/src/main/java/org/apache/hugegraph/computer/algorithm/community/cc/ClusteringCoefficientValue.java (1 line): - line 29: * TODO: We could reuse triangle's result to simplify it (and avoid logical differences) vermeer/apps/master/bl/scheduler_bl.go (1 line): - line 39: startChan := make(chan *structure.TaskInfo, 10) // TODO: make configurable computer/computer-api/src/main/java/org/apache/hugegraph/computer/core/allocator/RecyclerReference.java (1 line): - line 27: // TODO: create interface here and make parameter a interface. computer/computer-core/src/main/java/org/apache/hugegraph/computer/core/compute/input/EdgesInput.java (1 line): - line 208: // TODO: use one reused Edges instance to read batches for each vertex. computer/computer-k8s-operator/crd-generate/config/minio/minio_server.yaml (1 line): - line 96: # TODO: check the port computer/computer-test/src/main/java/org/apache/hugegraph/computer/core/graph/value/ListValueTest.java (1 line): - line 290: * TODO: should keep value1 unmodifiable and let value3 modifiable? computer/computer-core/src/main/java/org/apache/hugegraph/computer/core/store/file/select/DisperseEvenlySelector.java (1 line): - line 96: // TODO: design a better way of distribute computer/computer-core/src/main/java/org/apache/hugegraph/computer/core/worker/load/LoadService.java (1 line): - line 154: * TODO: If it is an in edge, we should get the data from the in shard;