Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/LearningJournal/Kafka-Streams-Real-time-Stream-Processing
/ functions
Functions
1,924 in github.com/LearningJournal/Kafka-Streams-Real-time-Stream-Processing
⨍
Functions
1,924
◇
Types & classes
246
↓ 1 callers
Method
setState
Sets the value of the 'State' field. @param value the value to set.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:261
↓ 1 callers
Method
setState
(String state)
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:185
↓ 1 callers
Method
setStoreID
Sets the value of the 'StoreID' field. @param value the value to set.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:165
↓ 1 callers
Method
setTaxableAmount
Sets the value of the 'TaxableAmount' field. @param value the value to set.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:303
↓ 1 callers
Method
setTaxableAmount
(Double taxableAmount)
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:173
↓ 1 callers
Method
setTotalAmount
Sets the value of the 'TotalAmount' field. @param value the value to set.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:255
↓ 1 callers
Method
setTotalAmount
(Double totalAmount)
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:143
↓ 1 callers
Method
setTotalAmount
Sets the value of the 'TotalAmount' field. @param value the value to set.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:110
↓ 1 callers
Method
setTotalLoyaltyPoints
(Double totalLoyaltyPoints)
rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:95
↓ 1 callers
Method
setTotalLoyaltyPoints
(Double totalLoyaltyPoints)
rewards-table/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:95
↓ 1 callers
Method
setTotalValue
Sets the value of the 'TotalValue' field. @param value the value to set.
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:147
↓ 1 callers
Method
setTotalValue
(Double totalValue)
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:75
↓ 1 callers
Method
setTotalValue
Sets the value of the 'TotalValue' field. @param value the value to set.
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:357
↓ 1 callers
Method
stop
()
ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/AppRestService.java:176
↓ 1 callers
Method
toString
()
custom-window/src/main/java/guru/learningjournal/kafka/examples/types/StockTicker.java:91
↓ 1 callers
Method
toString
()
ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/types/Employee.java:87
↓ 1 callers
Method
toString
()
stream-join/src/main/java/guru/learningjournal/kafka/examples/types/PaymentRequest.java:123
↓ 1 callers
Method
toString
()
kstream-aggregate/src/main/java/guru/learningjournal/kafka/examples/types/Employee.java:87
↓ 1 callers
Method
toString
()
ktable-aggregate/src/main/java/guru/learningjournal/kafka/examples/types/Employee.java:87
↓ 1 callers
Method
transform
(String key, GenericRecord genericRecord)
custom-sink/src/main/java/guru/learningjournal/kafka/examples/RecordTransformer.java:39
↓ 1 callers
Method
withAdClicks
(Long adClicks)
ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/types/CampaignPerformance.java:64
↓ 1 callers
Method
withAdClicks
(Long adClicks)
topology-test/src/main/java/guru/learningjournal/kafka/examples/types/CampaignPerformance.java:64
↓ 1 callers
Method
withAdImpressions
(Long adImpressions)
ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/types/CampaignPerformance.java:49
↓ 1 callers
Method
withAdImpressions
(Long adImpressions)
topology-test/src/main/java/guru/learningjournal/kafka/examples/types/CampaignPerformance.java:49
↓ 1 callers
Method
withCampaigner
(String campaigner)
ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/types/AdClick.java:46
↓ 1 callers
Method
withCreatedTime
(Long createdTime)
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:93
↓ 1 callers
Method
withCustomerCardNo
(String customerCardNo)
rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:168
↓ 1 callers
Method
withCustomerCardNo
(String customerCardNo)
rewards-table/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:168
↓ 1 callers
Method
withCustomerCardNo
(String customerCardNo)
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:168
↓ 1 callers
Method
withCustomerType
(String customerType)
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:153
↓ 1 callers
Method
withDeliveryType
(String deliveryType)
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:288
↓ 1 callers
Method
withEarnedLoyaltyPoints
(Double earnedLoyaltyPoints)
rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:85
↓ 1 callers
Method
withEarnedLoyaltyPoints
(Double earnedLoyaltyPoints)
rewards-table/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:85
↓ 1 callers
Method
withEarnedLoyaltyPoints
(Double earnedLoyaltyPoints)
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:82
↓ 1 callers
Method
withInvoiceNumber
(String invoiceNumber)
rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:78
↓ 1 callers
Method
withInvoiceNumber
(String invoiceNumber)
rewards-table/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:78
↓ 1 callers
Method
withItemCode
(String itemCode)
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:40
↓ 1 callers
Method
withItemDescription
(String itemDescription)
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:55
↓ 1 callers
Method
withItemPrice
(Double itemPrice)
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:70
↓ 1 callers
Method
withItemQty
(Integer itemQty)
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:85
↓ 1 callers
Method
withLastTradedPrice
(Double lastTradedPrice)
custom-window/src/main/java/guru/learningjournal/kafka/examples/types/StockTicker.java:71
↓ 1 callers
Method
withPaymentMethod
(String paymentMethod)
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:213
↓ 1 callers
Method
withPosID
(String posID)
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:123
↓ 1 callers
Method
withStatus
(String status)
stream-join/src/main/java/guru/learningjournal/kafka/examples/types/TransactionStatus.java:46
↓ 1 callers
Method
withStoreID
(String storeID)
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:108
↓ 1 callers
Method
withTickerSymbol
(String tickerSymbol)
custom-window/src/main/java/guru/learningjournal/kafka/examples/types/StockTicker.java:41
↓ 1 callers
Method
withTickerTime
(Long tickerTime)
custom-window/src/main/java/guru/learningjournal/kafka/examples/types/StockTicker.java:56
↓ 1 callers
Method
withTotalAmount
(Double totalAmount)
rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:183
↓ 1 callers
Method
withTotalAmount
(Double totalAmount)
rewards-table/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:183
↓ 1 callers
Method
withTotalAmount
(Double totalAmount)
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:183
↓ 1 callers
Method
withTotalLoyaltyPoints
(Double totalLoyaltyPoints)
rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:100
↓ 1 callers
Method
withTotalLoyaltyPoints
(Double totalLoyaltyPoints)
rewards-table/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:100
↓ 1 callers
Method
withTotalValue
(Double totalValue)
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:100
↓ 1 callers
Method
withTransactionID
(String transactionID)
stream-join/src/main/java/guru/learningjournal/kafka/examples/types/PaymentRequest.java:43
Method
AdClickSerde
()
ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:70
Method
AdClickSerde
()
top3-inventories/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:55
Method
AdClickSerde
()
topology-test/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:70
Method
AdImpressionSerde
()
ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:54
Method
AdImpressionSerde
()
topology-test/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:54
Method
AdInventoriesSerde
()
top3-inventories/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:38
Method
AddressGenerator
()
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/datagenerator/AddressGenerator.java:39
Method
AddressGenerator
()
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/datagenerator/AddressGenerator.java:39
Method
AppRestService
(KafkaStreams stream, String hostname, int port)
ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/AppRestService.java:37
Method
Builder
Creates a new Builder
pojo-from-avro/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:168
Method
Builder
Creates a new Builder
avro-consumer/src/main/java/guru/learningjournal/kafka/examples/StockData.java:366
Method
Builder
Creates a new Builder
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:190
Method
Builder
Creates a new Builder
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:190
Method
Builder
Creates a new Builder
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:455
Method
Builder
Creates a new Builder
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java:190
Method
Builder
Creates a new Builder
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:190
Method
Builder
Creates a new Builder
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java:455
Method
Builder
Creates a new Builder
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/Notification.java:168
Method
Builder
Creates a new Builder
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:410
Method
Builder
Creates a new Builder
avro-producer/src/main/java/guru/learningjournal/kafka/examples/StockData.java:367
Method
CampaignPerformance
()
ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:43
Method
CampaignPerformanceSerde
()
ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:38
Method
CampaignPerformanceSerde
()
topology-test/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:38
Method
ClicksByNewsTypeSerde
()
top3-inventories/src/main/java/guru/learningjournal/kafka/examples/common/AppSerdes.java:71
Method
DeliveryAddress
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:27
Method
DeliveryAddress
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java:27
Method
DepartmentAggSerde
()
ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:53
Method
DepartmentAggSerde
()
kstream-aggregate/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:53
Method
DepartmentAggSerde
()
ktable-aggregate/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:53
Method
Dispatcher
A dispatcher thread takes a producer and sends Kafka messages to the given topic. The Events are supplied in a file @param producer A valid produ
producer-threads/src/main/java/guru/learningjournal/kafka/examples/Dispatcher.java:49
Method
Dispatcher
A dispatcher thread takes a kafka producer and send a batch of messages to the given topic @param producer A valid producer instance @param topicNa
transactional-producer/src/main/java/guru/learningjournal/kafka/examples/Dispatcher.java:41
Method
Dispatcher
A dispatcher thread takes a kafka producer and send a batch of messages to the given topic @param producer A valid producer instance @param topicNa
json-producer/src/main/java/guru/learningjournal/kafka/examples/Dispatcher.java:47
Method
Dispatcher
A dispatcher thread takes a kafka producer and send a batch of messages to the given topic @param producer A valid producer instance @param topicNa
avro-producer/src/main/java/guru/learningjournal/kafka/examples/Dispatcher.java:43
Method
EmployeeSerde
()
ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:37
Method
EmployeeSerde
()
kstream-aggregate/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:37
Method
EmployeeSerde
()
ktable-aggregate/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:37
Method
GenericRecordSerde
()
custom-sink/src/main/java/guru/learningjournal/kafka/examples/AppSerdes.java:37
Method
HadoopRecord
Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use <code
pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java:37
Method
HadoopRecordSerde
()
pos-fanout/src/main/java/guru/learningjournal/kafka/examples/PosSerdes.java:72
Method
InvoiceGenerator
()
pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/datagenerator/InvoiceGenerator.java:43
Method
InvoiceGenerator
()
pos-simulator/src/main/java/guru/learningjournal/kafka/examples/datagenerator/InvoiceGenerator.java:43
Method
JsonDeserializer
()
custom-window/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:34
Method
JsonDeserializer
()
counting-session/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:34
Method
JsonDeserializer
()
ad-campaigns/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:34
Method
JsonDeserializer
()
rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:34
Method
JsonDeserializer
()
ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/serde/JsonDeserializer.java:34
← previous
next →
301–400 of 1,924, ranked by callers