Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
35 commits
Select commit Hold shift + click to select a range
d898e57
feat: support attribute insertion in OTAP transform
ThomsonTan Jan 7, 2026
cd1158c
Adding missing definition
ThomsonTan Jan 8, 2026
e4399b5
Merge branch 'main' into add_insert_attributes
ThomsonTan Jan 8, 2026
fc259ac
Format
ThomsonTan Jan 9, 2026
ad9e92e
Check empty slice
ThomsonTan Jan 9, 2026
15b6820
Merge branch 'main' into add_insert_attributes
ThomsonTan Jan 9, 2026
a01a34c
Merge branch 'main' into add_insert_attributes
ThomsonTan Jan 13, 2026
c3c48ba
Merge branch 'main' into add_insert_attributes
ThomsonTan Jan 13, 2026
e79db3f
Add Insert action to AttributeProcessor
ThomsonTan Jan 14, 2026
2397800
Format
ThomsonTan Jan 14, 2026
e8beb1c
Fix MetricsRegistryHandle
ThomsonTan Jan 14, 2026
47e9f12
Merge branch 'main' into add_insert_attributes
ThomsonTan Jan 15, 2026
1d6bbd4
Make sure insert doesn't overwrite existing key
ThomsonTan Jan 16, 2026
39a9521
Merge branch 'main' into add_insert_attributes
ThomsonTan Jan 16, 2026
726dbf9
Add test
ThomsonTan Jan 16, 2026
41751db
More format
ThomsonTan Jan 16, 2026
59f54bc
Fix liternal constant
ThomsonTan Jan 16, 2026
86f8eec
Rename literal
ThomsonTan Jan 16, 2026
4dd108e
Fix literal constant
ThomsonTan Jan 16, 2026
e076c61
Merge branch 'main' into add_insert_attributes
ThomsonTan Jan 16, 2026
97c7333
Merge branch 'main' into add_insert_attributes
ThomsonTan Jan 16, 2026
2f7e191
Merge branch 'main' into add_insert_attributes
ThomsonTan Jan 16, 2026
2dcacd0
Update rust/otap-dataflow/crates/otap/src/attributes_processor.rs
ThomsonTan Jan 20, 2026
7ea7ec8
Update rust/otap-dataflow/crates/otap/src/attributes_processor.rs
ThomsonTan Jan 20, 2026
6d70540
Update rust/otap-dataflow/crates/otap/src/attributes_processor.rs
ThomsonTan Jan 20, 2026
cd1afb3
Let unsupported value types cause a config error when insert
ThomsonTan Jan 20, 2026
579799a
Update rust/otap-dataflow/crates/otap/src/attributes_processor.rs
ThomsonTan Jan 20, 2026
92027a8
Extend schema before insert attribute to log batch
ThomsonTan Jan 20, 2026
8309dd1
Merge remote-tracking branch 'origin/main' into add_insert_attributes
ThomsonTan Jan 21, 2026
314bba5
Switch to BTreeMap store insert entries
ThomsonTan Jan 21, 2026
775243d
Apply suggestion from @albertlockett
ThomsonTan Jan 21, 2026
71fe3d2
Use append_str_n for build appends
ThomsonTan Jan 21, 2026
c949a48
use StringArrayAccessor and adaptive array builders in create_inserte…
ThomsonTan Jan 21, 2026
72ccdf6
Address feedback
ThomsonTan Jan 21, 2026
c19621a
Make create_inserted_batch generic
ThomsonTan Jan 21, 2026
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
Original file line number Diff line number Diff line change
Expand Up @@ -72,6 +72,7 @@ fn generate_dict_keys_attribute_batch(
fn bench_transform_attributes(c: &mut Criterion) {
// Pre-create AttributesTransform instances to avoid measuring their creation cost
let single_replace_no_delete = AttributesTransform {
insert: None,
rename: Some(RenameTransform::new(BTreeMap::from_iter([(
"attr24".into(),
"attr_24".into(),
Expand All @@ -80,6 +81,7 @@ fn bench_transform_attributes(c: &mut Criterion) {
};

let single_replace_single_delete = AttributesTransform {
insert: None,
rename: Some(RenameTransform::new(BTreeMap::from_iter([(
"attr24".into(),
"attr_24".into(),
Expand All @@ -88,11 +90,13 @@ fn bench_transform_attributes(c: &mut Criterion) {
};

let no_replace_single_delete = AttributesTransform {
insert: None,
rename: None,
delete: Some(DeleteTransform::new(BTreeSet::from_iter(["attr15".into()]))),
};

let attr3_replace_no_delete = AttributesTransform {
insert: None,
rename: Some(RenameTransform::new(BTreeMap::from_iter([(
"attr3".into(),
"attr_3".into(),
Expand All @@ -101,11 +105,13 @@ fn bench_transform_attributes(c: &mut Criterion) {
};

let no_replace_attr9_delete = AttributesTransform {
insert: None,
rename: None,
delete: Some(DeleteTransform::new(BTreeSet::from_iter(["attr9".into()]))),
};

let attr3_replace_attr9_delete = AttributesTransform {
insert: None,
rename: Some(RenameTransform::new(BTreeMap::from_iter([(
"attr3".into(),
"attr_3".into(),
Expand Down
Loading
Loading