Skip to content

Commit 167d454

Browse files
committed
* log-exporter: export action and event in parquet format
Signed-off-by: neo <[email protected]>
1 parent 7bb4022 commit 167d454

File tree

3 files changed

+2
-45
lines changed

3 files changed

+2
-45
lines changed

ext/log-exporter/src/main/java/core/log/domain/ActionLogEntry.java

Lines changed: 0 additions & 44 deletions
This file was deleted.

ext/log-exporter/src/main/java/core/log/domain/ActionLogSchema.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ public ActionLogSchema() {
2828
.optionalString("error_code")
2929
.optionalString("error_message")
3030
.requiredLong("elapsed")
31-
.name("context").type().optional().type(SchemaBuilder.map().values().stringType())
31+
.name("context").type().optional().type(SchemaBuilder.map().values(SchemaBuilder.array().items().stringType()))
3232
.name("stats").type().optional().map().values().doubleType()
3333
.name("perf_stats").type().optional().map().values().longType()
3434
.endRecord();

ext/log-exporter/src/test/java/core/log/kafka/ActionLogMessageHandlerTest.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,7 @@ void handle() throws IOException {
4747
message.result = "OK";
4848
message.host = "host";
4949
message.elapsed = 1000L;
50+
message.context = Map.of("key", List.of("value1", "value2"));
5051
message.performanceStats = Map.of();
5152
message.traceLog = "trace";
5253
handler.handle(List.of(new Message<>("key", message)));

0 commit comments

Comments
 (0)