MCPcopy Create free account

hub / github.com/bbejeck/KafkaStreamsInAction2ndEdition / functions

Functions814 in github.com/bbejeck/KafkaStreamsInAction2ndEdition

⨍ Functions 814◇ Types & classes 235
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_8/KTableAggregationExample.java:89
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_8/KTableFilterExample.java:46
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_8/joins/StreamTableVersionedJoinExample.java:72
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_8/joins/StreamTableJoinExample.java:65
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_8/joins/StreamGlobalKTableJoinExample.java:65
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_8/joins/KTableForeignKeyJoinExample.java:76
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_6/ZMartKafkaStreamsDynamicRoutingApp.java:82
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_6/KafkaStreamsYellingNamedProcessorsApp.java:67
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_6/SensorBranchingMergingApp.java:81
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_6/KafkaStreamsYellingApp.java:64
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_6/KafkaStreamsYellingAppWithPeek.java:64
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_6/ZMartKafkaStreamsFilteringBranchingApp.java:140
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_6/ZMartKafkaStreamsApp.java:136
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_6/client_supplier/KafkaStreamsCustomClientsApp.java:49
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_9/IotStreamingAggregationNoWindows.java:62
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_9/data/PageViewSlidingWindowRecordSupplier.java:53
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_9/data/IotWindowedRecordSupplier.java:55
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_9/session/PageViewSessionWindows.java:80
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_9/session/PageViewSessionWindowsWithSuppression.java:88
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_9/session/StreamsCountSessionWindow.java:53
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_9/session/PageViewSessionWindowsEmitOnClose.java:85
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_9/sliding/PageViewSlidingWindows.java:76
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_9/sliding/StreamsCountSlidingWindow.java:54
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_9/hopping/StreamsCountHoppingWindowExtractKey.java:53
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_9/hopping/IotStreamingAggregationHoppingWindowsEmitOnClose.java:86
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_9/hopping/StreamsCountHoppingWindow.java:54
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_9/hopping/IotStreamingAggregationHoppingWindows.java:84
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_9/tumbling/StreamsCountTumblingWindowSuppressedEager.java:61
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_9/tumbling/IotStreamingAggregationEmitOnCloseTumblingWindow.java:81
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_9/tumbling/IotStreamingAggregationStreamPartitionerTumblingWindows.java:87
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_9/tumbling/IotStreamingAggregationMapWindowTimeTumblingWindows.java:73
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_9/tumbling/StreamsCountTumblingWindow.java:64
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_9/tumbling/IotStreamingAggregationTumblingWindows.java:84
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_9/tumbling/StreamsCountTumblingWindowSuppressedStrict.java:60
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_7/KafkaStreamsJoinsApp.java:62
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_7/StreamsChangeKeyThenReuseRepartition.java:56
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_7/RepartitionForThroughput.java:52
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_7/StreamsPokerGameInMemoryStoreReducer.java:50
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_7/StreamsCountingApplication.java:44
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_7/StreamsStockTransactionAggregations.java:65
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_7/OptimizingStreamsRepartition.java:59
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_7/StreamsPokerGameReducer.java:46
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_7/ProactiveStreamsRepartition.java:59
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_7/StreamsCountingInMemoryApplication.java:43
Methodmain
(String[] args)
streams/src/main/java/bbejeck/data/DataGenerator.java:374
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_14/CurrencyExchangeConsumeProduceApplication.java:40
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_3/AvroReflectionProduceConsumeExample.java:33
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_3/producer/proto/ProtoReferenceCompanyProducer.java:45
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_3/producer/proto/ProtoProducer.java:39
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_3/producer/proto/ProtoReferenceCollegeProducer.java:40
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_3/producer/json/JsonSchemaReferenceCompanyProducer.java:39
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_3/producer/json/JsonSchemaReferenceCollegeProducer.java:43
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_3/producer/json/JsonSchemaProducer.java:42
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_3/producer/avro/AvroReferenceCompanyProducer.java:40
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_3/producer/avro/AvroReferenceCollegeProducer.java:40
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_3/producer/avro/AvroProducer.java:40
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_3/consumer/proto/ProtoReferenceCompanyConsumer.java:24
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_3/consumer/proto/ProtoReferenceCollegeConsumer.java:24
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_3/consumer/proto/ProtoConsumer.java:28
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_3/consumer/json/JsonSchemaReferenceCompanyConsumer.java:26
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_3/consumer/json/JsonSchemaConsumer.java:26
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_3/consumer/json/JsonSchemaReferenceCollegeConsumer.java:24
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_3/consumer/avro/AvroConsumer.java:27
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_3/consumer/avro/AvroReferenceCompanyConsumer.java:24
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_3/consumer/avro/AvroReferenceCollegeConsumer.java:24
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_3/codegen/JsonSchemaGen.java:11
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_4/pipelining/ProducePipeliningConsumeApplication.java:41
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_4/sales/SalesProduceConsumeApplication.java:38
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_10/StockPerformanceApplication.java:86
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_10/SensorAlertingApplication.java:79
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_10/PopsHopsApplication.java:82
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_10/StockPerformanceDslAndProcessorApplication.java:68
Methodmain
(String[] args)
streams/src/main/java/bbejeck/chapter_10/PopsHopsPrintingApplication.java:91
Methodmain
(String[] args)
sr-forward/src/main/java/bbejeck/chapter_3/producer/avro/AvroProducer.java:47
Methodmain
(String[] args)
sr-forward/src/main/java/bbejeck/chapter_3/consumer/avro/AvroConsumer.java:30
MethodnewRecord
(R connectRecord, Schema updatedSchema, Object updatedValue)
custom-connector/src/main/java/bbejeck/chapter_5/transformer/MultiFieldExtract.java:122
MethodnewRecord
(R connectRecord, Schema updatedSchema, Object updatedValue)
custom-connector/src/main/java/bbejeck/chapter_5/transformer/MultiFieldExtract.java:140
MethodonFailure
(Throwable ex)
spring-kafka/src/main/java/bbejeck/spring/processor/NewLoanApplicationProcessorLogTimestampKey.java:41
MethodonSuccess
(SendResult<String, LoanApplication> result)
spring-kafka/src/main/java/bbejeck/spring/processor/NewLoanApplicationProcessorLogTimestampKey.java:46
MethodoperatingSchema
(R connectRecord)
custom-connector/src/main/java/bbejeck/chapter_5/transformer/MultiFieldExtract.java:112
MethodoperatingSchema
(R connectRecord)
custom-connector/src/main/java/bbejeck/chapter_5/transformer/MultiFieldExtract.java:129
MethodoperatingValue
(R connectRecord)
custom-connector/src/main/java/bbejeck/chapter_5/transformer/MultiFieldExtract.java:117
MethodoperatingValue
(R connectRecord)
custom-connector/src/main/java/bbejeck/chapter_5/transformer/MultiFieldExtract.java:135
MethodoverrideConfigs
(final Map<String, Object> overrideConfigs)
sr-full/src/main/java/bbejeck/chapter_3/producer/BaseProducer.java:32
MethodoverrideConfigs
(final Map<String, Object> overrideConfigs)
sr-backward/src/main/java/bbejeck/chapter_3/producer/BaseProducer.java:32
MethodoverrideConfigs
(final Map<String, Object> overrideConfigs)
sr-forward/src/main/java/bbejeck/chapter_3/producer/BaseProducer.java:32
MethodparameterizedIdempotentProducerTest
(boolean enableIdempotence, String groupId)
streams/src/test/java/bbejeck/chapter_4/IdempotentProducerTest.java:89
Methodpartition
(String topic, Windowed<K> windowedKey, V value, int numPartitions)
streams/src/main/java/bbejeck/chapter_9/partitioner/WindowedStreamsPartitioner.java:25
MethodpeekNextKey
()
streams/src/main/java/bbejeck/utils/TestUtils.java:85
Methodprocess
()
streams/src/main/java/bbejeck/chapter_4/pipelining/ConcurrentRecordProcessor.java:56
Methodprocess
(Record<String, BeerPurchase> beerPurchaseRecord)
streams/src/main/java/bbejeck/chapter_10/processor/BeerPurchaseProcessor.java:26
Methodprocess
(Record<KIn, VIn> record)
streams/src/main/java/bbejeck/chapter_10/processor/MapValueProcessor.java:19
Methodprocess
(Record<String, Sensor> sensorRecord)
streams/src/main/java/bbejeck/chapter_10/processor/DataDrivenAggregate.java:54
Methodprocess
(Record<String, Transaction> transactionRecord)
streams/src/main/java/bbejeck/chapter_10/processor/StockPerformanceProcessor.java:40
Methodprocess
(Record<String, Transaction> record)
streams/src/main/java/bbejeck/chapter_10/cancellation/StockPerformanceCancellingProcessor.java:53
MethodprocessRecords
(ConsumerRecords<String, ProductTransaction> records)
streams/src/main/java/bbejeck/chapter_4/pipelining/ConcurrentRecordProcessor.java:41
MethodproduceConsumeMultipleEventsFromSameTopic
()
streams/src/test/java/bbejeck/chapter_4/multi_event/proto/MultiEventProtoProduceConsumeTest.java:57
Methodproperties
()
streams/src/main/java/bbejeck/BaseStreamsApplication.java:30
Methodpunctuate
(long timestamp)
streams/src/main/java/bbejeck/chapter_10/punctuator/StockPerformancePunctuatorOldProcessorAPI.java:26
MethodqaLoansTopic
()
spring-kafka/src/main/java/bbejeck/spring/streams/container/KafkaStreamsContainerLoanApplicationApplication.java:66
← previousnext →501–600 of 814, ranked by callers