MCPcopy Create free account

hub / github.com/didi/KnowStreaming / functions

Functions6,956 in github.com/didi/KnowStreaming

⨍ Functions 6,956◇ Types & classes 1,070
↓ 1 callersFunctionuC
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionuG
(t,e,n,i,r,o,a,s)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionuf
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionuh
(C)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionuk
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionul
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersMethodunifyData
(Long sourceKafkaClusterId, String sourceBootstrapServers, Properties sourceKafkaProps,
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/dto/connect/mm2/MirrorMakerCreateDTO.java:33
↓ 1 callersMethodupdateBeatTime
(KmNodePO kmNodePO)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/km/impl/KmNodeServiceImpl.java:103
↓ 1 callersFunctionupdateChartData
(timeRange: [number, number], sliderPos: [number, number])
km-console/packages/layout-clusters-fe/src/components/DraggableCharts/Detail.tsx:294
↓ 1 callersMethodupdateConfigById
(TopicPO topicPO)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/mysql/topic/TopicDAO.java:11
↓ 1 callersMethodupdateDBData
(Long clusterPhyId, List<Broker> zkBrokerList)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/handler/BrokersNodeChangeHandler.java:132
↓ 1 callersMethodupdateDBData
(Long clusterPhyId, long triggerTime)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/handler/ControllerNodeChangeHandler.java:98
↓ 1 callersMethodupdateDBData
(Long clusterPhyId, List<Topic> topicList)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/flusher/zk/handler/TopicsNodeChangeHandler.java:127
↓ 1 callersFunctionupdateGroupInfo
()
km-console/packages/layout-clusters-fe/src/pages/MutliClusterPage/CustomCheckGroup.tsx:27
↓ 1 callersMethodupdateJobTrafficLimit
根据某个 job 的限流值 @param clusterPhyId @param jobId @param limit @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/JobService.java:110
↓ 1 callersMethodupdateLatestMetrics
private method
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/handler/AbstractReassignJobHandler.java:155
↓ 1 callersMethodupdateLimit
修改一个任务的限流值 @param job 任务数据 @param limit 限流值 @return result
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/JobHandler.java:57
↓ 1 callersMethodupdatePartitionNum
(Long clusterPhyId, String topicName, Integer partitionNum)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/TopicService.java:44
↓ 1 callersFunctionupdateRank
(metricList: MetricInfo[])
km-console/packages/layout-clusters-fe/src/components/ChartOperateBar/MetricSelect.tsx:378
↓ 1 callersFunctionupdateRank
(metricList: MetricInfo[])
km-console/packages/layout-clusters-fe/src/pages/ConnectDashboard/MetricsFilter.tsx:93
↓ 1 callersMethodupdateStatusJob
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/impl/JobServiceImpl.java:403
↓ 1 callersMethodupdateTask
通过id更新任务 @param task task @return int
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/JobService.java:43
↓ 1 callersMethodupdateUserMetricItem
更新用户配置的指标项 @param clusterId @param type @param userMetricConfigDTO @param operator @return
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/version/VersionControlManager.java:50
↓ 1 callersMethodupdateZKAcl
(KafkaZkClient kafkaZkClient, ResourcePattern resourcePattern, AclEntry aclEntry, boolean deleteAcl)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/impl/OpKafkaAclServiceImpl.java:317
↓ 1 callersFunctionus
(t,e,n,i,r,o,a,s)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionut
(t,n)
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
↓ 1 callersMethodvalidateConfig
(Long connectClusterId, Properties props)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/plugin/impl/PluginServiceImpl.java:55
↓ 1 callersMethodvalidateConnectors
(MirrorMakerCreateDTO dto)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/MirrorMakerManager.java:42
↓ 1 callersMethodvalueOf
(Integer code)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/operaterecord/OperationEnum.java:56
↓ 1 callersMethodvalueOfStatus
(int status)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/job/JobStatusEnum.java:34
↓ 1 callersMethodvalueOfType
(Integer type)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/job/JobTypeEnum.java:35
↓ 1 callersMethodvalueOfType
(Integer type)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/job/JobHandleEnum.java:33
↓ 1 callersFunctionvb
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionvc
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:94
↓ 1 callersMethodverifyAndUpdateStatue
检查迁移任务
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/ReassignJobService.java:42
↓ 1 callersMethodverifyPartitionReassignments
检查迁移信息 @param executeReassignParam 参数 @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/ReassignService.java:51
↓ 1 callersFunctionvi
(n,t,r,e,u,i)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:64
↓ 1 callersFunctionvx
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionw
()
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
↓ 1 callersFunctionwE
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionwa
(a,b)
km-console/packages/layout-clusters-fe/static/js/react.production.min.js:11
↓ 1 callersMethodwaitResultAndReturnFinished
(int taskNum)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/utils/ApiCallThreadPoolService.java:49
↓ 1 callersFunctionwh
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionwi
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:35
↓ 1 callersMethodwithDatabaseName
(final String databaseName)
km-rest/src/test/java/com/xiaojukeji/know/streaming/test/container/mysql/KSMySQLContainer.java:168
↓ 1 callersMethodwithPassword
(final String password)
km-rest/src/test/java/com/xiaojukeji/know/streaming/test/container/mysql/KSMySQLContainer.java:180
↓ 1 callersMethodwithUsername
(final String username)
km-rest/src/test/java/com/xiaojukeji/know/streaming/test/container/mysql/KSMySQLContainer.java:174
↓ 1 callersFunctionwt
(e,n,r)
km-console/packages/layout-clusters-fe/static/js/react-router-dom.min.js:1
↓ 1 callersFunctionww
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionx
(t)
km-console/packages/layout-clusters-fe/static/js/react-router.min.js:1
↓ 1 callersFunctionxB
(t,e,n,i)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionxG
(t,e,n,i)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionxa
(a)
km-console/packages/layout-clusters-fe/static/js/react.production.min.js:11
↓ 1 callersFunctionxb
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionxc
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:95
↓ 1 callersFunctionxd
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionxf
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionxh
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionxk
(e,r,o)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionxm
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionxy
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionyC
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionyG
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionyO
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionyT
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionyd
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionyj
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:111
↓ 1 callersFunctionyp
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionyr
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionyt
()
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
↓ 1 callersFunctionyv
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionz
(p)
km-console/packages/layout-clusters-fe/static/js/react-router.min.js:1
↓ 1 callersFunctionzb
(t,e,n,i)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionzf
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:86
↓ 1 callersFunctionzi
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:68
↓ 1 callersFunctionzj
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:112
↓ 1 callersFunctionzl
(e,t,n,r)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersMethodzookeeperMetric2SinkPoint
(List<ZookeeperMetrics> zookeeperMetricsList)
km-extends/km-monitor/src/main/java/com/xiaojukeji/know/streaming/km/monitor/component/AbstractMonitorSinkService.java:166
↓ 1 callersMethodzookeeperUrl
()
km-rest/src/test/java/com/xiaojukeji/know/streaming/test/KMTestEnvService.java:79
↓ 1 callersFunctionzp
(e,a,t,i,n,c)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionzu
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:50
↓ 1 callersFunctionzz
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Function$
(t,n)
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
Function$R
(t,e,n,i)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Function$S
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Function$T
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Function$a
()
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:109
Function$c
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:97
Function$d
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Function$e
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:40
Function$e
(t,e,n,i)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:35
Function$f
(t,r)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:90
Function$f
(a,b,c)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:35
Function$k
(t,e,n,i,r,o)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Function$l
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Function$o
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:80
Function$s
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
Function$t
()
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:24
Function$t
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
FunctionAB
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
← previousnext →4,201–4,300 of 6,956, ranked by callers