Skip to content

Commit 4fbf8b4

Browse files
fix: update data type to Int64 for detect schema (#83)
Int64 to Float64 change is applicable for `TestSmokeLoadWithK6Stream`
1 parent d5189cd commit 4fbf8b4

File tree

2 files changed

+192
-1
lines changed

2 files changed

+192
-1
lines changed

model.go

+191
Original file line numberDiff line numberDiff line change
@@ -265,6 +265,197 @@ const FlogJsonSchema string = `{
265265
],
266266
"metadata": {}
267267
}`
268+
const DetectSchema_SchemaBody string = `{
269+
"fields": [
270+
{
271+
"name": "app_meta",
272+
"data_type": "Utf8",
273+
"nullable": true,
274+
"dict_id": 0,
275+
"dict_is_ordered": false,
276+
"metadata": {}
277+
},
278+
{
279+
"name": "device_id",
280+
"data_type": "Int64",
281+
"nullable": true,
282+
"dict_id": 0,
283+
"dict_is_ordered": false,
284+
"metadata": {}
285+
},
286+
{
287+
"name": "host",
288+
"data_type": "Utf8",
289+
"nullable": true,
290+
"dict_id": 0,
291+
"dict_is_ordered": false,
292+
"metadata": {}
293+
},
294+
{
295+
"name": "level",
296+
"data_type": "Utf8",
297+
"nullable": true,
298+
"dict_id": 0,
299+
"dict_is_ordered": false,
300+
"metadata": {}
301+
},
302+
{
303+
"name": "location",
304+
"data_type": "Utf8",
305+
"nullable": true,
306+
"dict_id": 0,
307+
"dict_is_ordered": false,
308+
"metadata": {}
309+
},
310+
{
311+
"name": "message",
312+
"data_type": "Utf8",
313+
"nullable": true,
314+
"dict_id": 0,
315+
"dict_is_ordered": false,
316+
"metadata": {}
317+
},
318+
{
319+
"name": "os",
320+
"data_type": "Utf8",
321+
"nullable": true,
322+
"dict_id": 0,
323+
"dict_is_ordered": false,
324+
"metadata": {}
325+
},
326+
{
327+
"name": "p_metadata",
328+
"data_type": "Utf8",
329+
"nullable": true,
330+
"dict_id": 0,
331+
"dict_is_ordered": false,
332+
"metadata": {}
333+
},
334+
{
335+
"name": "p_tags",
336+
"data_type": "Utf8",
337+
"nullable": true,
338+
"dict_id": 0,
339+
"dict_is_ordered": false,
340+
"metadata": {}
341+
},
342+
{
343+
"name": "p_timestamp",
344+
"data_type": {
345+
"Timestamp": [
346+
"Millisecond",
347+
null
348+
]
349+
},
350+
"nullable": true,
351+
"dict_id": 0,
352+
"dict_is_ordered": false,
353+
"metadata": {}
354+
},
355+
{
356+
"name": "process_id",
357+
"data_type": "Int64",
358+
"nullable": true,
359+
"dict_id": 0,
360+
"dict_is_ordered": false,
361+
"metadata": {}
362+
},
363+
{
364+
"name": "request_body",
365+
"data_type": "Utf8",
366+
"nullable": true,
367+
"dict_id": 0,
368+
"dict_is_ordered": false,
369+
"metadata": {}
370+
},
371+
{
372+
"name": "response_time",
373+
"data_type": "Int64",
374+
"nullable": true,
375+
"dict_id": 0,
376+
"dict_is_ordered": false,
377+
"metadata": {}
378+
},
379+
{
380+
"name": "runtime",
381+
"data_type": "Utf8",
382+
"nullable": true,
383+
"dict_id": 0,
384+
"dict_is_ordered": false,
385+
"metadata": {}
386+
},
387+
{
388+
"name": "session_id",
389+
"data_type": "Utf8",
390+
"nullable": true,
391+
"dict_id": 0,
392+
"dict_is_ordered": false,
393+
"metadata": {}
394+
},
395+
{
396+
"name": "source_time",
397+
"data_type": {
398+
"Timestamp": [
399+
"Millisecond",
400+
null
401+
]
402+
},
403+
"nullable": true,
404+
"dict_id": 0,
405+
"dict_is_ordered": false,
406+
"metadata": {}
407+
},
408+
{
409+
"name": "status_code",
410+
"data_type": "Int64",
411+
"nullable": true,
412+
"dict_id": 0,
413+
"dict_is_ordered": false,
414+
"metadata": {}
415+
},
416+
{
417+
"name": "timezone",
418+
"data_type": "Utf8",
419+
"nullable": true,
420+
"dict_id": 0,
421+
"dict_is_ordered": false,
422+
"metadata": {}
423+
},
424+
{
425+
"name": "user_agent",
426+
"data_type": "Utf8",
427+
"nullable": true,
428+
"dict_id": 0,
429+
"dict_is_ordered": false,
430+
"metadata": {}
431+
},
432+
{
433+
"name": "user_id",
434+
"data_type": "Int64",
435+
"nullable": true,
436+
"dict_id": 0,
437+
"dict_is_ordered": false,
438+
"metadata": {}
439+
},
440+
{
441+
"name": "uuid",
442+
"data_type": "Utf8",
443+
"nullable": true,
444+
"dict_id": 0,
445+
"dict_is_ordered": false,
446+
"metadata": {}
447+
},
448+
{
449+
"name": "version",
450+
"data_type": "Utf8",
451+
"nullable": true,
452+
"dict_id": 0,
453+
"dict_is_ordered": false,
454+
"metadata": {}
455+
}
456+
],
457+
"metadata": {}
458+
}`
268459

269460
const SchemaBody string = `{
270461
"fields": [

quest_test.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ func TestSmokeCreateStream(t *testing.T) {
6161
}
6262

6363
func TestSmokeDetectSchema(t *testing.T) {
64-
DetectSchema(t, NewGlob.QueryClient, SampleJson, SchemaBody)
64+
DetectSchema(t, NewGlob.QueryClient, SampleJson, DetectSchema_SchemaBody)
6565
}
6666

6767
func TestSmokeIngestEventsToStream(t *testing.T) {

0 commit comments

Comments
 (0)