MCPcopy Create free account

hub / github.com/SciSpike/kafka-lab / functions

Functions43 in github.com/SciSpike/kafka-lab

⨍ Functions 43◇ Types & classes 15
↓ 4 callersMethodstart
()
labs/06-Streaming/iot-kafka/gps-pump/src/main/java/app/GpsDeviceSimulator.java:35
↓ 3 callersMethodreset
()
labs/06-Streaming/iot-kafka/gps-pump/src/main/java/app/GpsDeviceSimulator.java:24
↓ 3 callersMethodtoString
()
labs/06-Streaming/iot-kafka/gps-monitor/src/main/java/app/LocationKey.java:35
↓ 2 callersMethodcreateOnlineMessage
(String key, String topic)
labs/04-Implement-Topics-And-Partitions/device-monitor/src/main/java/app/DeviceMonitor.java:123
↓ 2 callersMethodequals
(Object obj)
labs/06-Streaming/iot-kafka/gps-monitor/src/main/java/app/LocationKey.java:27
↓ 1 callersMethodcreateConsumer
()
labs/04-Implement-Topics-And-Partitions/device-monitor/src/main/java/app/DeviceMonitor.java:76
↓ 1 callersMethodcreateOfflineMessage
(String key, String topic)
labs/04-Implement-Topics-And-Partitions/device-monitor/src/main/java/app/DeviceMonitor.java:118
↓ 1 callersMethodcreateProducer
()
labs/04-Implement-Topics-And-Partitions/device-monitor/src/main/java/app/DeviceMonitor.java:99
↓ 1 callersMethodcreateSimulators
( KafkaProducer<String, String> producer, int count)
labs/04-Implement-Topics-And-Partitions/device-simulator/src/main/java/app/DeviceSimulatorApp.java:33
↓ 1 callersMethodgetGeoHash
()
labs/06-Streaming/iot-kafka/gps-monitor/src/main/java/app/LocationKey.java:14
↓ 1 callersMethodgetProperties
()
labs/06-Streaming/iot-kafka/gps-monitor/src/main/java/app/GpsMonitor.java:65
↓ 1 callersMethodgetProperties
()
labs/06-Streaming/iot-kafka/gps-pump/src/main/java/app/GpsDeviceSimulatorApp.java:32
↓ 1 callersMethodgetProperties
()
labs/06-Streaming/wordcount-kafka-streaming/src/main/java/app/StreamExample.java:75
↓ 1 callersMethodgetProperties
()
labs/04-Implement-Topics-And-Partitions/device-simulator/src/main/java/app/DeviceSimulatorApp.java:46
↓ 1 callersMethodheartbeatMissing
(Date lastDate)
labs/04-Implement-Topics-And-Partitions/device-monitor/src/main/java/app/DeviceMonitor.java:114
↓ 1 callersMethodprocess
(Record<String, String> record)
labs/06-Streaming/heartbeat-streams/src/main/java/app/HeartbeatMonitor.java:107
↓ 1 callersMethodsetupMonitoring
(final KafkaProducer<String, String> producer, String topic)
labs/04-Implement-Topics-And-Partitions/device-monitor/src/main/java/app/DeviceMonitor.java:50
↓ 1 callersMethodshutdown
()
labs/06-Streaming/iot-kafka/gps-pump/src/main/java/app/GpsDeviceSimulator.java:63
↓ 1 callersMethodshutdown
()
labs/04-Implement-Topics-And-Partitions/device-simulator/src/main/java/app/DeviceSimulator.java:44
↓ 1 callersMethodsleep
(long ms)
labs/classroom/A4-Slow-Poll-Eviction/slow-consumer/src/main/java/app/SlowConsumer.java:115
MethodDeviceSimulator
(final String deviceId, final KafkaProducer<String, String> producer)
labs/04-Implement-Topics-And-Partitions/device-simulator/src/main/java/app/DeviceSimulator.java:19
MethodGpsDeviceSimulator
(final KafkaProducer<String, String> producer, String dataFile)
labs/06-Streaming/iot-kafka/gps-pump/src/main/java/app/GpsDeviceSimulator.java:19
MethodLocationKey
(String objectId, double latitude, double longitude)
labs/06-Streaming/iot-kafka/gps-monitor/src/main/java/app/LocationKey.java:9
MethodTuple
(T1 t1, T2 t2)
labs/04-Implement-Topics-And-Partitions/device-monitor/src/main/java/app/DeviceMonitor.java:131
MethodcheckForSilentDevices
(long now)
labs/06-Streaming/heartbeat-streams/src/main/java/app/HeartbeatMonitor.java:121
MethodgetObjectId
()
labs/06-Streaming/iot-kafka/gps-monitor/src/main/java/app/LocationKey.java:18
MethodhashCode
()
labs/06-Streaming/iot-kafka/gps-monitor/src/main/java/app/LocationKey.java:22
Methodinit
(ProcessorContext<String, String> context)
labs/06-Streaming/heartbeat-streams/src/main/java/app/HeartbeatMonitor.java:87
Methodmain
(String[] args)
labs/06-Streaming/iot-kafka/gps-monitor/src/main/java/app/GpsMonitor.java:21
Methodmain
(String[] args)
labs/06-Streaming/iot-kafka/gps-pump/src/main/java/app/GpsDeviceSimulatorApp.java:15
Methodmain
(String[] args)
labs/06-Streaming/heartbeat-streams/src/main/java/app/HeartbeatMonitor.java:47
Methodmain
(String[] args)
labs/06-Streaming/wordcount-kafka-streaming/src/main/java/app/StreamExample.java:21
Methodmain
(String[] args)
labs/04-Implement-Topics-And-Partitions/device-monitor/src/main/java/app/DeviceMonitor.java:20
Methodmain
(String[] args)
labs/04-Implement-Topics-And-Partitions/device-simulator/src/main/java/app/DeviceSimulatorApp.java:16
Methodmain
(String[] args)
labs/classroom/A5-Exactly-Once/txn-producer/src/main/java/app/TxnProducer.java:30
Methodmain
(String[] args)
labs/classroom/A4-Slow-Poll-Eviction/slow-consumer/src/main/java/app/SlowConsumer.java:37
Methodmain
(String[] args)
labs/02-Publish-And-Subscribe/producer/src/main/java/app/Producer.java:19
Methodmain
(String[] args)
labs/02-Publish-And-Subscribe/consumer/src/main/java/app/Consumer.java:17
MethodonPartitionsAssigned
(Collection<TopicPartition> partitions)
labs/classroom/A4-Slow-Poll-Eviction/slow-consumer/src/main/java/app/SlowConsumer.java:77
MethodonPartitionsRevoked
(Collection<TopicPartition> partitions)
labs/classroom/A4-Slow-Poll-Eviction/slow-consumer/src/main/java/app/SlowConsumer.java:73
Methodrun
()
labs/06-Streaming/iot-kafka/gps-pump/src/main/java/app/GpsDeviceSimulator.java:40
Methodrun
()
labs/04-Implement-Topics-And-Partitions/device-monitor/src/main/java/app/DeviceMonitor.java:54
Methodrun
()
labs/04-Implement-Topics-And-Partitions/device-simulator/src/main/java/app/DeviceSimulator.java:30