@@ -240,7 +240,7 @@ impl FunctionExpression for ParseInfluxDBFn {
240
240
}
241
241
242
242
fn tags_kind ( ) -> Kind {
243
- Kind :: object ( Collection :: from_unknown ( Kind :: bytes ( ) ) )
243
+ Kind :: object ( Collection :: from_unknown ( Kind :: bytes ( ) ) ) | Kind :: null ( )
244
244
}
245
245
246
246
fn gauge_kind ( ) -> Kind {
@@ -253,7 +253,7 @@ fn metric_kind() -> BTreeMap<Field, Kind> {
253
253
btreemap ! {
254
254
"name" => Kind :: bytes( ) ,
255
255
"tags" => tags_kind( ) ,
256
- "timestamp" => Kind :: timestamp( ) ,
256
+ "timestamp" => Kind :: timestamp( ) | Kind :: null ( ) ,
257
257
"kind" => Kind :: bytes( ) ,
258
258
"gauge" => gauge_kind( ) ,
259
259
}
@@ -276,7 +276,7 @@ mod test {
276
276
parse_influxdb => ParseInfluxDB ;
277
277
278
278
influxdb_valid {
279
- args: func_args![ value: format! ( "cpu,host=A,region=us-west usage_system=64i,usage_user=10u,temperature=50.5,on=true,sleep=false 1590488773254420000" ) ] ,
279
+ args: func_args![ value: "cpu,host=A,region=us-west usage_system=64i,usage_user=10u,temperature=50.5,on=true,sleep=false 1590488773254420000" ] ,
280
280
want: Ok ( Value :: from( vec![
281
281
Value :: from( btreemap! {
282
282
"name" => "cpu_usage_system" ,
@@ -373,7 +373,7 @@ mod test {
373
373
}
374
374
375
375
influxdb_valid_no_tags {
376
- args: func_args![ value: format! ( "cpu usage_system=64i,usage_user=10i 1590488773254420000" ) ] ,
376
+ args: func_args![ value: "cpu usage_system=64i,usage_user=10i 1590488773254420000" ] ,
377
377
want: Ok ( Value :: from( vec![
378
378
Value :: from( btreemap! {
379
379
"name" => "cpu_usage_system" ,
0 commit comments