Skip to content

Commit 89a05e9

Browse files
committed
adding processed spat topic and updating processed bsm index
1 parent 3524ee0 commit 89a05e9

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

jikkou/kafka-topics-values.yaml

+1
Original file line numberDiff line numberDiff line change
@@ -172,6 +172,7 @@ apps:
172172
- topic.DeduplicatedOdeRawEncodedTIMJson
173173
- topic.DeduplicatedOdeBsmJson
174174
- topic.DeduplicatedProcessedBsm
175+
- topic.DeduplicatedProcessedSpat
175176
tableTopics: {}
176177
customTopics: {}
177178
kafkaconnect:

mongo/create_indexes.js

+1-1
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ const odeCollections = [
8888
const geoJsonConverterCollections = [
8989
{name: "ProcessedMap", ttlField: "recordGeneratedAt", timeField: "properties.timeStamp", intersectionField: "properties.intersectionId", expireTime: expireSeconds},
9090
{name: "ProcessedSpat", ttlField: "recordGeneratedAt", timeField: "utcTimeStamp", intersectionField: "intersectionId", expireTime: expireSeconds},
91-
{name: "ProcessedBsm", ttlField: "recordGeneratedAt", timeField: "timeStamp", geoSpatialField: "features.geometry.coordinates", expireTime: expireSeconds},
91+
{name: "ProcessedBsm", ttlField: "recordGeneratedAt", timeField: "timeStamp", geoSpatialField: "geometry.coordinates", expireTime: expireSeconds},
9292
];
9393

9494

0 commit comments

Comments
 (0)