incubator-hugegraph-computer.git
6 weeks agofeature: optimize data receiving (#181) master
Cong Zhao [Thu, 19 May 2022 09:04:35 +0000 (17:04 +0800)] 
feature: optimize data receiving (#181)

* use zero-copy optimize data recv
* remove fail message
* improve some config
* support buffer file sort
* support sort with buffer file and fix some unit test
* create target file
* rebuild sort module

Co-authored-by: ShouJing <1075185785@qq.com>
6 weeks agofeature: support partition concurrent compute (#177)
ShouJing [Thu, 19 May 2022 06:10:26 +0000 (14:10 +0800)] 
feature: support partition concurrent compute (#177)

6 weeks agorebuild ci to compatible apache (#184)
Cong Zhao [Thu, 19 May 2022 02:15:01 +0000 (10:15 +0800)] 
rebuild ci to compatible apache (#184)

* rebuild ci to compatible apache

3 months agochore: support codeQL check (#183)
imbajin [Mon, 14 Mar 2022 06:40:28 +0000 (14:40 +0800)] 
chore: support codeQL check (#183)

4 months agochore: use cla assistant to support robot pr (#182)
imbajin [Thu, 3 Mar 2022 11:27:24 +0000 (19:27 +0800)] 
chore: use cla assistant to support robot pr (#182)

Co-authored-by: imbajin <imbajin@users.noreply.github.com>
4 months agoexpand some operator function (#179)
coderzc [Wed, 9 Feb 2022 10:28:43 +0000 (18:28 +0800)] 
expand some operator function (#179)

5 months agoupdate hugegraph-client & hugegraph-rpc & hugegraph-common version (#180)
coderzc [Mon, 24 Jan 2022 11:50:47 +0000 (19:50 +0800)] 
update hugegraph-client & hugegraph-rpc & hugegraph-common version (#180)

5 months agoupdate java version to 11 (#170)
coderzc [Tue, 18 Jan 2022 08:58:50 +0000 (16:58 +0800)] 
update java version to 11 (#170)

5 months agofeature: support input from hdfs and support hdfs kerberos (#172)
coderzc [Mon, 17 Jan 2022 10:14:47 +0000 (18:14 +0800)] 
feature: support input from hdfs and support hdfs kerberos (#172)

* support input from local/hdfs file (based on loader)
* support hdfs kerberos for input/output
* support filter vertex for hdfs output

5 months agorefactor: add common hugegraph-output and writeType config (#175)
coderzc [Fri, 14 Jan 2022 04:03:50 +0000 (12:03 +0800)] 
refactor: add common hugegraph-output and writeType config  (#175)

6 months agorefactor combiner: add v3 as result param (#169)
ShouJing [Fri, 24 Dec 2021 07:14:40 +0000 (15:14 +0800)] 
refactor combiner: add v3 as result param (#169)

6 months agoImplement betweenness centrality algorithm (#164) v0.1.2
Linary [Mon, 20 Dec 2021 07:56:58 +0000 (15:56 +0800)] 
Implement betweenness centrality algorithm (#164)

6 months agoadd configmap and secret mount to container (#158)
coderzc [Tue, 14 Dec 2021 06:07:30 +0000 (14:07 +0800)] 
add configmap and secret mount to container (#158)

6 months agoImplement closeness centrality algorithm (#104)
Linary [Mon, 13 Dec 2021 15:07:21 +0000 (23:07 +0800)] 
Implement closeness centrality algorithm (#104)

6 months agofix race condition of MessageRecvBuffers (#162)
Jermy Li [Mon, 13 Dec 2021 06:15:39 +0000 (14:15 +0800)] 
fix race condition of MessageRecvBuffers (#162)

* fix race condition of MessageRecvBuffers

* Separate sort-start event and sort-end event

6 months agoimprove: edge triggered sendAvailable (#140)
coderzc [Mon, 13 Dec 2021 05:23:02 +0000 (13:23 +0800)] 
improve: edge triggered sendAvailable (#140)

6 months agofix some warnings: k8s-test client not closed (#152)
Jermy Li [Tue, 7 Dec 2021 14:18:32 +0000 (22:18 +0800)] 
fix some warnings: k8s-test client not closed (#152)

7 months agofix build images (#160)
coderzc [Sat, 4 Dec 2021 07:51:51 +0000 (15:51 +0800)] 
fix build images (#160)

7 months agoadd docker pulls badge (#154)
coderzc [Fri, 3 Dec 2021 06:14:42 +0000 (14:14 +0800)] 
add docker pulls badge (#154)

* add docker pulls badge
* rename hugegraph-computer-based-algorithm to hugegraph-builtin-algorithms
* fix publish images ci

7 months agoPublish docker images by actions (#153)
coderzc [Thu, 2 Dec 2021 03:15:46 +0000 (11:15 +0800)] 
Publish docker images by actions (#153)

* publish docker images by actions
* rename computer-algorithm-based.jar to hugegraph-builtin-algorithms.jar
* add build_images.sh

7 months agoimprove: close hgkvfile input immediately (#155)
ShouJing [Wed, 1 Dec 2021 13:12:04 +0000 (21:12 +0800)] 
improve: close hgkvfile input immediately (#155)

7 months agoadd license-maven-plugin (#151)
ShouJing [Thu, 25 Nov 2021 11:52:12 +0000 (19:52 +0800)] 
add license-maven-plugin (#151)

7 months agoremove template param from Value class (#146)
Jermy Li [Wed, 24 Nov 2021 09:07:37 +0000 (17:07 +0800)] 
remove template param from Value class (#146)

7 months agoasync watch the k8s job (#148) v0.1.1
coderzc [Tue, 23 Nov 2021 12:03:56 +0000 (20:03 +0800)] 
async watch the k8s job (#148)

* async watch k8s job
* let cancelJob return bool
* update version to 0.1.1

7 months agorelease maven package by actions (#119)
coderzc [Tue, 23 Nov 2021 12:02:58 +0000 (20:02 +0800)] 
release maven package by actions (#119)

7 months agochange expression engine (#149)
ShouJing [Tue, 23 Nov 2021 03:55:54 +0000 (11:55 +0800)] 
change expression engine (#149)

7 months agoadd default value() method for HugeGraphOutput (#144)
Jermy Li [Thu, 18 Nov 2021 07:15:35 +0000 (15:15 +0800)] 
add default value() method for HugeGraphOutput (#144)

* add default value() method for HugeGraphOutput
* fix EXPECT_RINGS format

7 months agoimprove: delete useless temp file (#142)
ShouJing [Wed, 17 Nov 2021 07:00:29 +0000 (15:00 +0800)] 
improve: delete useless temp file (#142)

* remove useless temp file in merge file process and inputs file after merge

7 months agofix rings detection unit test bug (#147)
ShouJing [Wed, 17 Nov 2021 05:49:10 +0000 (13:49 +0800)] 
fix rings detection unit test bug (#147)

7 months agoimplement kcore algorithm (#143)
Jermy Li [Tue, 16 Nov 2021 08:46:53 +0000 (16:46 +0800)] 
implement kcore algorithm (#143)

7 months agoclear vertex old files and edge old files on `beforeSuperstep(Constants.INPUT_SUPERST...
coderzc [Wed, 10 Nov 2021 07:46:09 +0000 (15:46 +0800)] 
clear vertex old files and edge old files on `beforeSuperstep(Constants.INPUT_SUPERSTEP + 1)` (#141)

7 months agodelete useless old files (#138)
coderzc [Fri, 5 Nov 2021 09:11:55 +0000 (17:11 +0800)] 
delete useless old files (#138)

* delete useless file

7 months agoimprove ci config (#136)
coderzc [Thu, 4 Nov 2021 09:21:12 +0000 (17:21 +0800)] 
improve ci config (#136)

7 months agoadd subKvEntry size to KvEntryWithFirstSubKv (#139)
ShouJing [Thu, 4 Nov 2021 07:22:56 +0000 (15:22 +0800)] 
add subKvEntry size to KvEntryWithFirstSubKv (#139)

* add subKvEntry size to KvEntryWithFirstSubKv

* bug fix and add unit test

7 months agofix: vertex at compute0() may be inactive (#134)
Jermy Li [Thu, 4 Nov 2021 02:30:04 +0000 (10:30 +0800)] 
fix: vertex at compute0() may be inactive (#134)

8 months agofix: output string value of log-output (#133)
Jermy Li [Wed, 3 Nov 2021 09:56:07 +0000 (17:56 +0800)] 
fix: output string value of log-output (#133)

* fix: output string value of log-output

8 months agounify input/output dir name to lowercase letters (#132)
Jermy Li [Wed, 3 Nov 2021 09:50:00 +0000 (17:50 +0800)] 
unify input/output dir name to lowercase letters (#132)

* unify input/output dir name to lowercase letters

8 months agofix message_stat not reset each superstep (#131)
Jermy Li [Thu, 28 Oct 2021 11:42:13 +0000 (19:42 +0800)] 
fix message_stat not reset each superstep (#131)

8 months agofix: remove no exist path from merge source paths (#130)
coderzc [Wed, 27 Oct 2021 06:10:11 +0000 (14:10 +0800)] 
fix: remove no exist path from merge source paths (#130)

8 months agoadd operator deploy readme (#123)
coderzc [Tue, 26 Oct 2021 09:25:35 +0000 (17:25 +0800)] 
add operator deploy readme (#123)

8 months agorefactor ComputerOutput (#128)
Jermy Li [Tue, 26 Oct 2021 06:29:44 +0000 (14:29 +0800)] 
refactor ComputerOutput (#128)

* refactor ComputerOutput

* fix HdfsOutput

8 months agofix messege-count calculation error (#127)
Jermy Li [Mon, 25 Oct 2021 11:24:27 +0000 (19:24 +0800)] 
fix messege-count calculation error (#127)

8 months agoimplement LPA algorithm (#110)
Jermy Li [Mon, 25 Oct 2021 09:31:02 +0000 (17:31 +0800)] 
implement LPA algorithm (#110)

* implement LPA algorithm

* add LPA algorithm test

8 months agoimprove value interface (#126)
coderzc [Mon, 25 Oct 2021 04:02:45 +0000 (12:02 +0800)] 
improve value interface (#126)

8 months agoUse version 3.1.2 of Hadoop (#124)
coderzc [Thu, 21 Oct 2021 03:23:39 +0000 (11:23 +0800)] 
Use version 3.1.2 of Hadoop (#124)

* improve hadoop pom

* improve hadoop version

8 months agorelease file descriptor after input and compute (#120)
ShouJing [Thu, 21 Oct 2021 03:13:54 +0000 (11:13 +0800)] 
release file descriptor after input and compute (#120)

8 months agoadd fetch input splits timeout (#113)
ShouJing [Mon, 18 Oct 2021 08:59:25 +0000 (16:59 +0800)] 
add fetch input splits timeout (#113)

8 months agoadd hdfs output (#114)
coderzc [Mon, 18 Oct 2021 02:05:31 +0000 (10:05 +0800)] 
add hdfs output (#114)

* add hsfd output
* statistics execute cost
* fix problems with using the same Config object for SenderIntegrateTest

8 months agofix bug: close file stream ahead at input stage (#118)
ShouJing [Fri, 15 Oct 2021 02:09:45 +0000 (10:09 +0800)] 
fix bug: close file stream ahead at input stage (#118)

* delay close file stream

* tiny improve

8 months agoinject more env var when start-computer.sh (#115)
coderzc [Thu, 14 Oct 2021 06:32:13 +0000 (14:32 +0800)] 
inject more env var when start-computer.sh (#115)

8 months agoFix file descriptor leak (#116)
ShouJing [Thu, 14 Oct 2021 03:54:33 +0000 (11:54 +0800)] 
Fix file descriptor leak (#116)

8 months agoupdate `input.edge_freq` default value to MULTIPLE (#106)
ShouJing [Tue, 12 Oct 2021 12:22:30 +0000 (20:22 +0800)] 
update `input.edge_freq` default value to MULTIPLE (#106)

8 months agofix some warnings (#111)
Jermy Li [Sat, 9 Oct 2021 06:45:27 +0000 (14:45 +0800)] 
fix some warnings (#111)

* fix some warnings
* improve algorithm test

9 months agosplit SortManager to SendSortManager and RecvSortManager (#105)
coderzc [Tue, 28 Sep 2021 06:18:40 +0000 (14:18 +0800)] 
split SortManager to SendSortManager and RecvSortManager (#105)

9 months agoimprove number of transport threads and max_timeout_heartbeat_count (#103)
coderzc [Sun, 26 Sep 2021 08:35:20 +0000 (16:35 +0800)] 
improve number of transport threads and max_timeout_heartbeat_count (#103)

9 months agoimplement rings-detection algorithm (#95)
ShouJing [Sun, 26 Sep 2021 07:21:44 +0000 (15:21 +0800)] 
implement rings-detection algorithm (#95)

* add cycle detection algorithm
* improve: add field label in Vertex and Edge
* support properties filter in RingsDetection
* add StringValue
* add method object in Value
* update built-in object name in SpreadFilter and improve code style
* add standard rings-detection algorithm
* add RingsDetectionOutput
* resolve circular dependencies
* add message type IdListList rings-detection

9 months agoImplement triangle_count algorithms and improve some code (#101)
coderzc [Fri, 24 Sep 2021 07:58:27 +0000 (15:58 +0800)] 
Implement triangle_count algorithms and improve some code (#101)

* Implement triangle_count algorithms
* Improve some code

9 months agouse session timeout option for sendControlMessageToWorkers (#92)
coderzc [Mon, 13 Sep 2021 09:58:45 +0000 (17:58 +0800)] 
use session timeout option for sendControlMessageToWorkers (#92)

9 months agoimprove k8s resource allocation (#100)
coderzc [Mon, 13 Sep 2021 08:29:25 +0000 (16:29 +0800)] 
improve k8s resource allocation (#100)

* add DEFAULT_TRANSPORT_PORT
* split master and worker resource quantity
* transport threads don't exceed the count of workers

9 months agobugfix: calculate fileOffset error in method BufferFileInput#readFully when read...
ShouJing [Sun, 12 Sep 2021 13:06:55 +0000 (21:06 +0800)] 
bugfix: calculate fileOffset error in method BufferFileInput#readFully when read length is bigger than buffer capacity (#98)

9 months agoadd clear graph data method in unit test (#99)
ShouJing [Sun, 12 Sep 2021 09:04:07 +0000 (17:04 +0800)] 
add clear graph data method in unit test (#99)

* add clear graph data method

9 months agoFix: params of string format error (#97)
zyxxoo [Tue, 7 Sep 2021 05:48:19 +0000 (13:48 +0800)] 
Fix: params of string format error (#97)

Co-authored-by: vaughn.zhang <vaughn.zhang@zoom.us>
10 months agostandardized algorithm package and name (#96)
Jermy Li [Mon, 30 Aug 2021 13:10:23 +0000 (21:10 +0800)] 
standardized algorithm package and name (#96)

10 months agoimprove wcc test and add property(key) (#94)
coderzc [Fri, 27 Aug 2021 07:18:54 +0000 (15:18 +0800)] 
improve wcc test and add property(key) (#94)

* improve wcc test
* add property(key) for vertex and edge

10 months agoFix the count of input edge less than actual (#93)
Linary [Fri, 27 Aug 2021 03:15:48 +0000 (11:15 +0800)] 
Fix the count of input edge less than actual (#93)

10 months agooutput demo(pagerank) (#72)
zhoney [Thu, 26 Aug 2021 12:28:39 +0000 (20:28 +0800)] 
output demo(pagerank) (#72)

* implement hugegraph pagerank output class
* support multiple threads writeback
* add output configs to driver

10 months agofix FileGraphPartition and some warnings (#90)
Jermy Li [Tue, 17 Aug 2021 03:21:43 +0000 (11:21 +0800)] 
fix FileGraphPartition and some warnings (#90)

* improve FileGraphPartition
* fix warnings
* fix warnings of test
* fix MessageInputTest
* fix tow workers shared one data_dirs

10 months agochore: remove deleted files (#91)
zyxxoo [Mon, 16 Aug 2021 08:24:28 +0000 (16:24 +0800)] 
chore: remove deleted files (#91)

10 months agosort different type of message use different combiner (#85)
ShouJing [Mon, 16 Aug 2021 07:41:10 +0000 (15:41 +0800)] 
sort different type of message use different combiner (#85)

* fix bug: sort use Pointer but combiner used to combine Value or Property
* fix bug: merge to one file until Sorter#iterator is perfected

10 months agofix some k8s bug and improve some code (#83)
coderzc [Mon, 16 Aug 2021 03:37:28 +0000 (11:37 +0800)] 
fix some k8s bug and improve some code (#83)

* fix the pod deleted when job failed
* fix job active state inaccurate
* upgrade fabric8 k8s client version to 5.6.0
* add job cost statistics
* add AUTO_DESTROY_POD option for operator
* improve k8s error log message
* use a separate thread for execution waitJob on unit test
* delete history job before run k8s test

10 months agoremove etcd (#86)
coderzc [Thu, 12 Aug 2021 07:54:29 +0000 (15:54 +0800)] 
remove etcd (#86)

10 months agofeat: add degree centrality (#77)
zyxxoo [Wed, 11 Aug 2021 12:56:34 +0000 (20:56 +0800)] 
feat: add degree centrality (#77)

* feat: add degree centrality

* feat: add degree centrality

* feat: cal weight degreen centrality

* fix: params bug

* chore: improve style

* chore: handle more hugeType for weight property and add output test to test result

* refactor: number value extends Number type

* chore: improve code style

* chore: add TODO

* modify job id

* fix test

Co-authored-by: coderzc <zc1217zc@126.com>
10 months agoUse BytesId unify the Id classes (#78)
Linary [Wed, 11 Aug 2021 09:16:37 +0000 (17:16 +0800)] 
Use BytesId unify the Id classes (#78)

10 months agoadd wcc algorithm (#81)
houzhizhen [Wed, 11 Aug 2021 07:39:52 +0000 (15:39 +0800)] 
add wcc algorithm (#81)

10 months agoAdd mvn release plugin (#82)
Linary [Mon, 9 Aug 2021 08:18:10 +0000 (16:18 +0800)] 
Add mvn release plugin (#82)

10 months agoFix bug: last edge attched in currVertex missed to send (#80)
Linary [Mon, 9 Aug 2021 04:53:11 +0000 (12:53 +0800)] 
Fix bug: last edge attched in currVertex missed to send (#80)

10 months agofeat: add startup and make docker image code (#71)
zyxxoo [Fri, 6 Aug 2021 08:42:05 +0000 (16:42 +0800)] 
feat: add startup and make docker image code (#71)

10 months agoadd LICENSE for hugegraph-computer (#79)
coderzc [Fri, 6 Aug 2021 05:26:22 +0000 (13:26 +0800)] 
add LICENSE for hugegraph-computer (#79)

10 months agoadd page-rank algorithm (#70)
houzhizhen [Thu, 5 Aug 2021 10:54:42 +0000 (18:54 +0800)] 
add page-rank algorithm (#70)

* add page-rank algorithm
* Set algorithm's parameters in ComputerContextUtil#initContext
* register ComputerOptions to overwrite the config in driver.config.ComputerOptions

11 months agoimprove k8s operator test (#76)
coderzc [Tue, 3 Aug 2021 09:02:40 +0000 (17:02 +0800)] 
improve k8s operator test (#76)

* improve k8s operator test

* * improve k8s operator test
* modify ci badge

* add k8s operator test

11 months agoadd computer-k8s and computer-k8s-operator (#56)
coderzc [Tue, 3 Aug 2021 03:28:57 +0000 (11:28 +0800)] 
add computer-k8s and computer-k8s-operator (#56)

11 months agoFix bug: some input splits missed in iteration (#75)
Linary [Tue, 3 Aug 2021 03:28:01 +0000 (11:28 +0800)] 
Fix bug: some input splits missed in iteration (#75)

11 months agoFix bug: Number id like int convert LongId failed (#74)
Linary [Fri, 30 Jul 2021 06:24:15 +0000 (14:24 +0800)] 
Fix bug: Number id like int convert LongId failed (#74)

11 months agofix: use ip instead of hostname due to can't resolved on k8s (#73)
coderzc [Wed, 28 Jul 2021 03:24:40 +0000 (11:24 +0800)] 
fix: use ip instead of hostname due to can't resolved on k8s (#73)

11 months agoFix bug: judge whether a notice is needed is wrong for MessageQueue (#69)
Linary [Tue, 20 Jul 2021 08:15:06 +0000 (16:15 +0800)] 
Fix bug: judge whether a notice is needed is wrong for MessageQueue (#69)

11 months agoadd ComputeManager (#66)
houzhizhen [Wed, 7 Jul 2021 07:08:46 +0000 (15:08 +0800)] 
add ComputeManager (#66)

add class ComputeManager, FileGraphPartition, EdgesInput, MessageInput, ReusablePointer, VertexInput, LogOutput, MessageRecvStat
add class ComputeTestSuite, ComputeManagerTest, MockComputation, MockMessageSender, EdgesInputTest, EmptyEdgesTest, MessageInputTest
add method copy in IdValueList.
remove mergeGraph from MessageRecvManager;
add method recvStat in MessageRecvPartition
add method recvStats in MessageRecvPartitions
add methods merge(recvStat)recvStat in Partition
WorkerService links compute and output to corresponding methods in ComputeManager
move method writeMessage from ComputeMessageRecvPartitionTest to ReceiverUtil

11 months agoadd seqfile (#65)
ShouJing [Mon, 5 Jul 2021 08:31:58 +0000 (16:31 +0800)] 
add seqfile (#65)

* add ValueFileOutput/ValueFileInput
* add BitsFileReader/BitFileWriter
* add AbstractBufferedFileInput/AbstractBufferedFileOutput

11 months agochore: add issue template & auto stale issues and pr (#64)
imbajin [Mon, 5 Jul 2021 08:22:58 +0000 (16:22 +0800)] 
chore: add issue template & auto stale issues and pr (#64)

12 months agofix copyToByteArray(): remove duplicate() (#67)
coderzc [Mon, 5 Jul 2021 07:04:30 +0000 (15:04 +0800)] 
fix copyToByteArray(): remove duplicate() (#67)

12 months agoAdd test for MultiQueue take in wait status (#68)
Linary [Mon, 5 Jul 2021 06:27:28 +0000 (14:27 +0800)] 
Add test for MultiQueue take in wait status (#68)

12 months agoLet Sender and Receiver process compute message with type MESSAGE_CLASS (#63)
houzhizhen [Tue, 22 Jun 2021 08:53:10 +0000 (16:53 +0800)] 
Let Sender and Receiver process compute message with type MESSAGE_CLASS (#63)

* delete ValueFactory
* rename VALUE_CLASS to ALGORITHM_RESULT_CLASS, remove VALUE_TYPE
* add option OUTPUT_VALUE_NAME
* check channel not null in QueuedMessageSender#init

12 months agoFix send thread may blocked all the time (#61)
Linary [Mon, 21 Jun 2021 06:22:46 +0000 (14:22 +0800)] 
Fix send thread may blocked all the time (#61)

* Fix send thread may blocked all the time
* Add back MultiQueue class

12 months agoImplement StreamGraphInput and EntryInput (#60)
Linary [Fri, 18 Jun 2021 08:25:37 +0000 (16:25 +0800)] 
Implement StreamGraphInput and EntryInput (#60)

12 months agoImplement data receiver of worker (#51)
houzhizhen [Fri, 18 Jun 2021 05:40:23 +0000 (13:40 +0800)] 
Implement data receiver of worker (#51)

* add DataServerManager to manage the data server.
* add MessageRecvBuffers the manages buffers with limit size.
* add MessageRecvPartition to manage the data received for a partition and three subclass
  (VertexMessageRecvPartition,EdgeMessageRecvPartition, ComputeMessageRecvPartition).
* add MessageRecvPartitions to manage the partitions of data received, and three subclass
  (VertexMessageRecvPartitions,EdgeMessageRecvPartitions, ComputeMessageRecvPartitions)
* add MessageRecvManager to implement MessageHandler to handle network messages.
* process start-finish event.
* Partition add iterator and sort logic.
* add class SuperstepFileGenerator.
* create ConnectionManager in WorkerService.
* add mergeBuffers using sort-mamager.

12 months agoUse github action for ci via ci.yml (#62)
Linary [Fri, 18 Jun 2021 03:34:04 +0000 (11:34 +0800)] 
Use github action for ci via ci.yml (#62)

12 months agoLink managers in worker sending end (#52)
Linary [Tue, 15 Jun 2021 07:35:58 +0000 (15:35 +0800)] 
Link managers in worker sending end (#52)

* Link managers in worker sending end
* Optimize WriteBufferPool and SortedBufferQueuePool
* Rafact MessageSendPartition, WriteBuffer and Edge
* Refact writeEdge with label and name
* Let SortManager don't need Sender
* Refact GraphComputeOutput and GraphWritebackOutput
* Refact OptimizedBytesOutput
* Add Input/Output Factory
* Refact writeFixedInt in sort module
* Move pending message into MessageQueue
* Define a MultiQueue support multi put

12 months agoAdd sessionActive for client (#59)
coderzc [Thu, 10 Jun 2021 07:50:08 +0000 (15:50 +0800)] 
Add sessionActive for client (#59)

13 months agoFix EntriesUtil#entryFromInput and some improve (#58)
ShouJing [Fri, 4 Jun 2021 11:45:57 +0000 (19:45 +0800)] 
Fix EntriesUtil#entryFromInput and some improve (#58)

13 months agoadd PointerCombiner (#57)
houzhizhen [Thu, 3 Jun 2021 06:30:36 +0000 (14:30 +0800)] 
add PointerCombiner (#57)

13 months agoAdd store/sort module (#37)
ShouJing [Mon, 31 May 2021 06:51:32 +0000 (14:51 +0800)] 
Add store/sort module (#37)

* add hgkvFile/hgkvDir module
* add EntriesUtil.java
* add SorterTest.java
* move file verification to HgkvDir
* rebuild HgkvFile readFooter and Fix HgkvDir#open
* add sort module
* implement InnerSortFlusher and OuterSortFlusher
* add KvEntry#numSubEntries