Functions — github.com/bbejeck/KafkaStreamsInAction2ndEdition

hub / github.com/bbejeck/KafkaStreamsInAction2ndEdition / functions

Functions814 in github.com/bbejeck/KafkaStreamsInAction2ndEdition

⨍ Functions 814◇ Types & classes 235

↓ 1 callersMethodgetFieldSchema

(final JsonNode node)

custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceTask.java:157

↓ 1 callersMethodgetHarryPotterCharacters

(int number)

streams/src/main/java/bbejeck/data/DataGenerator.java:356

↓ 1 callersMethodgetKafkaStreamsCustomizer

()

spring-kafka/src/main/java/bbejeck/spring/streams/boot/KafkaStreamsBootLoanApplicationApplication.java:83

↓ 1 callersMethodgetKeyMetadata

(K key, Serializer<K> keySerializer)

spring-kafka/src/main/java/bbejeck/spring/streams/container/LoanApplicationController.java:139

↓ 1 callersMethodgetNumberSchemaType

(final JsonNode numberNode)

custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceTask.java:179

↓ 1 callersMethodgetOffsets

()

streams/src/main/java/bbejeck/data/RecordProcessor.java:18

↓ 1 callersMethodgetProducer

(final boolean enableIdempotence)

streams/src/test/java/bbejeck/chapter_4/IdempotentProducerTest.java:150

↓ 1 callersMethodgetProducerConfigs

()

streams/src/test/java/bbejeck/chapter_4/multi_event/avro/MultiEventAvroProduceConsumeTest.java:100

↓ 1 callersMethodgetProducerConfigs

()

streams/src/main/java/bbejeck/chapter_14/CurrencyExchangeConsumeProduceApplication.java:86

↓ 1 callersMethodgetProducerConfigs

()

streams/src/main/java/bbejeck/chapter_4/pipelining/ProducePipeliningConsumeApplication.java:97

↓ 1 callersMethodgetProducerConfigs

()

streams/src/main/java/bbejeck/chapter_4/sales/SalesProduceConsumeApplication.java:89

↓ 1 callersMethodgetProducerProps

()

streams/src/test/java/bbejeck/chapter_4/multi_event/proto/MultiEventProtoProduceConsumeTest.java:73

↓ 1 callersMethodgetProperties

()

streams/src/main/java/bbejeck/chapter_8/KTableCountExample.java:78

↓ 1 callersMethodgetProperties

()

streams/src/main/java/bbejeck/chapter_8/KTableAggregationExample.java:106

↓ 1 callersMethodgetProperties

()

streams/src/main/java/bbejeck/chapter_8/KTableFilterExample.java:71

↓ 1 callersMethodgetProperties

()

streams/src/main/java/bbejeck/chapter_6/ZMartKafkaStreamsDynamicRoutingApp.java:98

↓ 1 callersMethodgetProperties

()

streams/src/main/java/bbejeck/chapter_6/KafkaStreamsYellingNamedProcessorsApp.java:84

↓ 1 callersMethodgetProperties

()

streams/src/main/java/bbejeck/chapter_6/SensorBranchingMergingApp.java:98

↓ 1 callersMethodgetProperties

()

streams/src/main/java/bbejeck/chapter_6/KafkaStreamsYellingApp.java:82

↓ 1 callersMethodgetProperties

()

streams/src/main/java/bbejeck/chapter_6/ZMartKafkaStreamsFilteringBranchingApp.java:158

↓ 1 callersMethodgetProperties

()

streams/src/main/java/bbejeck/chapter_6/ZMartKafkaStreamsApp.java:160

↓ 1 callersMethodgetProperties

()

streams/src/main/java/bbejeck/chapter_6/client_supplier/KafkaStreamsCustomClientsApp.java:66

↓ 1 callersMethodgetProperties

()

streams/src/main/java/bbejeck/chapter_9/hopping/StreamsCountHoppingWindow.java:71

↓ 1 callersMethodgetRecords

()

sr-full/src/main/java/bbejeck/chapter_3/producer/BaseProducer.java:30

↓ 1 callersMethodgetRecords

()

sr-backward/src/main/java/bbejeck/chapter_3/producer/BaseProducer.java:30

↓ 1 callersMethodgetRecords

()

streams/src/main/java/bbejeck/chapter_3/producer/proto/ProtoReferenceCollegeProducer.java:20

↓ 1 callersMethodgetRecords

()

streams/src/main/java/bbejeck/chapter_3/producer/json/JsonSchemaReferenceCompanyProducer.java:20

↓ 1 callersMethodgetRecords

()

streams/src/main/java/bbejeck/chapter_3/producer/avro/AvroReferenceCompanyProducer.java:20

↓ 1 callersMethodgetRecords

()

streams/src/main/java/bbejeck/chapter_3/producer/avro/AvroReferenceCollegeProducer.java:20

↓ 1 callersMethodgetRecords

()

sr-forward/src/main/java/bbejeck/chapter_3/producer/BaseProducer.java:30

↓ 1 callersMethodgetRequestString

(Map<String, String> props)

custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceTask.java:79

↓ 1 callersMethodgetResult

()

spring-kafka/src/main/java/bbejeck/spring/model/QueryResponse.java:52

↓ 1 callersMethodgetStockPerformance

()

streams/src/test/java/bbejeck/chapter_10/punctuator/StockPerformancePunctuatorTest.java:58

↓ 1 callersMethodgetSymbols

(int number)

streams/src/main/java/bbejeck/data/DataGenerator.java:365

↓ 1 callersMethodkvIterator

(Iterator<KeyValue<K, V>> values)

streams/src/main/java/bbejeck/utils/TestUtils.java:77

↓ 1 callersMethodmakeUpdatedSchema

(Schema schema)

custom-connector/src/main/java/bbejeck/chapter_5/transformer/MultiFieldExtract.java:104

↓ 1 callersMethodoperatingSchema

(R connectRecord)

custom-connector/src/main/java/bbejeck/chapter_5/transformer/MultiFieldExtract.java:74

↓ 1 callersMethodoverrideConfigs

(final Map<String, Object> overrideConfigs)

sr-full/src/main/java/bbejeck/chapter_3/consumer/BaseConsumer.java:60

↓ 1 callersMethodoverrideConfigs

(final Map<String, Object> overrideConfigs)

sr-backward/src/main/java/bbejeck/chapter_3/consumer/BaseConsumer.java:60

↓ 1 callersMethodoverrideConfigs

(final Map<String, Object> overrideConfigs)

sr-forward/src/main/java/bbejeck/chapter_3/consumer/BaseConsumer.java:60

↓ 1 callersMethodprocess

(Record<KIn, VIn> incomingRecord)

streams/src/main/java/bbejeck/chapter_10/processor/LoggingProcessor.java:18

↓ 1 callersMethodprocessRecords

(ConsumerRecords<K, V> records)

streams/src/main/java/bbejeck/data/RecordProcessor.java:16

↓ 1 callersMethodproduceIotData

()

streams/src/main/java/bbejeck/clients/MockDataProducer.java:345

↓ 1 callersMethodproduceJoinExampleRecords

(final String purchaseTopic, final String coffeeTopic)

streams/src/main/java/bbejeck/clients/MockDataProducer.java:203

↓ 1 callersMethodproduceKeyValuesWithTimestamp

(final String topic, final Collection<KeyValue<K,

streams/src/main/java/bbejeck/utils/TestUtils.java:32

↓ 1 callersMethodproducePurchasedItemsDataSchemaRegistry

()

streams/src/main/java/bbejeck/clients/MockDataProducer.java:72

↓ 1 callersMethodproduceStockAlertsForKtableAggregateExample

(final String topic)

streams/src/main/java/bbejeck/clients/MockDataProducer.java:151

↓ 1 callersMethodproduceStockTransactions

(final String topic)

streams/src/main/java/bbejeck/clients/MockDataProducer.java:249

↓ 1 callersMethodproducerConfig

(final Map<String, Object> overrides)

sr-full/src/main/java/bbejeck/chapter_3/producer/BaseProducer.java:44

↓ 1 callersMethodproducerConfig

(final Map<String, Object> overrides)

sr-backward/src/main/java/bbejeck/chapter_3/producer/BaseProducer.java:44

↓ 1 callersMethodproducerConfig

(final Map<String, Object> overrides)

streams/src/main/java/bbejeck/chapter_3/producer/BaseProducer.java:39

↓ 1 callersMethodproducerConfig

(final Map<String, Object> overrides)

sr-forward/src/main/java/bbejeck/chapter_3/producer/BaseProducer.java:44

↓ 1 callersMethodpropertiesToMap

(final Properties properties)

streams/src/main/java/bbejeck/utils/SerdeUtil.java:46

↓ 1 callersMethodpunctuate

(long timestamp)

streams/src/main/java/bbejeck/chapter_10/punctuator/StockPerformancePunctuator.java:27

↓ 1 callersMethodreadKeyValues

(final String topic, final Properties consumerProp

streams/src/main/java/bbejeck/utils/TestUtils.java:54

↓ 1 callersMethodrunConsumer

(final Map<String, Object> configs, final String topic,

sr-full/src/main/java/bbejeck/chapter_3/consumer/BaseConsumer.java:33

↓ 1 callersMethodrunConsumer

(final Map<String, Object> configs, final String topic,

sr-backward/src/main/java/bbejeck/chapter_3/consumer/BaseConsumer.java:33

↓ 1 callersMethodrunConsumer

()

streams/src/main/java/bbejeck/chapter_4/multi_event/proto/MultiEventProtoConsumerClient.java:48

↓ 1 callersMethodrunConsumer

()

streams/src/main/java/bbejeck/chapter_4/multi_event/avro/MultiEventAvroConsumerClient.java:45

↓ 1 callersMethodrunConsumer

(final Map<String, Object> configs, final String topic,

sr-forward/src/main/java/bbejeck/chapter_3/consumer/BaseConsumer.java:33

↓ 1 callersMethodrunConsumerOnce

()

streams/src/main/java/bbejeck/chapter_4/multi_event/proto/MultiEventProtoConsumerClient.java:65

↓ 1 callersMethodrunConsumerOnce

()

streams/src/main/java/bbejeck/chapter_4/multi_event/avro/MultiEventAvroConsumerClient.java:72

↓ 1 callersMethodrunExchange

()

streams/src/main/java/bbejeck/chapter_14/CurrencyExchangeClient.java:40

↓ 1 callersMethodrunProducer

()

streams/src/main/java/bbejeck/chapter_4/multi_event/proto/MultiEventProtoProducerClient.java:42

↓ 1 callersMethodrunProducer

()

streams/src/main/java/bbejeck/chapter_4/multi_event/avro/MultiEventAvroProducerClient.java:42

↓ 1 callersMethodrunProducerOnce

()

streams/src/main/java/bbejeck/chapter_4/multi_event/proto/MultiEventProtoProducerClient.java:64

↓ 1 callersMethodrunProducerOnce

()

streams/src/main/java/bbejeck/chapter_4/multi_event/avro/MultiEventAvroProducerClient.java:75

↓ 1 callersMethodrunTest

(final boolean enableIdempotence, final String groupId)

streams/src/test/java/bbejeck/chapter_4/IdempotentProducerTest.java:99

↓ 1 callersMethodsend

(final String topicName)

sr-backward/src/main/java/bbejeck/chapter_3/producer/BaseProducer.java:36

↓ 1 callersMethodsend

(final String topicName)

sr-forward/src/main/java/bbejeck/chapter_3/producer/BaseProducer.java:36

↓ 1 callersMethodserialize

(String topic, T data)

streams/src/main/java/bbejeck/serializers/ProtoSerializer.java:12

↓ 1 callersMethodsetAverageReading

(double averageReading)

streams/src/main/java/bbejeck/chapter_9/IotSensorAggregation.java:73

↓ 1 callersMethodsetHighestSeen

(double highestSeen)

streams/src/main/java/bbejeck/chapter_9/IotSensorAggregation.java:77

↓ 1 callersMethodsetHostType

(String hostType)

spring-kafka/src/main/java/bbejeck/spring/model/QueryResponse.java:36

↓ 1 callersMethodsetNumberReadings

(int numberReadings)

streams/src/main/java/bbejeck/chapter_9/IotSensorAggregation.java:46

↓ 1 callersMethodsetTempThresholdExceededCount

(int tempThresholdExceededCount)

streams/src/main/java/bbejeck/chapter_9/IotSensorAggregation.java:55

↓ 1 callersMethodsetTemperatureSum

(double temperatureSum)

streams/src/main/java/bbejeck/chapter_9/IotSensorAggregation.java:37

↓ 1 callersMethodsetWindowEnd

(long windowEnd)

streams/src/main/java/bbejeck/chapter_9/IotSensorAggregation.java:89

↓ 1 callersMethodsetWindowStart

(long windowStart)

streams/src/main/java/bbejeck/chapter_9/IotSensorAggregation.java:81

↓ 1 callersMethodstop

()

custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceTask.java:191

↓ 1 callersMethodtopology

()

spring-kafka/src/main/java/bbejeck/spring/streams/container/LoanApplicationTopology.java:53

↓ 1 callersMethodtopology

(Properties streamProperties)

streams/src/main/java/bbejeck/chapter_8/joins/StreamTableVersionedJoinExample.java:46

↓ 1 callersMethodtopology

(Properties streamProperties)

streams/src/main/java/bbejeck/chapter_8/joins/KTableForeignKeyJoinExample.java:46

↓ 1 callersMethodtopology

(Properties streamProperties)

streams/src/main/java/bbejeck/chapter_6/ZMartKafkaStreamsDynamicRoutingApp.java:59

↓ 1 callersMethodtopology

(Properties streamProperties)

streams/src/main/java/bbejeck/chapter_6/ZMartKafkaStreamsApp.java:81

↓ 1 callersMethodtopology

()

streams/src/main/java/bbejeck/chapter_6/client_supplier/KafkaStreamsCustomClientsApp.java:38

↓ 1 callersMethodtopology

(Properties streamProperties)

streams/src/main/java/bbejeck/chapter_9/IotStreamingAggregationNoWindows.java:33

↓ 1 callersMethodtopology

(Properties streamProperties)

streams/src/main/java/bbejeck/chapter_9/session/PageViewSessionWindowsWithSuppression.java:50

↓ 1 callersMethodtopology

(Properties streamProperties)

streams/src/main/java/bbejeck/chapter_9/session/StreamsCountSessionWindow.java:34

↓ 1 callersMethodtopology

(Properties streamProperties)

streams/src/main/java/bbejeck/chapter_9/session/PageViewSessionWindowsEmitOnClose.java:47

↓ 1 callersMethodtopology

(Properties streamProperties)

streams/src/main/java/bbejeck/chapter_9/sliding/StreamsCountSlidingWindow.java:35

↓ 1 callersMethodtopology

(Properties streamProperties)

streams/src/main/java/bbejeck/chapter_9/hopping/StreamsCountHoppingWindowExtractKey.java:35

↓ 1 callersMethodtopology

(Properties streamProperties)

streams/src/main/java/bbejeck/chapter_9/hopping/StreamsCountHoppingWindow.java:34

↓ 1 callersMethodtopology

(Properties streamProperties)

streams/src/main/java/bbejeck/chapter_9/tumbling/StreamsCountTumblingWindowSuppressedEager.java:40

↓ 1 callersMethodtopology

(Properties streamProperties)

streams/src/main/java/bbejeck/chapter_9/tumbling/IotStreamingAggregationStreamPartitionerTumblingWindows.java:48

↓ 1 callersMethodtopology

(Properties streamProperties)

streams/src/main/java/bbejeck/chapter_9/tumbling/IotStreamingAggregationMapWindowTimeTumblingWindows.java:37

↓ 1 callersMethodtopology

(Properties streamProperties)

streams/src/main/java/bbejeck/chapter_9/tumbling/StreamsCountTumblingWindow.java:37

↓ 1 callersMethodtopology

(Properties streamProperties)

streams/src/main/java/bbejeck/chapter_9/tumbling/StreamsCountTumblingWindowSuppressedStrict.java:39

↓ 1 callersMethodtopology

(final Properties streamProperties)

streams/src/main/java/bbejeck/chapter_7/StreamsChangeKeyThenReuseRepartition.java:33

↓ 1 callersMethodtopology

(final Properties streamProperties)

streams/src/main/java/bbejeck/chapter_7/StreamsPokerGameInMemoryStoreReducer.java:32

← previous next →201–300 of 814, ranked by callers