Functions — github.com/dataArtisans/yahoo-streaming-benchmark

hub / github.com/dataArtisans/yahoo-streaming-benchmark / functions

Functions268 in github.com/dataArtisans/yahoo-streaming-benchmark

⨍ Functions 268◇ Types & classes 85

↓ 1 callersMethodstreamSource

Choose source - either Kafka or data generator

flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyFlinkWindows.java:98

↓ 1 callersMethodstreamSource

Choose data source, either Kafka or data generator

flink-benchmarks/src/main/java/flink/benchmark/state/AdvertisingTopologyFlinkStateHighKeyCard.java:112

↓ 1 callersMethodsumReduceFunction

Sum - window reduce function

flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyFlinkWindows.java:138

↓ 1 callersMethodsumWindowFunction

Sum - Window function, summing already happened in reduce function

flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyFlinkWindows.java:151

↓ 1 callersMethodwriteWindow

(String campaign, Window win)

streaming-benchmark-common/src/main/java/benchmark/common/advertising/CampaignProcessorCommon.java:71

↓ 1 callersMethodyamlToParameters

(String yamlFile)

flink-benchmarks/src/main/java/flink/benchmark/BenchmarkConfig.java:112

MethodAddressDetectionState

(int timeout)

flink-benchmarks/src/main/java/flink/benchmark/state/ConnectionUtils.java:62

MethodBenchmarkConfig

Create a config starting with an instance of ParameterTool

flink-benchmarks/src/main/java/flink/benchmark/BenchmarkConfig.java:54

MethodCampaignAndWindow

(String campaign, String windowTimestamp)

streaming-benchmark-common/src/main/java/benchmark/common/advertising/PooledRedisConnections.java:59

MethodCampaignProcessor

(BenchmarkConfig config)

flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyNative.java:161

MethodCampaignProcessor

(long windowSize, String redisHost, int numConnections)

flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyRedisDirect.java:133

MethodCampaignProcessor

(String redisServerHost)

storm-benchmarks/src/main/java/storm/benchmark/AdvertisingTopology.java:157

MethodCampaignProcessorCommon

(String redisServerHostname)

streaming-benchmark-common/src/main/java/benchmark/common/advertising/CampaignProcessorCommon.java:30

MethodCampaignProcessorMultiThreaded

(long windowSize, String redisServerHost, int numWorkerTheads)

storm-benchmarks/src/main/java/storm/benchmark/AdvertisingTopologyHighKeyCard.java:123

MethodCampaignWindowPair

(String campaign, Window window)

streaming-benchmark-common/src/main/java/benchmark/common/advertising/CampaignWindowPair.java:11

MethodDataInputViewAsynchronousStateHandle

(long checkpointId, long timestamp, Map<Long, Map<UUID, CountAndAccessTime>> stateSnapshot,

flink-benchmarks/src/main/java/flink/benchmark/state/QueryableWindowOperatorEvicting.java:383

MethodDataInputViewAsynchronousStateHandle

(long checkpointId, long timestamp,

flink-benchmarks/src/main/java/flink/benchmark/state/QueryableWindowOperator.java:340

MethodEventGeneratorSource

(BenchmarkConfig config)

flink-benchmarks/src/main/java/flink/benchmark/generator/EventGeneratorSource.java:22

MethodHighKeyCardinalityGeneratorSource

(BenchmarkConfig config)

flink-benchmarks/src/main/java/flink/benchmark/generator/HighKeyCardinalityGeneratorSource.java:24

MethodLRUHashMap

(int cacheSize)

streaming-benchmark-common/src/main/java/benchmark/common/advertising/LRUHashMap.java:13

MethodLoadGeneratorSource

(int loadTargetHz, int timeSliceLengthMs)

flink-benchmarks/src/main/java/flink/benchmark/generator/LoadGeneratorSource.java:17

MethodPooledRedisConnections

(String redisServerHost, int numConnections)

streaming-benchmark-common/src/main/java/benchmark/common/advertising/PooledRedisConnections.java:18

MethodQueryActor

( RetrievalService<K> retrievalService, FiniteDuration lookupTimeout, FiniteDuration queryTimeout,

flink-benchmarks/src/main/java/flink/benchmark/state/QueryActor.java:63

MethodQueryState

(Long timestamp, K key)

flink-benchmarks/src/main/java/flink/benchmark/state/QueryState.java:27

MethodQueryableWindowOperator

( long windowSize, RegistrationService registrationService)

flink-benchmarks/src/main/java/flink/benchmark/state/QueryableWindowOperator.java:86

MethodQueryableWindowOperatorEvicting

( long windowSize, RegistrationService registrationService, boolean trackAccessTime)

flink-benchmarks/src/main/java/flink/benchmark/state/QueryableWindowOperatorEvicting.java:90

MethodRedisAdCampaignCache

(String redisServerHostname)

streaming-benchmark-common/src/main/java/benchmark/common/advertising/RedisAdCampaignCache.java:15

MethodRedisConnection

(Jedis jedis, BlockingQueue<CampaignAndWindow> queue, PooledRedisConnections errorReporter)

streaming-benchmark-common/src/main/java/benchmark/common/advertising/PooledRedisConnections.java:75

MethodRedisHelper

(BenchmarkConfig config)

flink-benchmarks/src/main/java/flink/benchmark/generator/RedisHelper.java:21

MethodRedisJoinBolt

(BenchmarkConfig config)

flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyFlinkWindows.java:254

MethodRedisJoinBolt

(BenchmarkConfig config)

flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyNative.java:124

MethodRedisJoinBolt

(BenchmarkConfig config)

flink-benchmarks/src/main/java/flink/benchmark/state/AdvertisingTopologyFlinkState.java:141

MethodRedisJoinBolt

(String redisServerHost)

storm-benchmarks/src/main/java/storm/benchmark/AdvertisingTopology.java:119

MethodRedisResultSink

(BenchmarkConfig config)

flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyFlinkWindows.java:325

MethodRedisResultSinkOptimized

(BenchmarkConfig config)

flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyFlinkWindows.java:382

MethodResponseActor

(QueryableKeyValueState<K, V> keyValueState)

flink-benchmarks/src/main/java/flink/benchmark/state/ResponseActor.java:33

MethodResult

(DescriptiveStatistics latencies, SummaryStatistics throughputs, Map<String, DescriptiveStatistics> perHostLat

flink-benchmarks/src/main/java/flink/benchmark/utils/AnalyzeTool.java:27

MethodStandaloneThroughputLogger

(long frequency)

streaming-benchmark-common/src/main/java/benchmark/common/RedisPerformanceTest.java:80

MethodStateFound

(K key, V value)

flink-benchmarks/src/main/java/flink/benchmark/state/StateFound.java:27

MethodStateNotFound

(K key)

flink-benchmarks/src/main/java/flink/benchmark/state/StateNotFound.java:27

MethodStringRepeater

(ParameterTool parameterTool)

flink-benchmarks/src/main/java/flink/benchmark/generator/StaticStringRepeater.java:38

MethodThroughputLogger

(int elementSize, long logfreq)

flink-benchmarks/src/main/java/flink/benchmark/utils/ThroughputLogger.java:18

MethodWrongKeyPartitionException

(String msg)

flink-benchmarks/src/main/java/flink/benchmark/state/WrongKeyPartitionException.java:23

MethodZooKeeperConfiguration

( String rootPath, String zkQuorum, int sessionTimeout, int connectionTimeout, int retryWait, int

flink-benchmarks/src/main/java/flink/benchmark/state/ZooKeeperConfiguration.java:31

MethodZooKeeperRegistrationService

(ZooKeeperConfiguration configuration)

flink-benchmarks/src/main/java/flink/benchmark/state/ZooKeeperRegistrationService.java:39

MethodZooKeeperRetrievalService

(ZooKeeperConfiguration configuration)

flink-benchmarks/src/main/java/flink/benchmark/state/ZooKeeperRetrievalService.java:39

Methodapply

(ActorRef actorRef)

flink-benchmarks/src/main/java/flink/benchmark/state/QueryActor.java:165

Methodcall

()

flink-benchmarks/src/main/java/flink/benchmark/state/QueryActor.java:180

Methodcancel

()

flink-benchmarks/src/main/java/flink/benchmark/generator/LoadGeneratorSource.java:49

Methodcancel

()

flink-benchmarks/src/main/java/flink/benchmark/generator/StaticStringRepeater.java:50

Methodcleanup

()

storm-benchmarks/src/main/java/storm/benchmark/AdvertisingTopologyHighKeyCard.java:151

Methodclose

()

flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyFlinkWindows.java:399

Methodclose

()

flink-benchmarks/src/main/java/flink/benchmark/state/QueryableWindowOperatorEvicting.java:126

Methodcompare

(Map.Entry<String, DescriptiveStatistics> o1, Map.Entry<String, DescriptiveStatistics> o2)

flink-benchmarks/src/main/java/flink/benchmark/utils/AnalyzeTool.java:123

MethoddeclareOutputFields

(OutputFieldsDeclarer declarer)

storm-benchmarks/src/main/java/storm/benchmark/AdvertisingTopologyHighKeyCard.java:62

MethoddeclareOutputFields

(OutputFieldsDeclarer declarer)

storm-benchmarks/src/main/java/storm/benchmark/AdvertisingTopologyHighKeyCard.java:84

MethoddeclareOutputFields

(OutputFieldsDeclarer declarer)

storm-benchmarks/src/main/java/storm/benchmark/AdvertisingTopologyHighKeyCard.java:105

MethoddeclareOutputFields

(OutputFieldsDeclarer declarer)

storm-benchmarks/src/main/java/storm/benchmark/AdvertisingTopologyHighKeyCard.java:158

MethoddeclareOutputFields

(OutputFieldsDeclarer declarer)

storm-benchmarks/src/main/java/storm/benchmark/AdvertisingTopology.java:65

MethoddeclareOutputFields

(OutputFieldsDeclarer declarer)

storm-benchmarks/src/main/java/storm/benchmark/AdvertisingTopology.java:87

MethoddeclareOutputFields

(OutputFieldsDeclarer declarer)

storm-benchmarks/src/main/java/storm/benchmark/AdvertisingTopology.java:108

MethoddeclareOutputFields

(OutputFieldsDeclarer declarer)

storm-benchmarks/src/main/java/storm/benchmark/AdvertisingTopology.java:143

MethoddeclareOutputFields

(OutputFieldsDeclarer declarer)

storm-benchmarks/src/main/java/storm/benchmark/AdvertisingTopology.java:177

Methodequals

(Object other)

streaming-benchmark-common/src/main/java/benchmark/common/advertising/CampaignWindowPair.java:16

Methodexecute

(String ad_id)

streaming-benchmark-common/src/main/java/benchmark/common/advertising/RedisAdCampaignCache.java:23

Methodexecute

(String campaign_id, String event_time)

streaming-benchmark-common/src/main/java/benchmark/common/advertising/CampaignProcessorCommon.java:59

Methodexecute

(Tuple tuple)

storm-benchmarks/src/main/java/storm/benchmark/AdvertisingTopologyHighKeyCard.java:48

Methodexecute

(Tuple tuple)

storm-benchmarks/src/main/java/storm/benchmark/AdvertisingTopologyHighKeyCard.java:76

Methodexecute

(Tuple tuple)

storm-benchmarks/src/main/java/storm/benchmark/AdvertisingTopologyHighKeyCard.java:98

Methodexecute

(Tuple tuple)

storm-benchmarks/src/main/java/storm/benchmark/AdvertisingTopologyHighKeyCard.java:134

Methodexecute

(Tuple tuple)

storm-benchmarks/src/main/java/storm/benchmark/AdvertisingTopology.java:51

Methodexecute

(Tuple tuple)

storm-benchmarks/src/main/java/storm/benchmark/AdvertisingTopology.java:79

Methodexecute

(Tuple tuple)

storm-benchmarks/src/main/java/storm/benchmark/AdvertisingTopology.java:101

Methodexecute

(Tuple tuple)

storm-benchmarks/src/main/java/storm/benchmark/AdvertisingTopology.java:167

MethodextractAscendingTimestamp

(Tuple7<String, String, String, String, String, String, String> element)

flink-benchmarks/src/main/java/flink/benchmark/state/AdvertisingTopologyFlinkStateHighKeyCard.java:198

MethodextractTimestamp

(Tuple2<String, String> element, long currentTimestamp)

flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyFlinkWindows.java:288

MethodextractWatermark

(Tuple2<String, String> element, long currentTimestamp)

flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyFlinkWindows.java:295

MethodflatMap

(String input, Collector<Tuple7<String, String, String, String, String, String, String>> out)

flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyFlinkWindows.java:214

MethodflatMap

(String input, Collector<Tuple7<String, String, String, String, String, String, String>> out)

flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyNative.java:88

MethodflatMap

(Tuple3<String, String, String> tuple, Collector<String> out)

flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyNative.java:173

MethodflatMap

(Tuple2<String, String> tuple, Collector<String> out)

flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyRedisDirect.java:145

MethodflatMap

(String input, Collector<Tuple2<String, String>> out)

flink-benchmarks/src/main/java/flink/benchmark/state/AdvertisingTopologyFlinkState.java:117

MethodgenerateElement

Generate a single element

flink-benchmarks/src/main/java/flink/benchmark/generator/EventGeneratorSource.java:35

MethodgenerateElement

()

flink-benchmarks/src/main/java/flink/benchmark/generator/HighKeyCardinalityGeneratorSource.java:29

MethodgetConnectingHostname

()

flink-benchmarks/src/main/java/flink/benchmark/state/ZooKeeperRegistrationService.java:99

MethodgetCurrentWatermark

()

flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyFlinkWindows.java:300

MethodgetKey

(UUID s)

flink-benchmarks/src/main/java/flink/benchmark/state/AdvertisingTopologyFlinkStateHighKeyCard.java:102

MethodgetStateSize

()

flink-benchmarks/src/main/java/flink/benchmark/state/QueryableWindowOperatorEvicting.java:416

MethodgetStateSize

()

flink-benchmarks/src/main/java/flink/benchmark/state/QueryableWindowOperator.java:377

MethodgetValue

Note: This method has nothing to do with a regular getValue() implementation. Its more designed as a remote debugger @throws WrongKeyPartitionExcepti

flink-benchmarks/src/main/java/flink/benchmark/state/QueryableWindowOperatorEvicting.java:269

MethodgetValue

()

flink-benchmarks/src/main/java/flink/benchmark/state/StateFound.java:32

MethodgetValue

Note: This method has nothing to do with a regular getValue() implementation. Its more designed as a remote debugger @throws WrongKeyPartitionExcepti

flink-benchmarks/src/main/java/flink/benchmark/state/QueryableWindowOperator.java:247

MethodhashCode

()

streaming-benchmark-common/src/main/java/benchmark/common/advertising/CampaignWindowPair.java:25

Methodinvoke

(Tuple3<String, String, Long> result)

flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyFlinkWindows.java:335

Methodinvoke

(Tuple3<String, String, Long> result)

flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyFlinkWindows.java:393

Methodmain

Very simple test to see how fast Redis can go

streaming-benchmark-common/src/main/java/benchmark/common/RedisPerformanceTest.java:16

Methodmain

(final String[] args)

flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyFlinkWindows.java:55

Methodmain

(final String[] args)

flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyNative.java:36

Methodmain

(final String[] args)

flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyRedisDirect.java:33

Methodmain

(String[] args)

flink-benchmarks/src/main/java/flink/benchmark/utils/AnalyzeTool.java:99

← previous next →101–200 of 268, ranked by callers