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

↓ 2 callersMethodgetSalary

()

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

↓ 2 callersMethodgetTotalAmount

()

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

↓ 2 callersMethodgetTotalAmount

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

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

↓ 2 callersMethodgetTotalAmount

()

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

↓ 2 callersMethodgetTotalSalary

()

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

↓ 2 callersMethodhashCode

()

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

↓ 2 callersMethodput

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

pojo-from-avro/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:55

↓ 2 callersMethodreadAllFromLocal

()

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

↓ 2 callersMethodsetDeliveryAddressBuilder

Sets the Builder instance for the 'DeliveryAddress' field @param value The builder instance that must be set. @return This builder.

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

↓ 2 callersMethodsetDeliveryAddressBuilder

Sets the Builder instance for the 'DeliveryAddress' field @param value The builder instance that must be set. @return This builder.

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

↓ 2 callersMethodshutdown

()

pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/RunnableProducer.java:64

↓ 2 callersMethodshutdown

()

pos-simulator/src/main/java/guru/learningjournal/kafka/examples/RunnableProducer.java:60

↓ 2 callersMethodshutdown

()

json-consumer/src/main/java/guru/learningjournal/kafka/examples/RunnableConsumer.java:95

↓ 2 callersMethodutcTimeString

(Long timestamp)

counting-session/src/main/java/guru/learningjournal/kafka/examples/CountingSessionApp.java:40

↓ 2 callersMethodwithAvgSalary

(Double avgSalary)

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

↓ 2 callersMethodwithEmployeeCount

(Integer employeeCount)

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

↓ 2 callersMethodwithInvoiceNumber

(String invoiceNumber)

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

↓ 2 callersMethodwithTotalSalary

(Integer totalSalary)

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

↓ 1 callersMethodAdClick

()

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

↓ 1 callersMethodClicksByNewsType

()

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

↓ 1 callersMethodDepartmentAggregate

()

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

↓ 1 callersMethodDepartmentAggregate

()

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

↓ 1 callersMethodDepartmentAggregate

()

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

↓ 1 callersMethodGenericRecord

()

custom-sink/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:42

↓ 1 callersMethodHadoopRecord

()

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

↓ 1 callersMethodHadoopRecord

()

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

↓ 1 callersMethodNotification

()

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

↓ 1 callersMethodNotification

()

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

↓ 1 callersMethodNotification

()

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

↓ 1 callersMethodPaymentConfirmation

()

stream-join/src/main/java/guru/learningjournal/kafka/examples/common/AppTimeExtractor.java:54

↓ 1 callersMethodPaymentRequest

()

stream-join/src/main/java/guru/learningjournal/kafka/examples/common/AppTimeExtractor.java:41

↓ 1 callersMethodPosInvoice

()

time-check/src/main/java/guru/learningjournal/kafka/examples/PosSerdes.java:44

↓ 1 callersMethodPosInvoice

()

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

↓ 1 callersMethodTableMap

()

custom-sink/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:58

↓ 1 callersMethodTickerStack

()

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

↓ 1 callersMethodTop3NewsTypes

()

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

↓ 1 callersMethodUserLogin

()

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

↓ 1 callersMethodavgValue

()

custom-window/src/main/java/guru/learningjournal/kafka/examples/types/TickerStack.java:83

↓ 1 callersMethodbuild

()

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

↓ 1 callersMethodclearDeliveryAddress

Clears the value of the 'DeliveryAddress' field. @return This builder.

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

↓ 1 callersMethodclearDeliveryAddress

Clears the value of the 'DeliveryAddress' field. @return This builder.

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

↓ 1 callersMethodclose

()

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

↓ 1 callersMethodclose

()

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

↓ 1 callersMethodclose

()

partitioned-producer/src/main/java/guru/learningjournal/kafka/examples/OddEvenPartitioner.java:56

↓ 1 callersMethodclose

()

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

↓ 1 callersMethodclose

()

json-consumer/src/main/java/guru/learningjournal/kafka/examples/JsonDeserializer.java:58

↓ 1 callersMethodclose

()

custom-sink/src/main/java/guru/learningjournal/kafka/examples/SinkProcessor.java:47

↓ 1 callersMethodconfigure

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

counting-session/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:37

↓ 1 callersMethodconfigure

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

time-check/src/main/java/guru/learningjournal/kafka/examples/serde/JsonSerializer.java:37

↓ 1 callersMethodconfigure

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

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

↓ 1 callersMethodget

(int field$)

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

↓ 1 callersMethodgetCampaigner

()

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

↓ 1 callersMethodgetCity

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

pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:237

↓ 1 callersMethodgetCity

()

pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:165

↓ 1 callersMethodgetCreatedTime

()

last-login/src/main/java/guru/learningjournal/kafka/examples/types/UserLogin.java:36

↓ 1 callersMethodgetCreatedTime

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

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

↓ 1 callersMethodgetCreatedTime

()

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

↓ 1 callersMethodgetCustomerCardNo

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

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

↓ 1 callersMethodgetCustomerCardNo

()

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

↓ 1 callersMethodgetCustomerType

()

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

↓ 1 callersMethodgetCustomerType

()

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

↓ 1 callersMethodgetDeliveryAddressBuilder

Gets the Builder instance for the 'DeliveryAddress' field and creates one if it doesn't exist yet. @return This builder.

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

↓ 1 callersMethodgetDeliveryAddressBuilder

Gets the Builder instance for the 'DeliveryAddress' field and creates one if it doesn't exist yet. @return This builder.

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

↓ 1 callersMethodgetDeliveryType

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

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

↓ 1 callersMethodgetDeliveryType

()

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

↓ 1 callersMethodgetDepartment

()

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

↓ 1 callersMethodgetDepartment

()

kstream-aggregate/src/main/java/guru/learningjournal/kafka/examples/types/Employee.java:57

↓ 1 callersMethodgetDepartment

()

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

↓ 1 callersMethodgetEarnedLoyaltyPoints

()

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

↓ 1 callersMethodgetHadoopRecords

Create a flattened List of HadoopRecords from Invoice Each Line Item is denormalized into an independent record @param invoice PosInvoice object @ret

pos-fanout/src/main/java/guru/learningjournal/kafka/examples/RecordBuilder.java:41

↓ 1 callersMethodgetIndex

()

pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/datagenerator/ProductGenerator.java:46

↓ 1 callersMethodgetIndex

()

pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/datagenerator/AddressGenerator.java:31

↓ 1 callersMethodgetIndex

()

pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/datagenerator/InvoiceGenerator.java:57

↓ 1 callersMethodgetIndex

()

pos-simulator/src/main/java/guru/learningjournal/kafka/examples/datagenerator/ProductGenerator.java:46

↓ 1 callersMethodgetIndex

()

pos-simulator/src/main/java/guru/learningjournal/kafka/examples/datagenerator/AddressGenerator.java:31

↓ 1 callersMethodgetIndex

()

pos-simulator/src/main/java/guru/learningjournal/kafka/examples/datagenerator/InvoiceGenerator.java:57

↓ 1 callersMethodgetInstance

()

pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/datagenerator/ProductGenerator.java:30

↓ 1 callersMethodgetInstance

()

pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/datagenerator/AddressGenerator.java:35

↓ 1 callersMethodgetInstance

()

pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/datagenerator/InvoiceGenerator.java:39

↓ 1 callersMethodgetInstance

()

pos-simulator/src/main/java/guru/learningjournal/kafka/examples/datagenerator/ProductGenerator.java:30

↓ 1 callersMethodgetInstance

()

pos-simulator/src/main/java/guru/learningjournal/kafka/examples/datagenerator/AddressGenerator.java:35

↓ 1 callersMethodgetInstance

()

pos-simulator/src/main/java/guru/learningjournal/kafka/examples/datagenerator/InvoiceGenerator.java:39

↓ 1 callersMethodgetInvoiceLineItems

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

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

↓ 1 callersMethodgetInvoiceLineItems

()

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

↓ 1 callersMethodgetInvoiceNumber

()

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

↓ 1 callersMethodgetInvoiceNumber

()

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

↓ 1 callersMethodgetItemCode

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

pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:75

↓ 1 callersMethodgetItemCode

()

pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:30

↓ 1 callersMethodgetItemDescription

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

pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:91

↓ 1 callersMethodgetItemDescription

()

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

↓ 1 callersMethodgetItemPrice

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

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

↓ 1 callersMethodgetItemPrice

()

pos-simulator/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:50

↓ 1 callersMethodgetItemPrice

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

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

↓ 1 callersMethodgetItemPrice

()

pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:60

↓ 1 callersMethodgetItemQty

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

pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:123

↓ 1 callersMethodgetItemQty

()

pos-simulator/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:60

↓ 1 callersMethodgetItemQty

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

pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:123

↓ 1 callersMethodgetItemQty

()

pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:75

↓ 1 callersMethodgetLastTradedPrice

()

custom-window/src/main/java/guru/learningjournal/kafka/examples/types/StockTicker.java:61

↓ 1 callersMethodgetLatestRecordTime

()

custom-window/src/main/java/guru/learningjournal/kafka/examples/types/TickerStack.java:43

← previous next →101–200 of 1,924, ranked by callers