Skip to content

Commit 146a79a

Browse files
authored
VY_Final_Tweaks
1 parent 46e8d95 commit 146a79a

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

calculating-bus-delay-time/README.adoc

+4-3
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,8 @@ See http://www.confluent.io/stream-processing-cookbook/ksql-recipes/calculating-
55
== Introduction
66

77
Many events happen on a time schedule where there is a scheduled time of arrival and an actual time of arrival. With these two data points, you are able to track the amount of time in which your event was delayed. By tracking this, you can better predict future delays and monitor your real-time progress.
8-
In this example, we will use buses to demonstrate how we can calculate in real-time the delays for every bus as it executes its route. After loading your static bus schedule into a KTable, you can then populate a live feed showing the number of minutes a bus is delayed from its expected course.
8+
9+
In this example, we will use buses to demonstrate how we can calculate in real time the delays for every bus as it executes its route. After loading your static bus schedule into a KTable, you can then populate a live feed showing the number of minutes a bus is delayed from its expected course.
910

1011

1112
== Pre-reqs:
@@ -47,7 +48,7 @@ docker-compose up -d
4748
docker-compose exec ksql-cli ksql http://ksql-server:8088
4849
----
4950

50-
4. The bus schedule with expected arrival times is held as JSON data on a Kafka topic, with the ETA stored as a Unix timestamp. Register a KSQL Table on this topic:
51+
4. The bus schedule with expected arrival times is held as JSON data on a Kafka topic, with the ETA stored as a Unix timestamp. Register a KSQL table on this topic:
5152
+
5253
[source,sql]
5354
----
@@ -59,7 +60,7 @@ CREATE TABLE BUS_SCHEDULE (ROUTE_ID INTEGER, \
5960
KEY='STOP_NUM');
6061
----
6162

62-
5. As buses complete their routes, they send events detailing the Unix timestamp of their arrival at a stop to a Kafka topic. Register this topic as a KSQL Stream:
63+
5. As buses complete their routes, they send events detailing the Unix timestamp of their arrival at a stop to a Kafka topic. Register this topic as a KSQL stream:
6364
+
6465
[source,sql]
6566
----

0 commit comments

Comments
 (0)