MCPcopy Create free account

hub / github.com/bbejeck/KafkaStreamsInAction2ndEdition / functions

Functions814 in github.com/bbejeck/KafkaStreamsInAction2ndEdition

⨍ Functions 814◇ Types & classes 235
MethodtearDown
()
streams/src/test/java/bbejeck/chapter_3/AvroProducerConsumerTest.java:59
MethodtearDown
()
streams/src/test/java/bbejeck/chapter_3/JsonSchemaProduceConsumeTest.java:73
MethodtearDown
()
streams/src/test/java/bbejeck/chapter_3/ProtobufProduceConsumeTest.java:74
MethodtearDown
()
streams/src/test/java/bbejeck/chapter_4/TransactionalProducerConsumerTest.java:60
MethodtearDown
()
streams/src/test/java/bbejeck/chapter_4/TransactionalConsumeTransformProduceTest.java:77
MethodtearDown
()
streams/src/test/java/bbejeck/chapter_4/multi_event/proto/MultiEventProtoProduceConsumeTest.java:50
MethodtearDown
()
streams/src/test/java/bbejeck/chapter_4/multi_event/avro/MultiEventAvroProduceConsumeTest.java:77
MethodtearDown
()
streams/src/test/java/bbejeck/chapter_10/SensorAlertingApplicationTest.java:55
MethodtearDown
()
streams/src/test/java/bbejeck/chapter_10/StockPerformanceDslAndProcessorApplicationTest.java:51
MethodtearDown
()
streams/src/test/java/bbejeck/chapter_10/PopsHopsApplicationTest.java:45
MethodtestAdderAggregatesShareAndDollarVolume
()
streams/src/test/java/bbejeck/chapter_8/KTableAggregationExampleTest.java:49
MethodtestAggregationAccumulatesOverMultipleRecords
()
streams/src/test/java/bbejeck/chapter_9/IotStreamingAggregationNoWindowsTest.java:40
MethodtestAggregationValuesOnWindowClose
()
streams/src/test/java/bbejeck/chapter_9/hopping/IotStreamingAggregationHoppingWindowsEmitOnCloseTest.java:111
MethodtestAggregationWithinSingleWindow
()
streams/src/test/java/bbejeck/chapter_9/hopping/IotStreamingAggregationHoppingWindowsTest.java:40
MethodtestAllOutputStreamsForCoffeePurchaseOverTenDollars
()
streams/src/test/java/bbejeck/chapter_6/ZMartKafkaStreamsFilteringBranchingAppTest.java:169
MethodtestAlreadyUppercaseInput
()
streams/src/test/java/bbejeck/chapter_6/KafkaStreamsYellingAppWithPeekTest.java:77
MethodtestBeerTypePreservedAfterConversion
()
streams/src/test/java/bbejeck/chapter_10/PopsHopsApplicationTest.java:124
MethodtestBonusPointsForLargePurchase
()
streams/src/test/java/bbejeck/chapter_7/KafkaStreamsJoinsAppTest.java:83
MethodtestBothTemperatureSourcesMerge
()
streams/src/test/java/bbejeck/chapter_6/SensorBranchingMergingAppTest.java:124
MethodtestClickWithNoMatchingUserProducesNoOutput
()
streams/src/test/java/bbejeck/chapter_8/joins/StreamTableJoinExampleTest.java:69
MethodtestCoffeeBranch
()
streams/src/test/java/bbejeck/chapter_6/ZMartKafkaStreamsFilteringBranchingAppTest.java:136
MethodtestConsumeOnlyOnceAfterAbortReadCommitted
(final List<Integer> expectedRecords, final String
streams/src/test/java/bbejeck/chapter_4/TransactionalProducerConsumerTest.java:92
MethodtestConsumeTransformProduceTransaction
()
streams/src/test/java/bbejeck/chapter_4/TransactionalConsumeTransformProduceTest.java:85
MethodtestCountAfterRepartition
()
streams/src/test/java/bbejeck/chapter_7/RepartitionForThroughputTest.java:20
MethodtestCountIncrementsWithinSession
()
streams/src/test/java/bbejeck/chapter_9/session/StreamsCountSessionWindowTest.java:34
MethodtestCountIncrementsWithinWindow
()
streams/src/test/java/bbejeck/chapter_9/hopping/StreamsCountHoppingWindowTest.java:33
MethodtestCreateTopics
()
streams/src/test/java/bbejeck/chapter_4/AdminClientTest.java:40
MethodtestCreditCardMasking
()
streams/src/test/java/bbejeck/chapter_6/ZMartKafkaStreamsFilteringBranchingAppTest.java:77
MethodtestDefaultBranch
()
streams/src/test/java/bbejeck/chapter_6/ZMartKafkaStreamsFilteringBranchingAppTest.java:158
MethodtestDeleteTopics
()
streams/src/test/java/bbejeck/chapter_4/AdminClientTest.java:60
MethodtestDifferentKeysDontJoin
()
streams/src/test/java/bbejeck/chapter_7/KafkaStreamsJoinsAppTest.java:108
MethodtestDifferentKeysHaveIndependentAggregations
()
streams/src/test/java/bbejeck/chapter_9/IotStreamingAggregationNoWindowsTest.java:93
MethodtestDifferentKeysHaveIndependentCounts
()
streams/src/test/java/bbejeck/chapter_9/hopping/StreamsCountHoppingWindowTest.java:59
MethodtestDifferentKeysHaveIndependentSessions
()
streams/src/test/java/bbejeck/chapter_9/session/StreamsCountSessionWindowTest.java:92
MethodtestDifferentSegmentsAreAggregatedIndependently
()
streams/src/test/java/bbejeck/chapter_8/KTableAggregationExampleTest.java:78
MethodtestDifferentSymbolsAreIndependent
()
streams/src/test/java/bbejeck/chapter_10/StockPerformanceDslAndProcessorApplicationTest.java:121
MethodtestDifferentUsersHaveIndependentSessions
()
streams/src/test/java/bbejeck/chapter_9/session/PageViewSessionWindowsTest.java:121
MethodtestDirectProximityInputMergesIntoOutputWithoutConversion
()
streams/src/test/java/bbejeck/chapter_6/SensorBranchingMergingAppTest.java:107
MethodtestDirectTemperatureInputMergesIntoOutput
()
streams/src/test/java/bbejeck/chapter_6/SensorBranchingMergingAppTest.java:91
MethodtestDollarPurchaseGoesToDomestic
()
streams/src/test/java/bbejeck/chapter_10/PopsHopsApplicationTest.java:50
MethodtestEachWindowProducesOneResultPerKey
()
streams/src/test/java/bbejeck/chapter_9/tumbling/StreamsCountTumblingWindowSuppressedStrictTest.java:90
MethodtestElectronicsBranch
()
streams/src/test/java/bbejeck/chapter_6/ZMartKafkaStreamsFilteringBranchingAppTest.java:147
MethodtestEmptyInputProducesNoOutput
()
streams/src/test/java/bbejeck/chapter_7/RepartitionForThroughputTest.java:88
MethodtestEuroPurchaseGoesToInternationalConverted
()
streams/src/test/java/bbejeck/chapter_10/PopsHopsApplicationTest.java:68
MethodtestEvenKeyIsCountedCorrectly
()
streams/src/test/java/bbejeck/chapter_8/KTableCountExampleTest.java:30
MethodtestFlatMapToPatterns
()
streams/src/test/java/bbejeck/chapter_6/ZMartKafkaStreamsFilteringBranchingAppTest.java:91
MethodtestIndependentCountsPerKey
()
streams/src/test/java/bbejeck/chapter_7/RepartitionForThroughputTest.java:46
MethodtestJoinProducesEnrichedOutput
()
streams/src/test/java/bbejeck/chapter_8/joins/StreamGlobalKTableJoinExampleTest.java:49
MethodtestJoinProducesEnrichedOutput
()
streams/src/test/java/bbejeck/chapter_8/joins/StreamTableJoinExampleTest.java:49
MethodtestJoinProducesPromotion
()
streams/src/test/java/bbejeck/chapter_7/KafkaStreamsJoinsAppTest.java:53
MethodtestKTableSemantics
()
streams/src/test/java/bbejeck/chapter_8/KTableFilterExampleTest.java:96
MethodtestKTableUpdateAdjustsCount
()
streams/src/test/java/bbejeck/chapter_8/KTableCountExampleTest.java:126
MethodtestKeyIsPreserved
()
streams/src/test/java/bbejeck/chapter_6/KafkaStreamsYellingAppWithPeekTest.java:57
MethodtestKeyPassThrough
()
streams/src/test/java/bbejeck/chapter_6/KafkaStreamsYellingNamedProcessorsAppTest.java:38
MethodtestLateRecordWithinGraceIsIncluded
()
streams/src/test/java/bbejeck/chapter_9/session/StreamsCountSessionWindowTest.java:127
MethodtestMixedKeysProduceIndependentCounts
()
streams/src/test/java/bbejeck/chapter_8/KTableCountExampleTest.java:89
MethodtestMixedPurchasesRouteCorrectly
()
streams/src/test/java/bbejeck/chapter_10/PopsHopsApplicationTest.java:107
MethodtestMultipleClicksFromSameUser
()
streams/src/test/java/bbejeck/chapter_8/joins/StreamTableJoinExampleTest.java:79
MethodtestMultipleSensorsJoinIndependently
()
streams/src/test/java/bbejeck/chapter_8/joins/StreamGlobalKTableJoinExampleTest.java:84
MethodtestNewSessionStartsAfterGap
()
streams/src/test/java/bbejeck/chapter_9/session/StreamsCountSessionWindowTest.java:60
MethodtestNoCrossRouting
()
streams/src/test/java/bbejeck/chapter_6/SensorBranchingMergingAppTest.java:138
MethodtestNoIntermediateEmissionsWhileWindowIsOpen
()
streams/src/test/java/bbejeck/chapter_9/hopping/IotStreamingAggregationHoppingWindowsEmitOnCloseTest.java:43
MethodtestNoIntermediateEmissionsWhileWindowIsOpen
()
streams/src/test/java/bbejeck/chapter_9/tumbling/IotStreamingAggregationEmitOnCloseTumblingWindowTest.java:40
MethodtestNoOutputWhileWindowIsOpen
()
streams/src/test/java/bbejeck/chapter_9/tumbling/StreamsCountTumblingWindowSuppressedStrictTest.java:34
MethodtestNoPunctuationWithoutTimeAdvance
()
streams/src/test/java/bbejeck/chapter_10/StockPerformanceDslAndProcessorApplicationTest.java:74
MethodtestNonQualifyingPurchaseDoesNotProduceReward
()
streams/src/test/java/bbejeck/chapter_6/ZMartKafkaStreamsFilteringBranchingAppTest.java:127
MethodtestOddKeyIsCountedCorrectly
()
streams/src/test/java/bbejeck/chapter_8/KTableCountExampleTest.java:61
MethodtestOneOutputPerInput
()
streams/src/test/java/bbejeck/chapter_6/KafkaStreamsYellingNamedProcessorsAppTest.java:58
MethodtestOneToOneMapping
()
streams/src/test/java/bbejeck/chapter_6/KafkaStreamsYellingAppWithPeekTest.java:39
MethodtestOnlyFinalResultEmittedWhenWindowCloses
()
streams/src/test/java/bbejeck/chapter_9/hopping/IotStreamingAggregationHoppingWindowsEmitOnCloseTest.java:68
MethodtestParameters
()
streams/src/test/java/bbejeck/chapter_4/TransactionalProducerConsumerTest.java:151
MethodtestParameters
()
streams/src/test/java/bbejeck/chapter_4/IdempotentProducerTest.java:171
MethodtestPeekDoesNotAlterValues
()
streams/src/test/java/bbejeck/chapter_6/KafkaStreamsYellingAppWithPeekTest.java:19
MethodtestPoundPurchaseGoesToInternationalConverted
()
streams/src/test/java/bbejeck/chapter_10/PopsHopsApplicationTest.java:89
MethodtestProduceTransactions
()
streams/src/test/java/bbejeck/chapter_4/TransactionalProducerConsumerTest.java:67
MethodtestProximitySensorFeetToMetersConversion
()
streams/src/test/java/bbejeck/chapter_6/SensorBranchingMergingAppTest.java:69
MethodtestPunctuationFiresOnTimeAdvance
()
streams/src/test/java/bbejeck/chapter_10/StockPerformanceDslAndProcessorApplicationTest.java:56
MethodtestPunctuationWithManualTimeAdvance
()
streams/src/test/java/bbejeck/chapter_10/StockPerformanceDslAndProcessorApplicationTest.java:106
MethodtestQualifyingPurchaseProducesReward
()
streams/src/test/java/bbejeck/chapter_6/ZMartKafkaStreamsFilteringBranchingAppTest.java:113
MethodtestRecordsBeyondGapStartNewSession
()
streams/src/test/java/bbejeck/chapter_9/session/PageViewSessionWindowsTest.java:78
MethodtestRecordsInDifferentWindowsAreAggregatedSeparately
()
streams/src/test/java/bbejeck/chapter_9/hopping/IotStreamingAggregationHoppingWindowsTest.java:76
MethodtestRecordsInDifferentWindowsProduceSeparateCounts
()
streams/src/test/java/bbejeck/chapter_9/hopping/StreamsCountHoppingWindowTest.java:91
MethodtestRecordsOutsideWindowDoNotJoin
()
streams/src/test/java/bbejeck/chapter_7/KafkaStreamsJoinsAppTest.java:131
MethodtestRecordsWithinGapMergeIntoSingleSession
()
streams/src/test/java/bbejeck/chapter_9/session/PageViewSessionWindowsTest.java:44
MethodtestRunningTotalContinuesGrowing
()
streams/src/test/java/bbejeck/chapter_9/IotStreamingAggregationNoWindowsTest.java:69
MethodtestSensorWithNoLookupProducesNoOutput
()
streams/src/test/java/bbejeck/chapter_8/joins/StreamGlobalKTableJoinExampleTest.java:72
MethodtestSerializeDeserializeHashMap
()
streams/src/test/java/bbejeck/serializers/JsonSerializerDeserializerTest.java:32
MethodtestSerializeThenDeserialize
()
streams/src/test/java/bbejeck/serializers/JsonSerializerDeserializerTest.java:17
MethodtestShouldBeAssignable
()
custom-connector/src/test/java/bbejeck/chapter_5/connector/StockTickerSourceConnectorTest.java:81
MethodtestShouldHaveFiveConfigList
()
custom-connector/src/test/java/bbejeck/chapter_5/connector/StockTickerSourceConnectorTest.java:64
MethodtestShouldHaveOneConfigList
()
custom-connector/src/test/java/bbejeck/chapter_5/connector/StockTickerSourceConnectorTest.java:45
MethodtestSingleFinalResultEmittedOnWindowClose
()
streams/src/test/java/bbejeck/chapter_9/tumbling/StreamsCountTumblingWindowSuppressedStrictTest.java:55
MethodtestSingleResultEmittedOnWindowClose
()
streams/src/test/java/bbejeck/chapter_9/tumbling/IotStreamingAggregationEmitOnCloseTumblingWindowTest.java:66
MethodtestStateAccumulatesAcrossTransactions
()
streams/src/test/java/bbejeck/chapter_10/StockPerformanceDslAndProcessorApplicationTest.java:90
MethodtestTemperatureSensorFromCombinedStream
()
streams/src/test/java/bbejeck/chapter_6/SensorBranchingMergingAppTest.java:50
MethodtestThresholdExceededCount
()
streams/src/test/java/bbejeck/chapter_9/hopping/IotStreamingAggregationHoppingWindowsTest.java:109
MethodtestThresholdExceededCountIsTracked
()
streams/src/test/java/bbejeck/chapter_9/IotStreamingAggregationNoWindowsTest.java:128
MethodtestTopologyContainsNamedProcessors
()
streams/src/test/java/bbejeck/chapter_6/KafkaStreamsYellingNamedProcessorsAppTest.java:77
MethodtestTopologyContainsRepartitionNode
()
streams/src/test/java/bbejeck/chapter_7/RepartitionForThroughputTest.java:77
MethodtestTumblingWindowAggregation
()
streams/src/test/java/bbejeck/chapter_9/tumbling/IotStreamingAggregationTumblingWindowsTest.java:27
← previousnext →701–800 of 814, ranked by callers