MCPcopy Create free account

hub / github.com/bbejeck/KafkaStreamsInAction2ndEdition / functions

Functions814 in github.com/bbejeck/KafkaStreamsInAction2ndEdition

⨍ Functions 814◇ Types & classes 235
↓ 2 callersMethodcalculateDifferentialFromAverage
(double value, double average)
streams/src/main/java/bbejeck/chapter_10/processor/StockPerformanceProcessor.java:82
↓ 2 callersMethodcalculateDifferentialFromAverage
(double value, double average)
streams/src/main/java/bbejeck/chapter_10/cancellation/StockPerformanceCancellingProcessor.java:93
↓ 2 callersMethodcalculateNewAverage
(double newValue, double currentAverage, List<Double> deque)
streams/src/main/java/bbejeck/chapter_10/processor/StockPerformanceProcessor.java:86
↓ 2 callersMethodcalculateNewAverage
(double newValue, double currentAverage, List<Double> deque)
streams/src/main/java/bbejeck/chapter_10/cancellation/StockPerformanceCancellingProcessor.java:97
↓ 2 callersMethodconfigure
(Map<String, ?> configs, boolean isKey)
streams/src/main/java/bbejeck/serializers/ProtoDeserializer.java:37
↓ 2 callersMethodconsumeRecords
(final KafkaConsumer<String, Integer> consumer)
streams/src/test/java/bbejeck/chapter_4/TransactionalProducerConsumerTest.java:133
↓ 2 callersMethodcreateNode
(String symbol, String displayName, Faker faker)
custom-connector/src/main/java/bbejeck/chapter_5/web_server/TickerServer.java:82
↓ 2 callersMethoddoKeyQuery
(final HostInfo targetHostInfo, final Query<ValueAndTimest
spring-kafka/src/main/java/bbejeck/spring/streams/container/LoanApplicationController.java:101
↓ 2 callersMethodfail
(Exception e)
custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceConnectorMonitorThread.java:102
↓ 2 callersMethodgenerateSensorInfo
(int numberInfoObjects)
streams/src/main/java/bbejeck/data/DataGenerator.java:335
↓ 2 callersMethodgenerateSensorReadings
(int numberRecords)
streams/src/main/java/bbejeck/data/DataGenerator.java:161
↓ 2 callersMethodgenerateStockAlertsForKTableAggregateExample
()
streams/src/main/java/bbejeck/data/DataGenerator.java:88
↓ 2 callersMethodgenerateStockTransaction
(int numberRecords)
streams/src/main/java/bbejeck/data/DataGenerator.java:262
↓ 2 callersMethodgetClassConfig
(boolean isKey)
streams/src/main/java/bbejeck/utils/SerdeUtil.java:52
↓ 2 callersMethodgetConsumer
(final String isolationLevel)
streams/src/test/java/bbejeck/chapter_4/TransactionalProducerConsumerTest.java:171
↓ 2 callersMethodgetConsumerConfigs
(final boolean specificType)
streams/src/test/java/bbejeck/chapter_3/AvroProducerConsumerTest.java:125
↓ 2 callersMethodgetConsumerConfigs
()
streams/src/test/java/bbejeck/chapter_3/JsonSchemaProduceConsumeTest.java:141
↓ 2 callersMethodgetConsumerConfigs
(final boolean isSpecific)
streams/src/test/java/bbejeck/chapter_3/ProtobufProduceConsumeTest.java:140
↓ 2 callersMethodgetConsumerProps
()
streams/src/test/java/bbejeck/chapter_4/TransactionalConsumeTransformProduceTest.java:171
↓ 2 callersMethodgetJsonFromFile
(final String jsonResultsFileName)
custom-connector/src/test/java/bbejeck/chapter_5/connector/StockTickerSourceTaskTest.java:110
↓ 2 callersMethodgetProducer
()
streams/src/test/java/bbejeck/chapter_4/TransactionalProducerConsumerTest.java:161
↓ 2 callersMethodgetProducerConfigs
()
streams/src/test/java/bbejeck/chapter_3/AvroProducerConsumerTest.java:116
↓ 2 callersMethodgetProducerConfigs
()
streams/src/test/java/bbejeck/chapter_3/JsonSchemaProduceConsumeTest.java:131
↓ 2 callersMethodgetProducerConfigs
()
streams/src/test/java/bbejeck/chapter_3/ProtobufProduceConsumeTest.java:130
↓ 2 callersMethodgetProducerProps
()
streams/src/test/java/bbejeck/chapter_4/TransactionalConsumeTransformProduceTest.java:161
↓ 2 callersMethodgetRecords
()
streams/src/main/java/bbejeck/chapter_3/producer/proto/ProtoReferenceCompanyProducer.java:25
↓ 2 callersMethodgetRecords
()
streams/src/main/java/bbejeck/chapter_3/producer/json/JsonSchemaReferenceCollegeProducer.java:25
↓ 2 callersMethodhasError
()
spring-kafka/src/main/java/bbejeck/spring/model/QueryResponse.java:41
↓ 2 callersMethodpartition
(String topic, Object key, byte[] keyBytes,
streams/src/main/java/bbejeck/chapter_4/sales/CustomOrderPartitioner.java:18
↓ 2 callersMethodproduceFixedNamesWithScores
(final String topic)
streams/src/main/java/bbejeck/clients/MockDataProducer.java:299
↓ 2 callersMethodreadingThreshold
()
streams/src/main/java/bbejeck/chapter_9/IotSensorAggregation.java:59
↓ 2 callersMethodrotatingStringKeyFunction
(int numKeys)
streams/src/main/java/bbejeck/utils/Functions.java:16
↓ 2 callersMethodshutdown
()
custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceConnectorMonitorThread.java:114
↓ 2 callersMethodsymbols
()
custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceConnectorMonitorThread.java:77
↓ 2 callersMethodtaskConfigs
(int maxTasks)
custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceConnector.java:64
↓ 2 callersMethodtemperatureSum
()
streams/src/main/java/bbejeck/chapter_9/IotSensorAggregation.java:32
↓ 2 callersMethodtopology
(Properties streamProperties)
streams/src/main/java/bbejeck/chapter_8/KTableAggregationExample.java:39
↓ 2 callersMethodtopology
(Properties streamProperties)
streams/src/main/java/bbejeck/chapter_8/joins/StreamTableJoinExample.java:42
↓ 2 callersMethodtopology
(Properties streamProperties)
streams/src/main/java/bbejeck/chapter_8/joins/StreamGlobalKTableJoinExample.java:45
↓ 2 callersMethodtopology
(Properties streamProperties)
streams/src/main/java/bbejeck/chapter_6/SensorBranchingMergingApp.java:41
↓ 2 callersMethodtopology
(Properties streamProperties)
streams/src/main/java/bbejeck/chapter_6/KafkaStreamsYellingApp.java:48
↓ 2 callersMethodtopology
(Properties streamProperties)
streams/src/main/java/bbejeck/chapter_6/ZMartKafkaStreamsFilteringBranchingApp.java:88
↓ 2 callersMethodtopology
(Properties streamProperties)
streams/src/main/java/bbejeck/chapter_9/sliding/PageViewSlidingWindows.java:42
↓ 2 callersMethodtopology
(Properties streamProperties)
streams/src/main/java/bbejeck/chapter_9/tumbling/IotStreamingAggregationTumblingWindows.java:47
↓ 2 callersMethodtopology
(Properties streamProperties)
streams/src/main/java/bbejeck/chapter_7/KafkaStreamsJoinsApp.java:36
↓ 2 callersMethodtopology
(final Properties streamProperties)
streams/src/main/java/bbejeck/chapter_7/StreamsStockTransactionAggregations.java:38
↓ 2 callersMethodtopology
(final Properties streamProperties)
streams/src/main/java/bbejeck/chapter_7/StreamsPokerGameReducer.java:30
↓ 2 callersMethodtopology
(Properties streamProperties)
streams/src/main/java/bbejeck/chapter_10/PopsHopsApplication.java:40
↓ 2 callersMethodtopology
(Properties streamProperties)
streams/src/main/java/bbejeck/chapter_10/StockPerformanceDslAndProcessorApplication.java:48
↓ 2 callersMethodupdate
(LoanApplication loanApplication)
spring-kafka/src/main/java/bbejeck/spring/model/LoanAppRollup.java:21
↓ 1 callersMethodaddHeader
(RetailPurchase purchase, ProducerRecord<String, RetailPurchase> producerRecord)
streams/src/main/java/bbejeck/clients/MockDataProducer.java:113
↓ 1 callersMethodapplySchemaless
(R connectRecord)
custom-connector/src/main/java/bbejeck/chapter_5/transformer/MultiFieldExtract.java:80
↓ 1 callersMethodapplyWithSchema
(R connectRecord)
custom-connector/src/main/java/bbejeck/chapter_5/transformer/MultiFieldExtract.java:88
↓ 1 callersMethodclose
()
spring-kafka/src/main/java/bbejeck/spring/datagen/MockLoanApplicationDataGenerator.java:68
↓ 1 callersMethodclose
()
custom-connector/src/main/java/bbejeck/chapter_5/transformer/MultiFieldExtract.java:65
↓ 1 callersMethodclose
()
streams/src/main/java/bbejeck/chapter_14/CurrencyExchangeClient.java:62
↓ 1 callersMethodclose
()
streams/src/main/java/bbejeck/chapter_4/multi_event/proto/MultiEventProtoProducerClient.java:70
↓ 1 callersMethodclose
()
streams/src/main/java/bbejeck/chapter_4/multi_event/proto/MultiEventProtoConsumerClient.java:107
↓ 1 callersMethodclose
()
streams/src/main/java/bbejeck/chapter_4/multi_event/avro/MultiEventAvroConsumerClient.java:77
↓ 1 callersMethodclose
()
streams/src/main/java/bbejeck/chapter_4/multi_event/avro/MultiEventAvroProducerClient.java:81
↓ 1 callersMethodclose
()
streams/src/main/java/bbejeck/chapter_4/pipelining/PipeliningProducerClient.java:59
↓ 1 callersMethodclose
()
streams/src/main/java/bbejeck/chapter_4/pipelining/PipeliningConsumerClient.java:62
↓ 1 callersMethodclose
()
streams/src/main/java/bbejeck/chapter_4/sales/SalesConsumerClient.java:49
↓ 1 callersMethodclose
()
streams/src/main/java/bbejeck/chapter_4/sales/SalesProducerClient.java:68
↓ 1 callersMethodconfigure
(Map<String, ?> props)
custom-connector/src/main/java/bbejeck/chapter_5/transformer/MultiFieldExtract.java:43
↓ 1 callersMethodconsumerConfig
(final Map<String, Object> overrides)
sr-full/src/main/java/bbejeck/chapter_3/consumer/BaseConsumer.java:64
↓ 1 callersMethodconsumerConfig
(final Map<String, Object> overrides)
sr-backward/src/main/java/bbejeck/chapter_3/consumer/BaseConsumer.java:64
↓ 1 callersMethodconsumerConfig
(final Map<String, Object> overrides)
streams/src/main/java/bbejeck/chapter_3/consumer/BaseConsumer.java:60
↓ 1 callersMethodconsumerConfig
(final Map<String, Object> overrides)
sr-forward/src/main/java/bbejeck/chapter_3/consumer/BaseConsumer.java:64
↓ 1 callersMethodconsumerConfigs
()
spring-kafka/src/main/java/bbejeck/spring/application/LoanApplicationProcessingApplicationAdvanced.java:74
↓ 1 callersMethodconsumerFactory
()
spring-kafka/src/main/java/bbejeck/spring/application/LoanApplicationProcessingApplicationAdvanced.java:82
↓ 1 callersMethodconvertToDollars
(String currentCurrency, double internationalAmount)
streams/src/main/java/bbejeck/chapter_10/processor/BeerPurchaseProcessor.java:45
↓ 1 callersMethodcreateTopic
(final Properties props, final String name, final in
streams/src/test/java/bbejeck/chapter_3/AvroProducerConsumerTest.java:137
↓ 1 callersMethodcreateTopic
(final Properties props, final String name, final in
streams/src/test/java/bbejeck/chapter_3/JsonSchemaProduceConsumeTest.java:153
↓ 1 callersMethodcreateTopic
(final Properties props, final String name, final in
streams/src/test/java/bbejeck/chapter_3/ProtobufProduceConsumeTest.java:155
↓ 1 callersMethodcreateTopic
(final Properties props, final String name, final in
streams/src/test/java/bbejeck/chapter_4/multi_event/avro/MultiEventAvroProduceConsumeTest.java:125
↓ 1 callersMethoddeleteTopic
(final Properties props, final String name)
streams/src/test/java/bbejeck/chapter_3/AvroProducerConsumerTest.java:146
↓ 1 callersMethoddeleteTopic
(final Properties props, final String name)
streams/src/test/java/bbejeck/chapter_3/JsonSchemaProduceConsumeTest.java:162
↓ 1 callersMethoddeleteTopic
(final Properties props, final String name)
streams/src/test/java/bbejeck/chapter_3/ProtobufProduceConsumeTest.java:164
↓ 1 callersMethoddeleteTopic
(final Properties props, final String name)
streams/src/test/java/bbejeck/chapter_4/multi_event/avro/MultiEventAvroProduceConsumeTest.java:134
↓ 1 callersMethoddeserialize
(String topic, byte[] data)
streams/src/main/java/bbejeck/serializers/ProtoDeserializer.java:24
↓ 1 callersMethoddoRemoteRequest
(String host, int port, String path)
spring-kafka/src/main/java/bbejeck/spring/streams/container/LoanApplicationController.java:124
↓ 1 callersMethodexchangeToDollars
(double amount)
streams/src/main/java/bbejeck/chapter_14/CurrencyExchangeTransaction.java:20
↓ 1 callersMethodextractKey
(final SpecificRecord record, final String keyField)
streams/src/main/java/bbejeck/chapter_4/multi_event/avro/MultiEventAvroProducerClient.java:66
↓ 1 callersMethodgenerateEmployees
(int numberEmployees)
streams/src/main/java/bbejeck/data/DataGenerator.java:309
↓ 1 callersMethodgenerateFixedNamesWithAScore
()
streams/src/main/java/bbejeck/data/DataGenerator.java:79
↓ 1 callersMethodgenerateJoinExampleData
(final int numberRecords)
streams/src/main/java/bbejeck/data/DataGenerator.java:196
↓ 1 callersMethodgenerateSensorReadingsList
(int numberReadings)
streams/src/main/java/bbejeck/data/DataGenerator.java:323
↓ 1 callersMethodgenerateStockTransactions
(int numberRecords)
streams/src/main/java/bbejeck/data/DataGenerator.java:139
↓ 1 callersMethodget
()
streams/src/main/java/bbejeck/chapter_9/data/PageViewSlidingWindowRecordSupplier.java:37
↓ 1 callersMethodget
()
streams/src/main/java/bbejeck/chapter_9/data/IotWindowedRecordSupplier.java:31
↓ 1 callersMethodgetConsumer
(final String groupId)
streams/src/test/java/bbejeck/chapter_4/IdempotentProducerTest.java:161
↓ 1 callersMethodgetConsumerConfigs
()
streams/src/test/java/bbejeck/chapter_4/multi_event/avro/MultiEventAvroProduceConsumeTest.java:112
↓ 1 callersMethodgetConsumerConfigs
()
streams/src/main/java/bbejeck/chapter_14/CurrencyExchangeConsumeProduceApplication.java:72
↓ 1 callersMethodgetConsumerConfigs
()
streams/src/main/java/bbejeck/chapter_4/pipelining/ProducePipeliningConsumeApplication.java:82
↓ 1 callersMethodgetConsumerConfigs
()
streams/src/main/java/bbejeck/chapter_4/sales/SalesProduceConsumeApplication.java:73
↓ 1 callersMethodgetConsumerProps
()
streams/src/test/java/bbejeck/chapter_4/multi_event/proto/MultiEventProtoProduceConsumeTest.java:83
↓ 1 callersMethodgetConsumerProps
()
streams/src/main/java/bbejeck/chapter_3/AvroReflectionProduceConsumeExample.java:66
↓ 1 callersMethodgetEventTypeByEnum
(final Events event)
streams/src/main/java/bbejeck/chapter_4/multi_event/proto/MultiEventProtoConsumerClient.java:70
↓ 1 callersMethodgetFavoriteColor
()
streams/src/main/java/bbejeck/chapter_3/model/User.java:39
← previousnext →101–200 of 814, ranked by callers