Functions — github.com/LearningJournal/Kafka-Streams-Real-time-Stream-Processing

hub / github.com/LearningJournal/Kafka-Streams-Real-time-Stream-Processing / functions

Functions1,924 in github.com/LearningJournal/Kafka-Streams-Real-time-Stream-Processing

⨍ Functions 1,924◇ Types & classes 246

↓ 143 callersMethodput

(int field$, java.lang.Object value$)

avro-consumer/src/main/java/guru/learningjournal/kafka/examples/StockData.java:91

↓ 31 callersMethodgetName

()

ktable-aggregate/src/main/java/guru/learningjournal/kafka/examples/types/Employee.java:42

↓ 30 callersMethodget

(int field$)

avro-consumer/src/main/java/guru/learningjournal/kafka/examples/StockData.java:71

↓ 30 callersMethodstart

()

ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/AppRestService.java:108

↓ 20 callersMethodbuild

()

avro-consumer/src/main/java/guru/learningjournal/kafka/examples/StockData.java:997

↓ 18 callersMethodadd

(final ClicksByNewsType newValue)

top3-inventories/src/main/java/guru/learningjournal/kafka/examples/common/Top3NewsTypes.java:54

↓ 14 callersMethodput

(int field$, java.lang.Object value$)

pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:107

↓ 9 callersMethodput

(int field$, java.lang.Object value$)

pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:107

↓ 8 callersMethodtoString

()

topology-test/src/main/java/guru/learningjournal/kafka/examples/types/AdClick.java:51

↓ 7 callersMethodCampaignPerformance

()

topology-test/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:43

↓ 7 callersMethodgetNewsType

()

top3-inventories/src/main/java/guru/learningjournal/kafka/examples/types/AdInventories.java:36

↓ 7 callersMethodwithCampaigner

(String campaigner)

topology-test/src/main/java/guru/learningjournal/kafka/examples/types/AdClick.java:46

↓ 6 callersMethodconfigure

(Map<String, ?> config, boolean isKey)

pos-fanout/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:37

↓ 6 callersMethodgetCampaigner

()

topology-test/src/main/java/guru/learningjournal/kafka/examples/types/AdClick.java:36

↓ 6 callersMethodremove

(final ClicksByNewsType oldValue)

top3-inventories/src/main/java/guru/learningjournal/kafka/examples/common/Top3NewsTypes.java:67

↓ 6 callersMethodtoString

()

pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:323

↓ 6 callersMethodwithImpressionID

(String impressionID)

topology-test/src/main/java/guru/learningjournal/kafka/examples/types/AdClick.java:31

↓ 5 callersMethodAdImpression

()

topology-test/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:59

↓ 5 callersMethodequals

(Object other)

pojo-from-json/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:121

↓ 5 callersMethodgetAdImpressions

()

topology-test/src/main/java/guru/learningjournal/kafka/examples/types/CampaignPerformance.java:39

↓ 5 callersMethodgetDeliveryAddress

Gets the value of the 'DeliveryAddress' field. @return The value of the 'DeliveryAddress' field.

pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:375

↓ 5 callersMethodgetDeliveryAddress

()

pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:293

↓ 4 callersMethodAdClick

()

topology-test/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:75

↓ 4 callersMethodconfigure

(Map<String, ?> config, boolean isKey)

top3-inventories/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:37

↓ 4 callersMethodgetDeliveryType

Gets the value of the 'DeliveryType' field. @return The value of the 'DeliveryType' field.

pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:359

↓ 4 callersMethodgetDeliveryType

()

pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:278

↓ 4 callersMethodgetEmployeeCount

()

ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/types/DepartmentAggregate.java:39

↓ 4 callersMethodgetEmployeeCount

()

ktable-aggregate/src/main/java/guru/learningjournal/kafka/examples/types/DepartmentAggregate.java:39

↓ 4 callersMethodgetSalary

()

ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/types/Employee.java:72

↓ 4 callersMethodgetSalary

()

ktable-aggregate/src/main/java/guru/learningjournal/kafka/examples/types/Employee.java:72

↓ 4 callersMethodgetTotalSalary

()

ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/types/DepartmentAggregate.java:24

↓ 4 callersMethodgetTotalSalary

()

ktable-aggregate/src/main/java/guru/learningjournal/kafka/examples/types/DepartmentAggregate.java:24

↓ 4 callersMethodtoString

()

pos-simulator/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:238

↓ 3 callersMethodclose

()

ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:61

↓ 3 callersMethodclose

()

time-check/src/main/java/guru/learningjournal/kafka/examples/TimeCheckDemo.java:73

↓ 3 callersMethodclose

()

pos-fanout/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:61

↓ 3 callersMethodconfigure

(Map<String, ?> config, boolean isKey)

ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:37

↓ 3 callersMethodconfigure

(Map<String, ?> config, boolean isKey)

topology-test/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:37

↓ 3 callersMethodget

(int field$)

pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:83

↓ 3 callersMethodgetAdClicks

()

topology-test/src/main/java/guru/learningjournal/kafka/examples/types/CampaignPerformance.java:54

↓ 3 callersMethodgetAdditionalProperties

()

custom-sink/src/main/java/guru/learningjournal/kafka/examples/types/TableMap.java:40

↓ 3 callersMethodgetCreatedTime

()

time-check/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:83

↓ 3 callersMethodgetTotalAmount

()

rewards-table/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:173

↓ 3 callersMethodnewBuilder

Creates a new PosInvoice RecordBuilder. @return A new PosInvoice RecordBuilder

pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:407

↓ 3 callersMethodnewBuilder

Creates a new PosInvoice RecordBuilder. @return A new PosInvoice RecordBuilder

pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:407

↓ 3 callersMethodput

(int field$, java.lang.Object value$)

avro-producer/src/main/java/guru/learningjournal/kafka/examples/StockData.java:92

↓ 3 callersMethodwithAvgSalary

(Double avgSalary)

ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/types/DepartmentAggregate.java:64

↓ 3 callersMethodwithAvgSalary

(Double avgSalary)

ktable-aggregate/src/main/java/guru/learningjournal/kafka/examples/types/DepartmentAggregate.java:64

↓ 3 callersMethodwithBuilder

(StreamsBuilder builder)

topology-test/src/main/java/guru/learningjournal/kafka/examples/AppTopology.java:32

↓ 3 callersMethodwithEmployeeCount

(Integer employeeCount)

ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/types/DepartmentAggregate.java:49

↓ 3 callersMethodwithEmployeeCount

(Integer employeeCount)

ktable-aggregate/src/main/java/guru/learningjournal/kafka/examples/types/DepartmentAggregate.java:49

↓ 3 callersMethodwithTotalSalary

(Integer totalSalary)

ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/types/DepartmentAggregate.java:34

↓ 3 callersMethodwithTotalSalary

(Integer totalSalary)

ktable-aggregate/src/main/java/guru/learningjournal/kafka/examples/types/DepartmentAggregate.java:34

↓ 2 callersMethodAdClick

()

ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:75

↓ 2 callersMethodAdImpression

()

ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:59

↓ 2 callersMethodAdInventories

()

top3-inventories/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:43

↓ 2 callersMethodEmployee

()

ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:42

↓ 2 callersMethodEmployee

()

kstream-aggregate/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:42

↓ 2 callersMethodEmployee

()

ktable-aggregate/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:42

↓ 2 callersMethodNotification

()

rewards-table/src/main/java/guru/learningjournal/kafka/examples/PosSerdes.java:61

↓ 2 callersMethodPaymentConfirmation

()

stream-join/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:58

↓ 2 callersMethodPaymentRequest

()

stream-join/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:42

↓ 2 callersMethodPosInvoice

()

rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/PosSerdes.java:45

↓ 2 callersMethodPosInvoice

()

pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/PosSerdes.java:39

↓ 2 callersMethodPosInvoice

()

pos-fanout/src/main/java/guru/learningjournal/kafka/examples/PosSerdes.java:45

↓ 2 callersMethodSimpleInvoice

()

counting-window/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:42

↓ 2 callersMethodStockTicker

()

custom-window/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:38

↓ 2 callersMethodUserClicks

()

counting-session/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:42

↓ 2 callersMethodUserDetails

()

last-login/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:42

↓ 2 callersMethodbuild

()

pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:1313

↓ 2 callersMethodclose

()

ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:61

↓ 2 callersMethodclose

()

transactional-producer/src/main/java/guru/learningjournal/kafka/examples/JsonSerializer.java:60

↓ 2 callersMethodclose

()

json-producer/src/main/java/guru/learningjournal/kafka/examples/JsonSerializer.java:63

↓ 2 callersMethodclose

()

topology-test/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:61

↓ 2 callersMethodconfigure

(Map<String, ?> config, boolean isKey)

custom-window/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:37

↓ 2 callersMethodconfigure

(Map<String, ?> config, boolean isKey)

rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:37

↓ 2 callersMethodconfigure

(Map<String, ?> config, boolean isKey)

ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:37

↓ 2 callersMethodconfigure

(Map<String, ?> config, boolean isKey)

last-login/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:37

↓ 2 callersMethodconfigure

(Map<String, ?> config, boolean isKey)

stream-join/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:37

↓ 2 callersMethodconfigure

(Map<String, ?> config, boolean isKey)

kstream-aggregate/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:37

↓ 2 callersMethodconfigure

(Map<String, ?> config, boolean isKey)

rewards-table/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:37

↓ 2 callersMethodconfigure

(Map<String, ?> config, boolean isKey)

ktable-aggregate/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:37

↓ 2 callersMethodconfigure

(Map<String, ?> config, boolean isKey)

custom-sink/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:37

↓ 2 callersMethodget

(int field$)

pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:83

↓ 2 callersMethodgetCampaigner

()

ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/types/AdClick.java:36

↓ 2 callersMethodgetClicks

()

top3-inventories/src/main/java/guru/learningjournal/kafka/examples/types/ClicksByNewsType.java:36

↓ 2 callersMethodgetCreatedTime

()

counting-session/src/main/java/guru/learningjournal/kafka/examples/types/UserClicks.java:42

↓ 2 callersMethodgetCreatedTime

()

stream-join/src/main/java/guru/learningjournal/kafka/examples/types/PaymentRequest.java:48

↓ 2 callersMethodgetCreatedTime

()

stream-join/src/main/java/guru/learningjournal/kafka/examples/types/PaymentConfirmation.java:39

↓ 2 callersMethodgetCreatedTime

()

counting-window/src/main/java/guru/learningjournal/kafka/examples/types/SimpleInvoice.java:42

↓ 2 callersMethodgetCustomerCardNo

()

rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:158

↓ 2 callersMethodgetCustomerCardNo

()

rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:45

↓ 2 callersMethodgetCustomerCardNo

()

rewards-table/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:158

↓ 2 callersMethodgetCustomerType

Gets the value of the 'CustomerType' field. @return The value of the 'CustomerType' field.

pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:215

↓ 2 callersMethodgetCustomerType

()

pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:143

↓ 2 callersMethodgetEarnedLoyaltyPoints

()

rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:75

↓ 2 callersMethodgetEmployeeCount

()

kstream-aggregate/src/main/java/guru/learningjournal/kafka/examples/types/DepartmentAggregate.java:39

↓ 2 callersMethodgetInvoiceNumber

Gets the value of the 'InvoiceNumber' field. @return The value of the 'InvoiceNumber' field.

pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:135

↓ 2 callersMethodgetInvoiceNumber

()

pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:68

↓ 2 callersMethodgetOTP

()

stream-join/src/main/java/guru/learningjournal/kafka/examples/types/PaymentRequest.java:108

next →1–100 of 1,924, ranked by callers