This is an automated email from the ASF dual-hosted git repository.
colinlee pushed a change to branch fix_err
in repository https://gitbox.apache.org/repos/asf/tsfile.git
discard 605939fd fix length
discard 0377f58e fix length.
discard 2a66d472 tmp code.
omit e2415afd tmp code.
omit f18ea69e tmp code.
omit c18c62f6 fix relase.
omit 0a60d610 fix segsegv.
omit 5447d8b8 skip first chunk in need.
omit de7bc018 tmp code.
omit bc58c534 disable some tree func.
omit 2545e50c fix data lossing.
omit 58f56217 fix filesize overflow.
omit 395c1100 fix file size overflow.
add 09015fa1 [CPP]Fix/multi fileds column (#522)
add de166a7d Support set default compression by data type (#523)
new 791de070 fix
new 15607aae update.
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (605939fd)
\
N -- N -- N refs/heads/fix_err (15607aae)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
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:
cpp/src/CMakeLists.txt | 2 +-
cpp/src/common/allocator/byte_stream.h | 168 +--
cpp/src/common/allocator/mem_alloc.cc | 4 +-
cpp/src/common/allocator/page_arena.cc | 2 +-
cpp/src/common/allocator/page_arena.h | 6 +-
cpp/src/common/cache/lru_cache.h | 11 +-
cpp/src/common/container/bit_map.h | 14 +-
cpp/src/common/container/byte_buffer.h | 1 +
cpp/src/common/container/hash_table.h | 10 +-
cpp/src/common/container/list.h | 12 +-
cpp/src/common/container/murmur_hash3.h | 23 +-
cpp/src/common/datatype/value.h | 5 +-
cpp/src/common/db_common.h | 11 +-
cpp/src/common/device_id.h | 39 +-
cpp/src/common/error_info/error_define.inc | 16 +-
cpp/src/common/error_info/error_info.h | 8 +-
cpp/src/common/global.cc | 1 +
cpp/src/common/global.h | 8 +-
cpp/src/common/mutex/mutex.h | 2 +-
cpp/src/common/path.h | 3 +-
cpp/src/common/record.h | 1 -
cpp/src/common/row_record.h | 4 +-
cpp/src/common/schema.h | 4 +-
cpp/src/common/statistic.h | 121 +-
cpp/src/common/tablet.h | 67 +-
cpp/src/common/tsblock/tsblock.cc | 3 +-
cpp/src/common/tsblock/tsblock.h | 48 +-
cpp/src/common/tsblock/tuple_desc.cc | 2 +-
cpp/src/common/tsblock/tuple_desc.h | 2 +-
cpp/src/common/tsfile_common.h | 83 +-
cpp/src/common/tsfile_mgr.cc | 139 ---
cpp/src/common/tsfile_mgr.h | 95 --
cpp/src/compress/gzip_compressor.cc | 407 ++++---
cpp/src/compress/gzip_compressor.h | 191 ++-
cpp/src/compress/lz4_compressor.cc | 6 +-
cpp/src/compress/lzo_compressor.cc | 8 +-
cpp/src/compress/lzo_compressor.h | 4 +-
cpp/src/compress/snappy_compressor.cc | 2 +-
cpp/src/compress/snappy_compressor.h | 5 +-
cpp/src/cwrapper/errno_define_c.h | 4 +-
cpp/src/encoding/intpacker.h | 6 +-
cpp/src/encoding/ts2diff_encoder.h | 18 +-
cpp/src/file/tsfile_io_reader.cc | 276 +++--
cpp/src/file/tsfile_io_reader.h | 33 +-
cpp/src/file/tsfile_io_writer.cc | 3 +
cpp/src/file/tsfile_io_writer.h | 336 +++---
cpp/src/parser/generated/PathLexer.cpp | 991 +++++++++-------
cpp/src/parser/generated/PathLexer.h | 134 ++-
cpp/src/parser/generated/PathParser.cpp | 1219 ++++++++++----------
cpp/src/parser/generated/PathParser.h | 413 ++++---
.../parser/generated/PathParserBaseListener.cpp | 3 -
cpp/src/parser/generated/PathParserBaseListener.h | 82 +-
cpp/src/parser/generated/PathParserBaseVisitor.cpp | 3 -
cpp/src/parser/generated/PathParserBaseVisitor.h | 86 +-
cpp/src/parser/generated/PathParserListener.cpp | 3 -
cpp/src/parser/generated/PathParserListener.h | 49 +-
cpp/src/parser/generated/PathParserVisitor.cpp | 3 -
cpp/src/parser/generated/PathParserVisitor.h | 40 +-
cpp/src/parser/path_nodes_generator.cpp | 39 +-
cpp/src/parser/path_nodes_generator.h | 6 +-
cpp/src/parser/path_parser_error.h | 33 +-
cpp/src/parser/path_visitor.cpp | 153 +--
cpp/src/parser/path_visitor.h | 37 +-
.../reader/block/device_ordered_tsblock_reader.cc | 5 +
.../reader/block/single_device_tsblock_reader.cc | 7 +-
.../reader/block/single_device_tsblock_reader.h | 8 +-
cpp/src/reader/bloom_filter.h | 9 +-
cpp/src/reader/chunk_reader.h | 9 +-
cpp/src/reader/column_mapping.h | 14 +-
cpp/src/reader/device_meta_iterator.cc | 8 +-
cpp/src/reader/filter/filter.h | 9 +
cpp/src/reader/filter/gt_eq.h | 2 +-
cpp/src/reader/imeta_data_querier.h | 3 +-
cpp/src/reader/qds_with_timegenerator.cc | 25 +-
cpp/src/reader/qds_with_timegenerator.h | 2 +-
cpp/src/reader/scan_iterator.h | 5 +-
cpp/src/reader/table_query_executor.h | 6 +-
cpp/src/reader/task/device_query_task.h | 7 +-
cpp/src/reader/tsfile_executor.cc | 5 +-
cpp/src/utils/db_utils.h | 20 +-
cpp/src/utils/injection.h | 6 +-
cpp/src/utils/storage_utils.h | 20 +-
cpp/src/writer/chunk_writer.h | 3 +-
cpp/src/writer/time_chunk_writer.h | 7 +-
cpp/src/writer/tsfile_writer.cc | 3 +
cpp/src/writer/tsfile_writer.h | 6 +-
cpp/src/writer/value_chunk_writer.h | 3 +-
.../writer/table_view/tsfile_writer_table_test.cc | 103 +-
cpp/test/writer/tsfile_writer_test.cc | 6 +-
.../apache/tsfile/common/conf/TSFileConfig.java | 80 ++
.../tsfile/common/conf/TSFileDescriptor.java | 6 +
.../tsfile/write/chunk/AlignedChunkWriterImpl.java | 11 +-
.../tsfile/write/schema/MeasurementSchema.java | 4 +-
.../tsfile/write/schema/TimeseriesSchema.java | 4 +-
.../write/schema/VectorMeasurementSchema.java | 107 +-
.../apache/tsfile/write/writer/TsFileIOWriter.java | 4 +
.../org/apache/tsfile/write/ChunkRewriteTest.java | 2 +-
.../apache/tsfile/write/TsFileIOWriterTest.java | 137 ++-
98 files changed, 3347 insertions(+), 2817 deletions(-)
delete mode 100644 cpp/src/common/tsfile_mgr.cc
delete mode 100644 cpp/src/common/tsfile_mgr.h
