[feature] integrate with Apache Arrow #2860
Merged
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
What's changed?
#2825
Not completed yet!!!!!
I've write codes that can run successfully in local. It can be tested by using
CentOS monitor
.How to test?
--add-opens=java.base/java.nio=org.apache.arrow.memory.core,ALL-UNNAMED
Operations in Apache Arrow
Please refer package: org.apache.hertzbeat.common.entity.arrow
I've organized operations and data structure about arrow.
org.apache.hertzbeat.common.entity.arrow.ArrowVectorWriter
: used for writing data and tranferring to bytes arr, which can be set incollect_rep.proto
.org.apache.hertzbeat.common.entity.arrow.ArrowVectorReader
: used for reading bytes arr that created by ArrowVectorWriterorg.apache.hertzbeat.common.entity.arrow.RowWrapper
andorg.apache.hertzbeat.common.entity.arrow.ArrowCell
: when try to read data from ArrowVectorReader, we can get this two data structure.Todo List
collect_rep.proto
.hertzbeat-collector
hertzbeat-collector
Checklist
Add or update API