Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Pipe: Support 'format'='tsfile' option in table model data sync sinks #14108

Merged
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
50 commits
Select commit Hold shift + click to select a range
727d667
Pipe: Sink supports table model TSFile format
luoluoyuyu Nov 15, 2024
205eb0e
Modify the sorting algorithm
luoluoyuyu Nov 18, 2024
c40cc9d
Modify code format
luoluoyuyu Nov 18, 2024
3168aca
Merge branch 'apache:master' into support-table-model-file-format
luoluoyuyu Nov 18, 2024
7a1c7d8
Modify code format
luoluoyuyu Nov 18, 2024
ad580d6
add license
luoluoyuyu Nov 18, 2024
a1152d5
add license
luoluoyuyu Nov 18, 2024
bf01dce
add test
luoluoyuyu Nov 18, 2024
e248253
update PipeTableModeTsFileBuilder
luoluoyuyu Nov 18, 2024
f3d5671
update IoTDBPipeDataSinkIT
luoluoyuyu Nov 18, 2024
3676d6a
Fix array out of bounds
luoluoyuyu Nov 19, 2024
add5ad6
fix PipeTableModelTabletEventSorter
luoluoyuyu Nov 19, 2024
189e086
add UT
luoluoyuyu Nov 19, 2024
4c76405
fix ci
luoluoyuyu Nov 19, 2024
211beac
modify comment
luoluoyuyu Nov 21, 2024
3108ccf
fix PipeTransferTabletRawReqV2
luoluoyuyu Nov 21, 2024
8a5ae65
Merge branch 'apache:master' into support-table-model-file-format
luoluoyuyu Nov 21, 2024
68640c5
update PipeTableModelTabletEventSorter
luoluoyuyu Nov 26, 2024
c869757
Refactor
luoluoyuyu Nov 27, 2024
051c1f8
fix
luoluoyuyu Dec 3, 2024
658e217
Merge remote-tracking branch 'iotdb/master' into support-table-model-…
luoluoyuyu Dec 3, 2024
715c4dc
update TSFileBuilder
luoluoyuyu Dec 3, 2024
207e56d
update PipeTabletEventSorterTest
luoluoyuyu Dec 3, 2024
806f6fb
fix
luoluoyuyu Dec 3, 2024
802dd46
Merge branch 'master' into support-table-model-file-format
luoluoyuyu Dec 5, 2024
94c1978
Merge remote-tracking branch 'origin/support-table-model-file-format'…
luoluoyuyu Dec 5, 2024
bf8ac82
update OpcUaNameSpace
luoluoyuyu Dec 5, 2024
f4a7ed5
update PipeTableModelTabletEventSorter
luoluoyuyu Dec 5, 2024
2b6c911
fix
luoluoyuyu Dec 10, 2024
08f4c8a
modify code format
luoluoyuyu Dec 10, 2024
ccb628f
Merge branch 'master' into support-table-model-file-format
luoluoyuyu Dec 12, 2024
a10f4e7
add IT
luoluoyuyu Dec 14, 2024
527eaa4
spotless
luoluoyuyu Dec 14, 2024
b0a112f
spotless
luoluoyuyu Dec 14, 2024
1051ce4
fix IT
luoluoyuyu Dec 15, 2024
0306ae0
add test case
luoluoyuyu Dec 16, 2024
4412268
spotless
luoluoyuyu Dec 16, 2024
d4292cf
fix
luoluoyuyu Dec 16, 2024
5b8820e
add test case
luoluoyuyu Dec 16, 2024
9dd29ac
update PipeTableModeTsFileBuilder
luoluoyuyu Dec 17, 2024
972b172
modify test case
luoluoyuyu Dec 17, 2024
b5a924f
modify session pool max size
luoluoyuyu Dec 17, 2024
a468b79
close session pool
luoluoyuyu Dec 18, 2024
3972607
modify TableModelUtils
luoluoyuyu Dec 18, 2024
84a931b
Merge remote-tracking branch 'iotdb/master' into support-table-model-…
luoluoyuyu Jan 3, 2025
f7e984d
The receiver sorting rules are changed to be consistent with Session
luoluoyuyu Jan 3, 2025
89b7d46
update PipeTableModelTabletEventSorter
luoluoyuyu Jan 6, 2025
314dc52
refactor
SteveYurongSu Jan 7, 2025
0d1e084
Merge branch 'master' of https://github.com/apache/iotdb into pr/14108
SteveYurongSu Jan 7, 2025
bc97e11
refactor
SteveYurongSu Jan 7, 2025
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view

Large diffs are not rendered by default.

Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,7 @@ private void testInsertNullValueTemplate(
TableModelUtils.createDataBaseAndTable(senderEnv, "test", "test");

if (insertType == InsertType.SESSION_INSERT_TABLET) {
TableModelUtils.insertDataByTablet("test", "test", 0, 200, senderEnv, true);
TableModelUtils.insertTablet("test", "test", 0, 200, senderEnv, true);
} else if (insertType == InsertType.SQL_INSERT) {
TableModelUtils.insertData("test", "test", 0, 200, senderEnv, true);
}
Expand All @@ -96,7 +96,7 @@ private void testInsertNullValueTemplate(
}

if (insertType == InsertType.SESSION_INSERT_TABLET) {
TableModelUtils.insertDataByTablet("test", "test", 200, 400, senderEnv, true);
TableModelUtils.insertTablet("test", "test", 200, 400, senderEnv, true);
} else if (insertType == InsertType.SQL_INSERT) {
TableModelUtils.insertData("test", "test", 200, 400, senderEnv, true);
}
Expand Down
Loading
Loading