MCPcopy Create free account

hub / github.com/bbejeck/KafkaStreamsInAction2ndEdition / functions

Functions814 in github.com/bbejeck/KafkaStreamsInAction2ndEdition

⨍ Functions 814◇ Types & classes 235
MethodacceptedLoansTopic
()
spring-kafka/src/main/java/bbejeck/spring/streams/boot/KafkaStreamsBootLoanApplicationApplication.java:64
MethodacceptedLoansTopic
()
spring-kafka/src/main/java/bbejeck/spring/application/LoanApplicationProcessingApplicationAdvanced.java:58
MethodacceptedLoansTopic
()
spring-kafka/src/main/java/bbejeck/spring/application/LoanApplicationProcessingApplication.java:42
MethodaddExecutionInfo
(Map<String, Set<String>>executionInfo)
spring-kafka/src/main/java/bbejeck/spring/model/QueryResponse.java:31
MethodaggregateStockTransactionTest
()
streams/src/test/java/bbejeck/chapter_7/StreamsStockTransactionAggregationsTest.java:28
Methodapply
(String s)
streams/src/main/java/bbejeck/utils/Functions.java:19
Methodapply
(String s)
streams/src/main/java/bbejeck/chapter_8/KTableCountExample.java:58
Methodapply
(String s)
streams/src/main/java/bbejeck/chapter_8/KTableFilterExample.java:51
Methodapply
(String key, RetailPurchase value)
streams/src/main/java/bbejeck/chapter_6/mapper/RetailKeyValueMapper.java:14
Methodapply
(String customerIdKey, RetailPurchase value)
streams/src/main/java/bbejeck/chapter_6/mapper/RetailValueMapperWithKey.java:12
Methodapply
(String userId, String url, Map<String, Integer> aggregate)
streams/src/main/java/bbejeck/chapter_9/aggregator/PageViewAggregator.java:11
Methodapply
(String key, Double reading, IotSensorAggregation aggregate)
streams/src/main/java/bbejeck/chapter_9/aggregator/IotStreamingAggregator.java:10
Methodapply
(Windowed<String> windowed, IotSensorAggregation iotSe
streams/src/main/java/bbejeck/chapter_9/mapper/WindowTimeToAggregateMapper.java:9
Methodapply
(String aggKey, Map<String, Integer> mapOne,
streams/src/main/java/bbejeck/chapter_9/session/PageViewSessionMerger.java:12
Methodapply
(String key, Transaction transaction,
streams/src/main/java/bbejeck/chapter_7/aggregator/StockAggregator.java:12
MethodcleanOutDanglingAggregations
(final long timestamp)
streams/src/main/java/bbejeck/chapter_10/processor/DataDrivenAggregate.java:86
Methodclose
()
streams/src/main/java/bbejeck/chapter_4/pipelining/ConcurrentRecordProcessor.java:96
Methodclose
()
streams/src/main/java/bbejeck/chapter_4/sales/CustomOrderPartitioner.java:39
Methodclose
()
streams/src/main/java/bbejeck/clients/MockDataProducer.java:373
Methodconfig
()
custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceConnector.java:98
Methodconfig
()
custom-connector/src/main/java/bbejeck/chapter_5/transformer/MultiFieldExtract.java:69
MethodcreateTopic
()
streams/src/test/java/bbejeck/chapter_4/IdempotentProducerTest.java:79
MethoddeleteTopic
()
streams/src/test/java/bbejeck/chapter_4/IdempotentProducerTest.java:84
MethoddoProcessLoanApplication
(LoanApplication loanApplication)
spring-kafka/src/main/java/bbejeck/spring/processor/NewLoanApplicationProcessorListenerClassLevel.java:40
MethoddoProcessLoanApplication
(LoanApplication loanApplication)
spring-kafka/src/main/java/bbejeck/spring/processor/NewLoanApplicationProcessor.java:38
MethoddoProcessLoanApplication
(LoanApplication loanApplication, @Header(KafkaHeaders.RECEIVED_TIMES
spring-kafka/src/main/java/bbejeck/spring/processor/NewLoanApplicationProcessorLogTimestampKey.java:59
MethoddoProcessRecord
(ConsumerRecord<String, ProductTransaction> record)
streams/src/main/java/bbejeck/chapter_4/pipelining/ConcurrentRecordProcessor.java:82
Methodextract
(String key, RetailPurchase value, RecordContext recordCon
streams/src/main/java/bbejeck/chapter_6/PurchaseTopicNameExtractor.java:13
Methodextract
(String key, RetailPurchase value, RecordContext recordCon
streams/src/main/java/bbejeck/chapter_6/HeadersTopicNameExtractor.java:18
Methodextract
(ConsumerRecord<Object, Object> consumerRecord, long partitionTime)
streams/src/main/java/bbejeck/chapter_9/timestamp_extractor/TransactionTimestampExtractor.java:11
Methodfetch
()
streams/src/main/java/bbejeck/data/ConstantAvroEventDataSource.java:18
Methodfetch
()
streams/src/main/java/bbejeck/data/ConstantProtoEventDataSource.java:18
Methodfetch
()
streams/src/main/java/bbejeck/chapter_4/sales/SalesDataSource.java:23
MethodfmtInstant
(Instant instant)
streams/src/main/java/bbejeck/BaseStreamsApplication.java:38
Methodget
()
streams/src/main/java/bbejeck/chapter_8/joins/StreamTableVersionedJoinExample.java:101
Methodget
()
streams/src/main/java/bbejeck/chapter_8/joins/StreamTableJoinExample.java:94
Methodget
()
streams/src/main/java/bbejeck/chapter_8/joins/StreamGlobalKTableJoinExample.java:95
Methodget
()
streams/src/main/java/bbejeck/chapter_8/joins/KTableForeignKeyJoinExample.java:107
Methodget
()
streams/src/main/java/bbejeck/chapter_9/data/PageViewSessionsRecordSupplier.java:38
Methodget
()
streams/src/main/java/bbejeck/chapter_10/StockPerformanceApplication.java:114
Methodget
()
streams/src/main/java/bbejeck/chapter_10/SensorAlertingApplication.java:104
Methodget
()
streams/src/main/java/bbejeck/chapter_10/StockPerformanceDslAndProcessorApplication.java:96
Methodget
()
streams/src/main/java/bbejeck/chapter_10/PopsHopsPrintingApplication.java:120
Methodget
()
streams/src/main/java/bbejeck/chapter_10/processor/StockPerformanceProcessorSupplier.java:19
MethodgetAdmin
(Map<String, Object> config)
streams/src/main/java/bbejeck/chapter_6/client_supplier/CustomKafkaStreamsClientSupplier.java:48
MethodgetAggregationKeyQuery
(@PathVariable String loanType)
spring-kafka/src/main/java/bbejeck/spring/streams/container/LoanApplicationController.java:77
MethodgetConsumer
(Map<String, Object> config)
streams/src/main/java/bbejeck/chapter_6/client_supplier/CustomKafkaStreamsClientSupplier.java:30
MethodgetEmail
()
streams/src/main/java/bbejeck/chapter_3/codegen/Customer.java:47
MethodgetErrorMessage
()
spring-kafka/src/main/java/bbejeck/spring/model/QueryResponse.java:48
MethodgetEventType
(final Events event)
streams/src/main/java/bbejeck/chapter_4/multi_event/proto/MultiEventProtoConsumerClient.java:90
MethodgetExecutionInfo
()
spring-kafka/src/main/java/bbejeck/spring/model/QueryResponse.java:56
MethodgetFavoriteNumber
()
streams/src/main/java/bbejeck/chapter_3/model/User.java:31
MethodgetGlobalConsumer
(Map<String, Object> config)
streams/src/main/java/bbejeck/chapter_6/client_supplier/CustomKafkaStreamsClientSupplier.java:42
MethodgetHostType
()
spring-kafka/src/main/java/bbejeck/spring/model/QueryResponse.java:45
MethodgetNumApproved
()
spring-kafka/src/main/java/bbejeck/spring/model/LoanAppRollup.java:40
MethodgetNumRejected
()
spring-kafka/src/main/java/bbejeck/spring/model/LoanAppRollup.java:44
MethodgetOffsets
()
streams/src/main/java/bbejeck/chapter_4/pipelining/ConcurrentRecordProcessor.java:51
MethodgetProducer
(Map<String, Object> config)
streams/src/main/java/bbejeck/chapter_6/client_supplier/CustomKafkaStreamsClientSupplier.java:24
MethodgetRecords
()
sr-full/src/main/java/bbejeck/chapter_3/producer/avro/AvroProducer.java:26
MethodgetRecords
()
sr-backward/src/main/java/bbejeck/chapter_3/producer/avro/AvroProducer.java:26
MethodgetRecords
()
sr-forward/src/main/java/bbejeck/chapter_3/producer/avro/AvroProducer.java:28
MethodgetRestoreConsumer
(Map<String, Object> config)
streams/src/main/java/bbejeck/chapter_6/client_supplier/CustomKafkaStreamsClientSupplier.java:36
MethodgetStockQuotes
()
custom-connector/src/test/java/bbejeck/chapter_5/connector/StockTickerSourceTaskTest.java:38
MethodgetStockQuotesYahoo
()
custom-connector/src/test/java/bbejeck/chapter_5/connector/StockTickerSourceTaskTest.java:73
MethodgetTotalLoans
()
spring-kafka/src/main/java/bbejeck/spring/model/LoanAppRollup.java:32
MethodgetTotalRejected
()
spring-kafka/src/main/java/bbejeck/spring/model/LoanAppRollup.java:36
MethodhandleAcceptedLoans
(LoanApplication acceptedLoan)
spring-kafka/src/main/java/bbejeck/spring/processor/CompletedLoanApplicationProcessor.java:16
MethodhandleQALoans
(LoanApplication qaLoan)
spring-kafka/src/main/java/bbejeck/spring/processor/CompletedLoanApplicationProcessor.java:26
MethodhandleRejectedLoans
(LoanApplication rejectedLoan)
spring-kafka/src/main/java/bbejeck/spring/processor/CompletedLoanApplicationProcessor.java:21
MethodhandleUnknownObject
(Object unknown)
spring-kafka/src/main/java/bbejeck/spring/processor/NewLoanApplicationProcessorListenerClassLevel.java:58
MethodhashCode
()
streams/src/main/java/bbejeck/chapter_3/model/User.java:55
Methodinit
()
spring-kafka/src/main/java/bbejeck/spring/streams/container/KafkaStreamsContainer.java:42
Methodinit
()
spring-kafka/src/main/java/bbejeck/spring/streams/container/LoanApplicationController.java:71
Methodinit
()
streams/src/test/java/bbejeck/chapter_4/IdempotentProducerTest.java:72
Methodinit
(ProcessorContext<String, SensorAggregation> context)
streams/src/main/java/bbejeck/chapter_10/processor/DataDrivenAggregate.java:47
Methodinit
(ProcessorContext<String, StockPerformance> context)
streams/src/main/java/bbejeck/chapter_10/processor/StockPerformanceProcessor.java:29
Methodinit
(ProcessorContext<String, StockPerformance> processorContext)
streams/src/main/java/bbejeck/chapter_10/cancellation/StockPerformanceCancellingProcessor.java:42
MethodkafkaListenerContainerFactory
()
spring-kafka/src/main/java/bbejeck/spring/application/LoanApplicationProcessingApplicationAdvanced.java:89
MethodkafkaStreams
()
spring-kafka/src/main/java/bbejeck/spring/streams/container/KafkaStreamsContainer.java:37
MethodkafkaStreamsConfiguration
()
spring-kafka/src/main/java/bbejeck/spring/streams/container/KafkaStreamsContainerLoanApplicationApplication.java:78
MethodkafkaStreamsConfiguration
()
spring-kafka/src/main/java/bbejeck/spring/streams/boot/KafkaStreamsBootLoanApplicationApplication.java:97
MethodkafkaStreamsCustomizer
()
spring-kafka/src/main/java/bbejeck/spring/streams/boot/KafkaStreamsBootLoanApplicationApplication.java:92
Methodlist
(final Properties props)
streams/src/main/java/bbejeck/utils/Topics.java:57
MethodloadProperties
(String propertyFilePath)
streams/src/main/java/bbejeck/BaseStreamsApplication.java:24
MethodloanAppInputTopic
()
spring-kafka/src/main/java/bbejeck/spring/streams/container/KafkaStreamsContainerLoanApplicationApplication.java:52
MethodloanAppInputTopic
()
spring-kafka/src/main/java/bbejeck/spring/streams/boot/KafkaStreamsBootLoanApplicationApplication.java:59
MethodloanAppInputTopic
()
spring-kafka/src/main/java/bbejeck/spring/application/LoanApplicationProcessingApplicationAdvanced.java:53
MethodloanAppInputTopic
()
spring-kafka/src/main/java/bbejeck/spring/application/LoanApplicationProcessingApplication.java:37
MethodloanProcessingTopology
(StreamsBuilder builder)
spring-kafka/src/main/java/bbejeck/spring/streams/boot/LoanApplicationProcessor.java:46
Methodmain
(String[] args)
sr-full/src/main/java/bbejeck/chapter_3/producer/avro/AvroProducer.java:61
Methodmain
(String[] args)
sr-full/src/main/java/bbejeck/chapter_3/consumer/avro/AvroConsumer.java:30
Methodmain
(String[] args)
sr-backward/src/main/java/bbejeck/chapter_3/producer/avro/AvroProducer.java:45
Methodmain
(String[] args)
sr-backward/src/main/java/bbejeck/chapter_3/consumer/avro/AvroConsumer.java:30
Methodmain
(String[] args)
spring-kafka/src/main/java/bbejeck/spring/streams/container/KafkaStreamsContainerLoanApplicationApplication.java:89
Methodmain
(String[] args)
spring-kafka/src/main/java/bbejeck/spring/streams/boot/KafkaStreamsBootLoanApplicationApplication.java:105
Methodmain
(String[] args)
spring-kafka/src/main/java/bbejeck/spring/application/LoanApplicationProcessingApplicationAdvanced.java:100
Methodmain
(String[] args)
spring-kafka/src/main/java/bbejeck/spring/application/LoanApplicationProcessingApplication.java:56
Methodmain
(String[] args)
custom-connector/src/main/java/bbejeck/chapter_5/web_server/TickerServer.java:34
Methodmain
(String[] args)
streams/src/test/java/bbejeck/chapter_6/SubtopologyTest.java:27
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_8/KTableCountExample.java:53
← previousnext →401–500 of 814, ranked by callers