MCPcopy Create free account

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

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

↓ 1 callersMethodgetLtpStack
()
custom-window/src/main/java/guru/learningjournal/kafka/examples/types/TickerStack.java:53
↓ 1 callersMethodgetMaskedInvoice
Set personally identifiable values to null @param invoice PosInvoice object @return masked PosInvoice object
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/RecordBuilder.java:73
↓ 1 callersMethodgetNewInvoiceNumber
()
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/datagenerator/InvoiceGenerator.java:61
↓ 1 callersMethodgetNewInvoiceNumber
()
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/datagenerator/InvoiceGenerator.java:61
↓ 1 callersMethodgetNewsType
()
top3-inventories/src/main/java/guru/learningjournal/kafka/examples/types/ClicksByNewsType.java:21
↓ 1 callersMethodgetNextAddress
()
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/datagenerator/AddressGenerator.java:51
↓ 1 callersMethodgetNextAddress
()
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/datagenerator/AddressGenerator.java:51
↓ 1 callersMethodgetNextInvoice
()
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/datagenerator/InvoiceGenerator.java:69
↓ 1 callersMethodgetNextInvoice
()
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/datagenerator/InvoiceGenerator.java:69
↓ 1 callersMethodgetNextProduct
()
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/datagenerator/ProductGenerator.java:54
↓ 1 callersMethodgetNextProduct
()
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/datagenerator/ProductGenerator.java:54
↓ 1 callersMethodgetNoOfItems
()
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/datagenerator/InvoiceGenerator.java:65
↓ 1 callersMethodgetNoOfItems
()
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/datagenerator/InvoiceGenerator.java:65
↓ 1 callersMethodgetNotification
Transform PosInvoice to Notification @param invoice PosInvoice Object @return Notification Object
rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/RecordBuilder.java:37
↓ 1 callersMethodgetNotification
Transform PosInvoice to Notification @param invoice PosInvoice Object @return Notification Object
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/RecordBuilder.java:88
↓ 1 callersMethodgetNotificationFrom
(PosInvoice invoice)
rewards-table/src/main/java/guru/learningjournal/kafka/examples/Notifications.java:31
↓ 1 callersMethodgetPaymentMethod
Gets the value of the 'PaymentMethod' field. @return The value of the 'PaymentMethod' field.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:279
↓ 1 callersMethodgetPaymentMethod
()
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:203
↓ 1 callersMethodgetPinCode
Gets the value of the 'PinCode' field. @return The value of the 'PinCode' field.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:269
↓ 1 callersMethodgetPinCode
()
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:195
↓ 1 callersMethodgetPosID
Gets the value of the 'PosID' field. @return The value of the 'PosID' field.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:183
↓ 1 callersMethodgetPosID
()
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:113
↓ 1 callersMethodgetQuantity
()
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/datagenerator/ProductGenerator.java:50
↓ 1 callersMethodgetQuantity
()
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/datagenerator/ProductGenerator.java:50
↓ 1 callersMethodgetRowID
()
custom-sink/src/main/java/guru/learningjournal/kafka/examples/types/GenericRecord.java:38
↓ 1 callersMethodgetState
Gets the value of the 'State' field. @return The value of the 'State' field.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:253
↓ 1 callersMethodgetState
()
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:180
↓ 1 callersMethodgetStatus
()
stream-join/src/main/java/guru/learningjournal/kafka/examples/types/TransactionStatus.java:36
↓ 1 callersMethodgetStocks
private static method to read data from given dataFile @param dataFile data file name in resource folder @return List of StockData Instance @throws I
transactional-producer/src/main/java/guru/learningjournal/kafka/examples/TransactionalProducer.java:47
↓ 1 callersMethodgetStocks
private static method to read data from given dataFile @param dataFile data file name in resource folder @return List of StockData Instance @throws I
json-producer/src/main/java/guru/learningjournal/kafka/examples/JsonProducerDemo.java:56
↓ 1 callersMethodgetStocks
private static method to read data from given dataFile @param dataFile data file name in resource folder @return List of StockData Instance @throws I
avro-producer/src/main/java/guru/learningjournal/kafka/examples/AvroProducerDemo.java:55
↓ 1 callersMethodgetStoreID
Gets the value of the 'StoreID' field. @return The value of the 'StoreID' field.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:167
↓ 1 callersMethodgetStoreID
()
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:88
↓ 1 callersMethodgetStoreID
Gets the value of the 'StoreID' field. @return The value of the 'StoreID' field.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:167
↓ 1 callersMethodgetStoreID
()
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:98
↓ 1 callersMethodgetTargetTable
()
custom-sink/src/main/java/guru/learningjournal/kafka/examples/types/TableMap.java:25
↓ 1 callersMethodgetTop3Sorted
()
top3-inventories/src/main/java/guru/learningjournal/kafka/examples/common/Top3NewsTypes.java:78
↓ 1 callersMethodgetTotalLoyaltyPoints
()
rewards-table/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:90
↓ 1 callersMethodgetTotalValue
Gets the value of the 'TotalValue' field. @return The value of the 'TotalValue' field.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:139
↓ 1 callersMethodgetTotalValue
()
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:70
↓ 1 callersMethodgetTotalValue
Gets the value of the 'TotalValue' field. @return The value of the 'TotalValue' field.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:139
↓ 1 callersMethodgetTotalValue
()
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:90
↓ 1 callersMethodgetTransactionID
()
stream-join/src/main/java/guru/learningjournal/kafka/examples/types/PaymentRequest.java:33
↓ 1 callersMethodhasDeliveryAddress
Checks whether the 'DeliveryAddress' field has been set. @return True if the 'DeliveryAddress' field has been set, false otherwise.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:1225
↓ 1 callersMethodhasDeliveryAddress
Checks whether the 'DeliveryAddress' field has been set. @return True if the 'DeliveryAddress' field has been set, false otherwise.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:1225
↓ 1 callersMethodhasDeliveryAddressBuilder
Checks whether the 'DeliveryAddress' field has an active Builder instance @return True if the 'DeliveryAddress' field has an active Builder instance
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:1259
↓ 1 callersMethodhasDeliveryAddressBuilder
Checks whether the 'DeliveryAddress' field has an active Builder instance @return True if the 'DeliveryAddress' field has an active Builder instance
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:1259
↓ 1 callersMethodpartition
Simple partitioning on the message key Odd keys to partition 0 Even keys to partition 1 @param topic topic Name @param key Message Key @param keyByte
partitioned-producer/src/main/java/guru/learningjournal/kafka/examples/OddEvenPartitioner.java:45
↓ 1 callersMethodprocess
(String key, GenericRecord valueRecord)
custom-sink/src/main/java/guru/learningjournal/kafka/examples/SinkProcessor.java:38
↓ 1 callersMethodpush
(Double lastTradedPrice)
custom-window/src/main/java/guru/learningjournal/kafka/examples/types/TickerStack.java:75
↓ 1 callersMethodreadAllFromRemote
( HostInfo hostInfo)
ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/AppRestService.java:88
↓ 1 callersMethodreadKeyFromLocal
(String searchKey)
ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/AppRestService.java:47
↓ 1 callersMethodreadKeyFromRemote
(String searchKey, HostInfo hostInfo)
ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/AppRestService.java:59
↓ 1 callersMethodsetActive
(Boolean state)
ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/AppRestService.java:43
↓ 1 callersMethodsetAdditionalProperty
(String name, Object value)
custom-sink/src/main/java/guru/learningjournal/kafka/examples/types/TableMap.java:45
↓ 1 callersMethodsetAddressLine
Sets the value of the 'AddressLine' field. @param value the value to set.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:83
↓ 1 callersMethodsetAddressLine
(String addressLine)
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:35
↓ 1 callersMethodsetCESS
Sets the value of the 'CESS' field. @param value the value to set.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:351
↓ 1 callersMethodsetCESS
(Double cESS)
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:203
↓ 1 callersMethodsetCGST
Sets the value of the 'CGST' field. @param value the value to set.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:319
↓ 1 callersMethodsetCGST
(Double cGST)
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:183
↓ 1 callersMethodsetCity
Sets the value of the 'City' field. @param value the value to set.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:245
↓ 1 callersMethodsetCity
(String city)
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:170
↓ 1 callersMethodsetClicks
(Long clicks)
top3-inventories/src/main/java/guru/learningjournal/kafka/examples/types/ClicksByNewsType.java:41
↓ 1 callersMethodsetContactNumber
Sets the value of the 'ContactNumber' field. @param value the value to set.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:147
↓ 1 callersMethodsetContactNumber
(String contactNumber)
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:95
↓ 1 callersMethodsetCreatedTime
Sets the value of the 'CreatedTime' field. @param value the value to set.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:159
↓ 1 callersMethodsetCreatedTime
(Long createdTime)
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:83
↓ 1 callersMethodsetCreatedTime
Sets the value of the 'CreatedTime' field. @param value the value to set.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:149
↓ 1 callersMethodsetCustomerCardNo
Sets the value of the 'CustomerCardNo' field. @param value the value to set.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:239
↓ 1 callersMethodsetCustomerCardNo
Sets the value of the 'CustomerCardNo' field. @param value the value to set.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:94
↓ 1 callersMethodsetCustomerCardNo
(String customerCardNo)
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:163
↓ 1 callersMethodsetCustomerType
Sets the value of the 'CustomerType' field. @param value the value to set.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:197
↓ 1 callersMethodsetDeliveryAddress
Sets the value of the 'DeliveryAddress' field. @param value the value to set.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:383
↓ 1 callersMethodsetDeliveryAddress
(DeliveryAddress deliveryAddress)
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:223
↓ 1 callersMethodsetDeliveryType
Sets the value of the 'DeliveryType' field. @param value the value to set.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:229
↓ 1 callersMethodsetEarnedLoyaltyPoints
Sets the value of the 'EarnedLoyaltyPoints' field. @param value the value to set.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:126
↓ 1 callersMethodsetInvoiceLineItems
Sets the value of the 'InvoiceLineItems' field. @param value the value to set.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:399
↓ 1 callersMethodsetInvoiceLineItems
(List<PosLineItem> invoiceLineItems)
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:233
↓ 1 callersMethodsetInvoiceNumber
Sets the value of the 'InvoiceNumber' field. @param value the value to set.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:143
↓ 1 callersMethodsetInvoiceNumber
(String invoiceNumber)
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:73
↓ 1 callersMethodsetInvoiceNumber
Sets the value of the 'InvoiceNumber' field. @param value the value to set.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:78
↓ 1 callersMethodsetInvoiceNumber
Sets the value of the 'InvoiceNumber' field. @param value the value to set.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:133
↓ 1 callersMethodsetItemCode
Sets the value of the 'ItemCode' field. @param value the value to set.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:293
↓ 1 callersMethodsetItemDescription
Sets the value of the 'ItemDescription' field. @param value the value to set.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:309
↓ 1 callersMethodsetItemPrice
Sets the value of the 'ItemPrice' field. @param value the value to set.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:325
↓ 1 callersMethodsetItemQty
Sets the value of the 'ItemQty' field. @param value the value to set.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:131
↓ 1 callersMethodsetItemQty
(Integer itemQty)
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:65
↓ 1 callersMethodsetItemQty
Sets the value of the 'ItemQty' field. @param value the value to set.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:341
↓ 1 callersMethodsetLastLogin
(Long lastLogin)
last-login/src/main/java/guru/learningjournal/kafka/examples/types/UserDetails.java:59
↓ 1 callersMethodsetLatestRecordTime
(long timestamp)
custom-window/src/main/java/guru/learningjournal/kafka/examples/types/TickerStack.java:48
↓ 1 callersMethodsetNewsType
(String newsType)
top3-inventories/src/main/java/guru/learningjournal/kafka/examples/types/ClicksByNewsType.java:26
↓ 1 callersMethodsetNumberOfItems
Sets the value of the 'NumberOfItems' field. @param value the value to set.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:271
↓ 1 callersMethodsetNumberOfItems
(Integer numberOfItems)
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:153
↓ 1 callersMethodsetPaymentMethod
Sets the value of the 'PaymentMethod' field. @param value the value to set.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:213
↓ 1 callersMethodsetPinCode
Sets the value of the 'PinCode' field. @param value the value to set.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:277
↓ 1 callersMethodsetPinCode
(String pinCode)
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:200
↓ 1 callersMethodsetPosID
Sets the value of the 'PosID' field. @param value the value to set.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:181
↓ 1 callersMethodsetSGST
Sets the value of the 'SGST' field. @param value the value to set.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:335
↓ 1 callersMethodsetSGST
(Double sGST)
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:193
← previousnext →201–300 of 1,924, ranked by callers