This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/tsfile.git
from b956d4ca merge config files to iotdb-system.properties (#85)
new 27c395a8 init tsfile for cpp.
new 7bda0420 refine code dir and add exmaples, benchmark etc.
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/unit-test.yml | 12 +-
cpp/.clang-format | 226 ++
cpp/.gitignore | 7 +
cpp/CMakeLists.txt | 129 +-
cpp/{tsfile => }/README-zh.md | 0
cpp/README.md | 79 +
cpp/bench_mark/CMakeLists.txt | 33 +
cpp/bench_mark/bench_mark_src/CMakeLists.txt | 57 +
.../bench_mark/bench_mark_src/bench_conf.h | 17 +-
cpp/bench_mark/bench_mark_src/bench_mark.cc | 161 +
.../bench_mark_src/bench_mark.h} | 10 +-
.../public/.asf.yaml => cpp/bench_mark/build.sh | 35 +-
cpp/build-utils/source-bundle-descriptor.xml | 36 -
cpp/build.sh | 142 +
cpp/cmake/build_function.cmake | 34 +
.../test/common_test.cpp => cmake/cmake_config.h} | 11 +-
cpp/cmake/config.h.in | 1 +
cpp/common/CMakeLists.txt | 48 -
cpp/common/include/common.hpp | 30 -
cpp/common/src/common.cpp | 27 -
cpp/examples/CMakeLists.txt | 68 +-
.../public/.asf.yaml => cpp/examples/build.sh | 17 +-
cpp/examples/cpp_examples/CMakeLists.txt | 22 +
.../examples/cpp_examples/cpp_examples.h | 19 +-
cpp/examples/cpp_examples/demo_read.cpp | 101 +
cpp/examples/cpp_examples/demo_write.cpp | 55 +
.../IDataWriter.java => cpp/examples/examples.cc | 12 +-
cpp/examples/include/example.hpp | 24 -
cpp/examples/src/example.cpp | 29 -
cpp/pom.xml | 94 +-
cpp/src/CMakeLists.txt | 55 +
cpp/src/common/CMakeLists.txt | 35 +
cpp/src/common/allocator/CMakeLists.txt | 26 +
cpp/src/common/allocator/alloc_base.h | 131 +
cpp/src/common/allocator/byte_stream.h | 1109 +++++++
cpp/src/common/allocator/mem_alloc.cc | 253 ++
cpp/src/common/allocator/my_string.h | 144 +
cpp/src/common/allocator/object_pool.h | 110 +
cpp/src/common/allocator/page_arena.cc | 65 +
cpp/src/common/allocator/page_arena.h | 101 +
cpp/src/common/allocator/stl_allocator.h | 90 +
cpp/src/common/allocator/util_define.h | 152 +
cpp/src/common/config/CMakeLists.txt | 20 +
cpp/src/common/config/config.h | 70 +
cpp/src/common/container/CMakeLists.txt | 22 +
cpp/src/common/container/array.h | 305 ++
.../src/common/container/bit_map.cc | 41 +-
cpp/src/common/container/bit_map.h | 83 +
cpp/src/common/container/blocking_queue.cc | 57 +
.../src/common/container/blocking_queue.h | 30 +-
cpp/src/common/container/byte_buffer.h | 127 +
cpp/src/common/container/hash_func.h | 106 +
cpp/src/common/container/hash_node.h | 73 +
cpp/src/common/container/hash_segm.h | 53 +
cpp/src/common/container/hash_table.h | 792 +++++
cpp/src/common/container/list.h | 149 +
cpp/src/common/container/murmur_hash3.cc | 138 +
cpp/src/common/container/murmur_hash3.h | 75 +
cpp/src/common/container/simple_vector.h | 58 +
cpp/src/common/container/slice.h | 148 +
cpp/src/common/container/sorted_array.h | 329 ++
cpp/src/common/datatype/CMakeLists.txt | 18 +
cpp/src/common/datatype/value.h | 223 ++
cpp/src/common/db_common.h | 183 ++
cpp/src/common/global.cc | 189 ++
cpp/src/common/global.h | 48 +
.../src/common/logger/elog.h | 30 +-
cpp/src/common/mutex/CMakeLists.txt | 20 +
cpp/src/common/mutex/mutex.h | 74 +
.../Preconditions.java => cpp/src/common/path.h | 41 +-
cpp/src/common/record.h | 138 +
cpp/src/common/row_record.h | 193 ++
cpp/src/common/schema.h | 73 +
cpp/src/common/seq_tvlist.h | 172 ++
cpp/src/common/seq_tvlist.inc | 174 ++
cpp/src/common/statistic.h | 839 ++++++
cpp/src/common/tablet.cc | 164 +
cpp/src/common/tablet.h | 100 +
cpp/src/common/tablet_iterator.h | 78 +
cpp/src/common/tsblock/CMakeLists.txt | 22 +
cpp/src/common/tsblock/tsblock.cc | 310 ++
cpp/src/common/tsblock/tsblock.h | 272 ++
cpp/src/common/tsblock/tuple_desc.cc | 88 +
cpp/src/common/tsblock/tuple_desc.h | 118 +
.../common/tsblock/vector/fixed_length_vector.h | 82 +
.../common/tsblock/vector/variable_length_vector.h | 87 +
cpp/src/common/tsblock/vector/vector.h | 94 +
cpp/src/common/tsfile_common.cc | 259 ++
cpp/src/common/tsfile_common.h | 823 +++++
cpp/src/common/tsfile_mgr.cc | 139 +
cpp/src/common/tsfile_mgr.h | 95 +
cpp/src/compress/CMakeLists.txt | 23 +
.../src/compress/compressor.c | 5 +-
cpp/src/compress/compressor.h | 51 +
cpp/src/compress/compressor_factory.h | 71 +
cpp/src/compress/gzip_compressor.cc | 292 ++
cpp/src/compress/gzip_compressor.h | 153 +
cpp/src/compress/lz4.c | 3162 ++++++++++++++++++++
cpp/src/compress/lz4.h | 1000 +++++++
cpp/src/compress/lz4_compressor.cc | 141 +
cpp/src/compress/lz4_compressor.h | 66 +
cpp/src/compress/uncompressed_compressor.h | 54 +
cpp/src/encoding/CMakeLists.txt | 32 +
cpp/src/encoding/bitpack_decoder.h | 175 ++
cpp/src/encoding/bitpack_encoder.h | 173 ++
.../Constant.java => cpp/src/encoding/decoder.h | 34 +-
cpp/src/encoding/decoder_factory.h | 97 +
cpp/src/encoding/dictionary_decoder.h | 78 +
cpp/src/encoding/dictionary_encoder.h | 101 +
cpp/src/encoding/encode_utils.h | 146 +
cpp/src/encoding/encoder.h | 44 +
cpp/src/encoding/encoder_factory.h | 113 +
cpp/src/encoding/gorilla_decoder.h | 411 +++
cpp/src/encoding/gorilla_encoder.h | 468 +++
cpp/src/encoding/intpacker.h | 155 +
cpp/src/encoding/plain_decoder.h | 52 +
cpp/src/encoding/plain_encoder.h | 63 +
cpp/src/encoding/ts2diff_decoder.h | 311 ++
cpp/src/encoding/ts2diff_encoder.h | 335 +++
cpp/src/encoding/zigzag_decoder.h | 205 ++
cpp/src/encoding/zigzag_encoder.h | 172 ++
cpp/src/file/CMakeLists.txt | 24 +
cpp/src/file/open_file.cc | 110 +
cpp/src/file/open_file.h | 137 +
cpp/src/file/read_file.cc | 126 +
cpp/src/file/read_file.h | 66 +
cpp/src/file/tsfile_io_reader.cc | 535 ++++
cpp/src/file/tsfile_io_reader.h | 169 ++
cpp/src/file/tsfile_io_writer.cc | 757 +++++
cpp/src/file/tsfile_io_writer.h | 191 ++
cpp/src/file/write_file.cc | 128 +
cpp/src/file/write_file.h | 61 +
cpp/src/reader/CMakeLists.txt | 23 +
cpp/src/reader/bloom_filter.cc | 268 ++
cpp/src/reader/bloom_filter.h | 128 +
cpp/src/reader/chunk_reader.cc | 454 +++
cpp/src/reader/chunk_reader.h | 137 +
cpp/src/reader/expression.cc | 207 ++
cpp/src/reader/expression.h | 133 +
cpp/src/reader/filter/and_filter.h | 87 +
cpp/src/reader/filter/between.h | 135 +
.../src/reader/filter/binary_filter.h | 34 +-
cpp/src/reader/filter/eq.h | 71 +
cpp/src/reader/filter/filter.h | 60 +
cpp/src/reader/filter/filter_type.h | 51 +
cpp/src/reader/filter/gt.h | 69 +
cpp/src/reader/filter/gt_eq.h | 70 +
cpp/src/reader/filter/in.h | 55 +
cpp/src/reader/filter/lt.h | 69 +
cpp/src/reader/filter/lt_eq.h | 70 +
cpp/src/reader/filter/not_eq.h | 71 +
cpp/src/reader/filter/object.h | 84 +
cpp/src/reader/filter/or_filter.h | 89 +
cpp/src/reader/filter/time_filter.cc | 46 +
cpp/src/reader/filter/time_filter.h | 53 +
cpp/src/reader/filter/time_operator.cc | 274 ++
cpp/src/reader/filter/time_operator.h | 213 ++
cpp/src/reader/filter/unary_filter.h | 66 +
cpp/src/reader/qds_with_timegenerator.cc | 384 +++
cpp/src/reader/qds_with_timegenerator.h | 136 +
cpp/src/reader/qds_without_timegenerator.cc | 159 +
cpp/src/reader/qds_without_timegenerator.h | 65 +
.../Cache.java => cpp/src/reader/query_data_set.h | 21 +-
cpp/src/reader/query_executor.h | 63 +
cpp/src/reader/scan_iterator.cc | 257 ++
cpp/src/reader/scan_iterator.h | 189 ++
cpp/src/reader/tsfile_executor.cc | 114 +
cpp/src/reader/tsfile_executor.h | 57 +
cpp/src/reader/tsfile_reader.cc | 67 +
cpp/src/reader/tsfile_reader.h | 55 +
cpp/src/reader/tsfile_series_scan_iterator.cc | 111 +
cpp/src/reader/tsfile_series_scan_iterator.h | 98 +
cpp/src/utils/CMakeLists.txt | 19 +
cpp/src/utils/db_utils.h | 417 +++
cpp/src/utils/errno_define.h | 76 +
cpp/src/utils/injection.h | 68 +
cpp/src/utils/storage_utils.h | 86 +
cpp/src/utils/util_define.h | 145 +
cpp/src/writer/CMakeLists.txt | 24 +
cpp/src/writer/chunk_writer.cc | 154 +
cpp/src/writer/chunk_writer.h | 136 +
cpp/src/writer/page_writer.cc | 210 ++
cpp/src/writer/page_writer.h | 178 ++
cpp/src/writer/tsfile_writer.cc | 429 +++
cpp/src/writer/tsfile_writer.h | 121 +
.../.vuepress/public/.asf.yaml => cpp/test_all.sh | 7 -
cpp/tsfile/CMakeLists.txt | 49 -
cpp/tsfile/README.md | 34 -
cpp/tsfile/include/tsfile.hpp | 30 -
cpp/tsfile/src/tsfile.cpp | 29 -
pom.xml | 6 +
191 files changed, 28457 insertions(+), 670 deletions(-)
create mode 100644 cpp/.clang-format
create mode 100644 cpp/.gitignore
rename cpp/{tsfile => }/README-zh.md (100%)
create mode 100644 cpp/README.md
create mode 100644 cpp/bench_mark/CMakeLists.txt
create mode 100644 cpp/bench_mark/bench_mark_src/CMakeLists.txt
copy
java/tsfile/src/main/java/org/apache/tsfile/read/query/timegenerator/node/NodeType.java
=> cpp/bench_mark/bench_mark_src/bench_conf.h (76%)
create mode 100644 cpp/bench_mark/bench_mark_src/bench_mark.cc
rename cpp/{tsfile/test/tsfile_test.cpp =>
bench_mark/bench_mark_src/bench_mark.h} (79%)
copy docs/src/.vuepress/public/.asf.yaml => cpp/bench_mark/build.sh (56%)
delete mode 100644 cpp/build-utils/source-bundle-descriptor.xml
create mode 100644 cpp/build.sh
create mode 100644 cpp/cmake/build_function.cmake
rename cpp/{common/test/common_test.cpp => cmake/cmake_config.h} (79%)
create mode 100644 cpp/cmake/config.h.in
delete mode 100644 cpp/common/CMakeLists.txt
delete mode 100644 cpp/common/include/common.hpp
delete mode 100644 cpp/common/src/common.cpp
copy docs/src/.vuepress/public/.asf.yaml => cpp/examples/build.sh (80%)
create mode 100644 cpp/examples/cpp_examples/CMakeLists.txt
copy java/common/src/main/java/org/apache/tsfile/utils/Accountable.java =>
cpp/examples/cpp_examples/cpp_examples.h (63%)
create mode 100644 cpp/examples/cpp_examples/demo_read.cpp
create mode 100644 cpp/examples/cpp_examples/demo_write.cpp
copy java/tsfile/src/main/java/org/apache/tsfile/write/writer/IDataWriter.java
=> cpp/examples/examples.cc (80%)
delete mode 100644 cpp/examples/include/example.hpp
delete mode 100644 cpp/examples/src/example.cpp
create mode 100644 cpp/src/CMakeLists.txt
create mode 100644 cpp/src/common/CMakeLists.txt
create mode 100644 cpp/src/common/allocator/CMakeLists.txt
create mode 100644 cpp/src/common/allocator/alloc_base.h
create mode 100644 cpp/src/common/allocator/byte_stream.h
create mode 100644 cpp/src/common/allocator/mem_alloc.cc
create mode 100644 cpp/src/common/allocator/my_string.h
create mode 100644 cpp/src/common/allocator/object_pool.h
create mode 100644 cpp/src/common/allocator/page_arena.cc
create mode 100644 cpp/src/common/allocator/page_arena.h
create mode 100644 cpp/src/common/allocator/stl_allocator.h
create mode 100644 cpp/src/common/allocator/util_define.h
create mode 100644 cpp/src/common/config/CMakeLists.txt
create mode 100644 cpp/src/common/config/config.h
create mode 100644 cpp/src/common/container/CMakeLists.txt
create mode 100644 cpp/src/common/container/array.h
copy
java/tsfile/src/main/java/org/apache/tsfile/read/common/BatchDataFactory.java
=> cpp/src/common/container/bit_map.cc (52%)
create mode 100644 cpp/src/common/container/bit_map.h
create mode 100644 cpp/src/common/container/blocking_queue.cc
copy
java/tsfile/src/main/java/org/apache/tsfile/read/common/type/TypeEnum.java =>
cpp/src/common/container/blocking_queue.h (59%)
create mode 100644 cpp/src/common/container/byte_buffer.h
create mode 100644 cpp/src/common/container/hash_func.h
create mode 100644 cpp/src/common/container/hash_node.h
create mode 100644 cpp/src/common/container/hash_segm.h
create mode 100644 cpp/src/common/container/hash_table.h
create mode 100644 cpp/src/common/container/list.h
create mode 100644 cpp/src/common/container/murmur_hash3.cc
create mode 100644 cpp/src/common/container/murmur_hash3.h
create mode 100644 cpp/src/common/container/simple_vector.h
create mode 100644 cpp/src/common/container/slice.h
create mode 100644 cpp/src/common/container/sorted_array.h
create mode 100644 cpp/src/common/datatype/CMakeLists.txt
create mode 100644 cpp/src/common/datatype/value.h
create mode 100644 cpp/src/common/db_common.h
create mode 100644 cpp/src/common/global.cc
create mode 100644 cpp/src/common/global.h
copy
java/tsfile/src/main/java/org/apache/tsfile/exception/NotImplementedException.java
=> cpp/src/common/logger/elog.h (66%)
create mode 100644 cpp/src/common/mutex/CMakeLists.txt
create mode 100644 cpp/src/common/mutex/mutex.h
copy java/tsfile/src/main/java/org/apache/tsfile/utils/Preconditions.java =>
cpp/src/common/path.h (51%)
create mode 100644 cpp/src/common/record.h
create mode 100644 cpp/src/common/row_record.h
create mode 100644 cpp/src/common/schema.h
create mode 100644 cpp/src/common/seq_tvlist.h
create mode 100644 cpp/src/common/seq_tvlist.inc
create mode 100644 cpp/src/common/statistic.h
create mode 100644 cpp/src/common/tablet.cc
create mode 100644 cpp/src/common/tablet.h
create mode 100644 cpp/src/common/tablet_iterator.h
create mode 100644 cpp/src/common/tsblock/CMakeLists.txt
create mode 100644 cpp/src/common/tsblock/tsblock.cc
create mode 100644 cpp/src/common/tsblock/tsblock.h
create mode 100644 cpp/src/common/tsblock/tuple_desc.cc
create mode 100644 cpp/src/common/tsblock/tuple_desc.h
create mode 100644 cpp/src/common/tsblock/vector/fixed_length_vector.h
create mode 100644 cpp/src/common/tsblock/vector/variable_length_vector.h
create mode 100644 cpp/src/common/tsblock/vector/vector.h
create mode 100644 cpp/src/common/tsfile_common.cc
create mode 100644 cpp/src/common/tsfile_common.h
create mode 100644 cpp/src/common/tsfile_mgr.cc
create mode 100644 cpp/src/common/tsfile_mgr.h
create mode 100644 cpp/src/compress/CMakeLists.txt
copy java/tsfile/src/main/java/org/apache/tsfile/write/writer/IDataWriter.java
=> cpp/src/compress/compressor.c (84%)
create mode 100644 cpp/src/compress/compressor.h
create mode 100644 cpp/src/compress/compressor_factory.h
create mode 100644 cpp/src/compress/gzip_compressor.cc
create mode 100644 cpp/src/compress/gzip_compressor.h
create mode 100644 cpp/src/compress/lz4.c
create mode 100644 cpp/src/compress/lz4.h
create mode 100644 cpp/src/compress/lz4_compressor.cc
create mode 100644 cpp/src/compress/lz4_compressor.h
create mode 100644 cpp/src/compress/uncompressed_compressor.h
create mode 100644 cpp/src/encoding/CMakeLists.txt
create mode 100644 cpp/src/encoding/bitpack_decoder.h
create mode 100644 cpp/src/encoding/bitpack_encoder.h
copy java/examples/src/main/java/org/apache/tsfile/Constant.java =>
cpp/src/encoding/decoder.h (50%)
create mode 100644 cpp/src/encoding/decoder_factory.h
create mode 100644 cpp/src/encoding/dictionary_decoder.h
create mode 100644 cpp/src/encoding/dictionary_encoder.h
create mode 100644 cpp/src/encoding/encode_utils.h
create mode 100644 cpp/src/encoding/encoder.h
create mode 100644 cpp/src/encoding/encoder_factory.h
create mode 100644 cpp/src/encoding/gorilla_decoder.h
create mode 100644 cpp/src/encoding/gorilla_encoder.h
create mode 100644 cpp/src/encoding/intpacker.h
create mode 100644 cpp/src/encoding/plain_decoder.h
create mode 100644 cpp/src/encoding/plain_encoder.h
create mode 100644 cpp/src/encoding/ts2diff_decoder.h
create mode 100644 cpp/src/encoding/ts2diff_encoder.h
create mode 100644 cpp/src/encoding/zigzag_decoder.h
create mode 100644 cpp/src/encoding/zigzag_encoder.h
create mode 100644 cpp/src/file/CMakeLists.txt
create mode 100644 cpp/src/file/open_file.cc
create mode 100644 cpp/src/file/open_file.h
create mode 100644 cpp/src/file/read_file.cc
create mode 100644 cpp/src/file/read_file.h
create mode 100644 cpp/src/file/tsfile_io_reader.cc
create mode 100644 cpp/src/file/tsfile_io_reader.h
create mode 100644 cpp/src/file/tsfile_io_writer.cc
create mode 100644 cpp/src/file/tsfile_io_writer.h
create mode 100644 cpp/src/file/write_file.cc
create mode 100644 cpp/src/file/write_file.h
create mode 100644 cpp/src/reader/CMakeLists.txt
create mode 100644 cpp/src/reader/bloom_filter.cc
create mode 100644 cpp/src/reader/bloom_filter.h
create mode 100644 cpp/src/reader/chunk_reader.cc
create mode 100644 cpp/src/reader/chunk_reader.h
create mode 100644 cpp/src/reader/expression.cc
create mode 100644 cpp/src/reader/expression.h
create mode 100644 cpp/src/reader/filter/and_filter.h
create mode 100644 cpp/src/reader/filter/between.h
copy
java/tsfile/src/main/java/org/apache/tsfile/exception/filter/StatisticsClassException.java
=> cpp/src/reader/filter/binary_filter.h (50%)
create mode 100644 cpp/src/reader/filter/eq.h
create mode 100644 cpp/src/reader/filter/filter.h
create mode 100644 cpp/src/reader/filter/filter_type.h
create mode 100644 cpp/src/reader/filter/gt.h
create mode 100644 cpp/src/reader/filter/gt_eq.h
create mode 100644 cpp/src/reader/filter/in.h
create mode 100644 cpp/src/reader/filter/lt.h
create mode 100644 cpp/src/reader/filter/lt_eq.h
create mode 100644 cpp/src/reader/filter/not_eq.h
create mode 100644 cpp/src/reader/filter/object.h
create mode 100644 cpp/src/reader/filter/or_filter.h
create mode 100644 cpp/src/reader/filter/time_filter.cc
create mode 100644 cpp/src/reader/filter/time_filter.h
create mode 100644 cpp/src/reader/filter/time_operator.cc
create mode 100644 cpp/src/reader/filter/time_operator.h
create mode 100644 cpp/src/reader/filter/unary_filter.h
create mode 100644 cpp/src/reader/qds_with_timegenerator.cc
create mode 100644 cpp/src/reader/qds_with_timegenerator.h
create mode 100644 cpp/src/reader/qds_without_timegenerator.cc
create mode 100644 cpp/src/reader/qds_without_timegenerator.h
copy java/tsfile/src/main/java/org/apache/tsfile/common/cache/Cache.java =>
cpp/src/reader/query_data_set.h (67%)
create mode 100644 cpp/src/reader/query_executor.h
create mode 100644 cpp/src/reader/scan_iterator.cc
create mode 100644 cpp/src/reader/scan_iterator.h
create mode 100644 cpp/src/reader/tsfile_executor.cc
create mode 100644 cpp/src/reader/tsfile_executor.h
create mode 100644 cpp/src/reader/tsfile_reader.cc
create mode 100644 cpp/src/reader/tsfile_reader.h
create mode 100644 cpp/src/reader/tsfile_series_scan_iterator.cc
create mode 100644 cpp/src/reader/tsfile_series_scan_iterator.h
create mode 100644 cpp/src/utils/CMakeLists.txt
create mode 100644 cpp/src/utils/db_utils.h
create mode 100644 cpp/src/utils/errno_define.h
create mode 100644 cpp/src/utils/injection.h
create mode 100644 cpp/src/utils/storage_utils.h
create mode 100644 cpp/src/utils/util_define.h
create mode 100644 cpp/src/writer/CMakeLists.txt
create mode 100644 cpp/src/writer/chunk_writer.cc
create mode 100644 cpp/src/writer/chunk_writer.h
create mode 100644 cpp/src/writer/page_writer.cc
create mode 100644 cpp/src/writer/page_writer.h
create mode 100644 cpp/src/writer/tsfile_writer.cc
create mode 100644 cpp/src/writer/tsfile_writer.h
copy docs/src/.vuepress/public/.asf.yaml => cpp/test_all.sh (91%)
delete mode 100644 cpp/tsfile/CMakeLists.txt
delete mode 100644 cpp/tsfile/README.md
delete mode 100644 cpp/tsfile/include/tsfile.hpp
delete mode 100644 cpp/tsfile/src/tsfile.cpp
