MCPcopy Create free account

hub / github.com/alain898/real_time_stream_computing_book_source_code / functions

Functions743 in github.com/alain898/real_time_stream_computing_book_source_code

⨍ Functions 743◇ Types & classes 210
↓ 128 callersMethodadd
(Bin bin)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/tools/DynamicHistogram.java:37
↓ 59 callersMethodgetOn
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/StreamFQL.java:53
↓ 56 callersMethodgetWindow
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/StreamFQL.java:29
↓ 32 callersMethodgetValue
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/Void.java:15
↓ 30 callersMethodreplace
(List<String> value, Map<String, List<String>> functionTokenMap)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/MacroFunction.java:56
↓ 28 callersMethodgetString
(String path)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/tools/ConfigHolder.java:49
↓ 28 callersMethodopenIgniteCache
(String cacheName, Class<K> kClass,
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/AbstractFunction.java:144
↓ 28 callersMethodttlSeconds
(String window)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/AbstractFunction.java:170
↓ 27 callersMethodgetTarget
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/StreamFQL.java:45
↓ 26 callersMethodgetStringFromEvent
(JSONObject event, Field field)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/AbstractFunction.java:295
↓ 24 callersMethodgetValueByPath
(String jsonString, String jsonPath)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/tools/JsonTool.java:21
↓ 22 callersMethodgenResponseString
(int code, String msg)
chapter2/src/main/java/com/alain898/book/realtimestreaming/common/RestHelper.java:27
↓ 21 callersMethodgetKey
(JSONObject value)
chapter11/flink-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/flinkfeatureextractor/FlinkRiskEngine.java:65
↓ 20 callersMethodmap
(String s)
chapter11/flink-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/flinkfeatureextractor/FlinkRiskEngine.java:55
↓ 19 callersMethodequals
(Object o)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/StreamFQL.java:69
↓ 19 callersMethodgetOp
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/AbstractFunction.java:45
↓ 18 callersMethodcreate
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/Void.java:11
↓ 18 callersMethodgetLong
(String path)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/tools/ConfigHolder.java:45
↓ 18 callersMethodgetStringFromConditionOrEvent
(JSONObject event, Field field)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/AbstractFunction.java:291
↓ 18 callersMethodprint
(String str)
chapter3/src/main/java/com/alain898/book/realtimestreaming/chapter3/featureextractor/tests/Tests.java:38
↓ 17 callersMethodgetField
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/Field.java:20
↓ 16 callersMethodgetPartition
()
chapter3/src/main/java/com/alain898/book/realtimestreaming/common/concurrency/BackPressureExecutor.java:42
↓ 16 callersMethodtoString
()
chapter7/src/main/java/com/alain898/book/realtimestreaming/chapter7/kappa/example/Event.java:34
↓ 15 callersMethodgetDoubleFromConditionOrEvent
(JSONObject event, Field field)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/AbstractFunction.java:311
↓ 15 callersMethodgetInt
(String path)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/tools/ConfigHolder.java:41
↓ 15 callersMethodisUpdateMode
(String mode)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/AbstractFunction.java:129
↓ 15 callersMethodquery
(long timestamp)
chapter7/src/main/java/com/alain898/book/realtimestreaming/chapter7/kappa/example/ServerLayer.java:51
↓ 14 callersMethodgenCacheName
(StreamFQL fql, JSONObject event)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/AbstractFunction.java:123
↓ 14 callersMethodgetValue
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/Equal.java:11
↓ 14 callersMethodisGetMode
(String mode)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/AbstractFunction.java:140
↓ 13 callersMethodfilter
(JSONObject value)
chapter4/src/main/java/com/alain898/book/realtimestreaming/chapter4/cep/TemperatureMonitor.java:41
↓ 13 callersMethodgetValue
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/tools/DynamicHistogram.java:231
↓ 13 callersMethodmd5ID
(String... args)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/tools/MD5Tool.java:6
↓ 13 callersMethodwindowMilliSeconds
(String window)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/AbstractFunction.java:215
↓ 12 callersMethodsleep
(long ms)
chapter7/src/main/java/com/alain898/book/realtimestreaming/chapter7/kappa/example/Tools.java:4
↓ 11 callersMethodgetInstance
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/console/commands/ConsoleStatus.java:24
↓ 11 callersMethodgetName
()
chapter3/src/main/java/com/alain898/book/realtimestreaming/chapter3/featureextractor/common/services/AbstractStreamService.java:169
↓ 11 callersMethodgetValueFromEvent
(JSONObject event, Field field)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/AbstractFunction.java:321
↓ 10 callersMethodgetFql
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/StreamFQLResult.java:17
↓ 10 callersMethodsortedOn
(StreamFQL fql)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/AbstractFunction.java:327
↓ 9 callersMethodnormalizeDSL
(String dsl)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/StreamFQLParser.java:29
↓ 9 callersMethodreduce
(Event a, Event b)
chapter7/src/main/java/com/alain898/book/realtimestreaming/chapter7/kappa/experiment/WordCountExample.java:38
↓ 9 callersMethodsendResponse
(ChannelHandlerContext ctx, HttpResponseStatus status,
chapter2/src/main/java/com/alain898/book/realtimestreaming/chapter2/datacollector/netty/SyncServerHandler.java:128
↓ 9 callersMethodsetFql
(StreamFQL fql)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/StreamFQLResult.java:21
↓ 9 callersMethodsetResult
(Object result)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/StreamFQLResult.java:29
↓ 9 callersMethodsleep
(long seconds)
chapter3/src/main/java/com/alain898/book/realtimestreaming/chapter3/featureextractor/tests/Tests.java:10
↓ 8 callersMethodexecute
(Runnable command)
chapter4/src/main/java/com/alain898/book/realtimestreaming/common/concurrency/MultiQueueExecutorService.java:205
↓ 8 callersMethodisValidNumber
(Object obj)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/AbstractFunction.java:343
↓ 8 callersMethodmap
(String s)
chapter7/src/main/java/com/alain898/book/realtimestreaming/chapter7/kappa/example/FastLayer.java:50
↓ 8 callersMethodmap
(String s)
chapter11/flink-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/flinkfeatureextractor/FlinkFeatureExtractor.java:55
↓ 8 callersMethodstart
()
chapter3/src/main/java/com/alain898/book/realtimestreaming/chapter3/featureextractor/common/services/ServiceInterface.java:5
↓ 7 callersMethodceilTimestamp
(long timestamp, String window)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/AbstractFunction.java:272
↓ 7 callersMethodgetCondition
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/Field.java:28
↓ 7 callersMethodgetWindowSegmentId
(long timestamp, String window)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/AbstractFunction.java:277
↓ 7 callersMethodisNotNull
(Object obj)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/AbstractFunction.java:339
↓ 7 callersMethodsleep
(long ms)
chapter11/flink-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/flinkfeatureextractor/Tools.java:4
↓ 6 callersMethodexecute
(Runnable command)
chapter2/src/main/java/com/alain898/book/realtimestreaming/common/concurrency/BackPressureExecutor.java:205
↓ 6 callersMethodexecuteTreeAsync
(Map<String, Set<StreamFQL>> dslTree, JSONObject eve
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/StreamFQLExecuteEngine.java:92
↓ 6 callersMethodgetAlias
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/StreamFQL.java:92
↓ 6 callersMethodgetApplicationConfigs
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/console/commands/ConsoleStatus.java:36
↓ 6 callersMethodgetCount
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/tools/DynamicHistogram.java:239
↓ 6 callersMethodgetMethod
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/FieldCondition.java:12
↓ 6 callersMethodgetResult
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/StreamFQLResult.java:25
↓ 6 callersMethodshutdown
()
chapter3/src/main/java/com/alain898/book/realtimestreaming/common/concurrency/BackPressureExecutor.java:77
↓ 5 callersMethodequals
(Object o)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/O_Max.java:40
↓ 5 callersMethodgetName
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/StreamFQL.java:21
↓ 5 callersMethodgetName
()
chapter3/src/main/java/com/alain898/book/realtimestreaming/chapter3/featureextractor/common/services/ServiceInterface.java:11
↓ 5 callersMethodpipeline
(boolean checkStop, boolean exitWhenNoInput)
chapter3/src/main/java/com/alain898/book/realtimestreaming/chapter3/featureextractor/common/services/AbstractStreamService.java:47
↓ 5 callersMethodsendResponse
(ChannelHandlerContext ctx, HttpResponseStatus status,
chapter2/src/main/java/com/alain898/book/realtimestreaming/chapter2/datacollector/netty/AsyncServerHandler.java:170
↓ 5 callersMethodsleepSec
(long seconds)
chapter4/src/main/java/com/alain898/book/realtimestreaming/common/TimeTools.java:14
↓ 4 callersMethodcreateMultiQueueThreadPool
(String name, int executorNumber, int coreSize, int maxSize, int capacity, long rejectSleepMills)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/tools/Executors.java:95
↓ 4 callersMethodgetConfig
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/StreamFQLConfig.java:13
↓ 4 callersMethodnewProperties
@param propsArray Properties array, the later properties will cover the older ones. @return
chapter2/src/main/java/com/alain898/book/realtimestreaming/common/kafka/PropertiesUtil.java:14
↓ 4 callersMethodnewProperties
@param propsArray Properties array, the later properties will cover the older ones. @return
chapter3/src/main/java/com/alain898/book/realtimestreaming/common/kafka/PropertiesUtil.java:12
↓ 4 callersMethodparseField
(String field)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/StreamFQLParser.java:273
↓ 4 callersMethodparseFromTokens
( JSONObject applicationSetting, List<String> tokens, Map<String, List<Str
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/StreamFQLParser.java:90
↓ 4 callersMethodshutdownAndWait
(ExecutorService executorService)
chapter3/src/main/java/com/alain898/book/realtimestreaming/chapter3/featureextractor/completablefuturestream/FeatureExtractor.java:89
↓ 4 callersMethodstop
()
chapter3/src/main/java/com/alain898/book/realtimestreaming/chapter3/featureextractor/common/services/ServiceInterface.java:7
↓ 3 callersMethodcancel
()
chapter4/src/main/java/com/alain898/book/realtimestreaming/chapter4/cep/TemperatureMonitor.java:109
↓ 3 callersMethodcreateExecutor
(int nThreads, String threadNamePrefix)
chapter2/src/main/java/com/alain898/book/realtimestreaming/common/ExecutorHelper.java:13
↓ 3 callersMethodexecute
(Runnable command)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/tools/BackPressureExecutor.java:203
↓ 3 callersMethodflatMap
(JSONObject value, Collector<JSONObject> out)
chapter11/flink-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/flinkfeatureextractor/FlinkFeatureExtractor.java:64
↓ 3 callersMethodflatMap
(String value, Collector<WordWithCount> out)
chapter6/flink-example/src/main/java/com/alain898/book/realtimestreaming/chapter6/flink/streamapi/WordCountExample.java:28
↓ 3 callersMethodgetApplication
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/console/commands/ConsoleStatus.java:28
↓ 3 callersMethodgetOp
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/StreamFQL.java:61
↓ 3 callersMethodgetSource
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/console/commands/ConsoleStatus.java:60
↓ 3 callersMethodgetState
(Class<T> tClass)
chapter11/flink-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/flinkfeatureextractor/FlinkRiskEngine.java:148
↓ 3 callersMethodgetState
(Class<T> tClass)
chapter11/flink-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/flinkfeatureextractor/FlinkFeatureExtractor.java:117
↓ 3 callersMethodgetValueFromConditionOrEvent
(JSONObject event, Field field)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/AbstractFunction.java:299
↓ 3 callersMethodhasNext
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/tools/KafkaReader.java:49
↓ 3 callersMethodincrementAndGet
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/tools/BackPressureExecutor.java:67
↓ 3 callersMethodisNull
(Object obj)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/AbstractFunction.java:335
↓ 3 callersMethodisTimeSeg
(String segment)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/functions/AbstractFunction.java:166
↓ 3 callersMethodnext
()
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/tools/KafkaReader.java:62
↓ 3 callersMethodparseDSL
(String dsl)
chapter11/flink-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/flinkfeatureextractor/FlinkRiskEngine.java:38
↓ 3 callersMethodparseExecutionTree
(List<String> dsls)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/StreamFQLParser.java:55
↓ 3 callersMethodparseTokens
(String dsl, boolean dslNormalized)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/StreamFQLParser.java:240
↓ 3 callersMethodsend
(ChannelHandlerContext ctx, HttpRequest req, JSONObject event)
chapter2/src/main/java/com/alain898/book/realtimestreaming/chapter2/datacollector/netty/AsyncServerHandler.java:84
↓ 3 callersMethodsetCondition
(FieldCondition condition)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/Field.java:32
↓ 3 callersMethodsetEvent_type
(String event_type)
chapter11/stream-feature-extractor/src/main/java/com/alain898/book/realtimestreaming/chapter11/streamfeatureextractor/core/StreamFQL.java:41
next →1–100 of 743, ranked by callers