Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/didi/KnowStreaming
/ functions
Functions
6,956 in github.com/didi/KnowStreaming
⨍
Functions
6,956
◇
Types & classes
1,070
Method
expandTopic
(TopicPartitionExpandParam expandParam, String operator)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/OpTopicServiceImpl.java:184
Method
expandTopic
(TopicExpansionDTO dto, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/topic/impl/OpTopicManagerImpl.java:132
Method
expandTopicByKafkaClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/OpTopicServiceImpl.java:378
Method
expandTopicByZKClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/OpTopicServiceImpl.java:407
Method
expandTopics
(@Validated @RequestBody TopicExpansionDTO dto)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/topic/TopicController.java:57
Method
extend
(VersionJmxInfo jmxInfo)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/version/VersionMetricControlItem.java:74
Method
extendMethod
(String methodName)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/version/VersionMetricControlItem.java:86
Function
fI
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Function
fa
()
km-console/packages/layout-clusters-fe/static/js/react.production.min.js:10
Function
ff
()
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:83
Function
filterOption
(inputValue, option)
km-console/packages/config-manager-fe/src/pages/UserManage/RoleTabContent.tsx:295
Method
float2String
(Float f)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/ConvertUtil.java:333
Method
flush
schedule flush method
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/service/CollectThreadPoolService.java:83
Function
fo
(n,t,r)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:76
Function
formatAssignSize
(size: number, convertTarget: string, fix = 2)
km-console/packages/layout-clusters-fe/src/pages/Jobs/config.tsx:667
Method
formatDouble
保留指定的小数位 四舍五入 @param data 需要转换的数据 @param decimal 保留小数的位数 默认是2 @return
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/CommonUtils.java:76
Function
formateTableData
()
km-console/packages/layout-clusters-fe/src/components/ChartOperateBar/MetricSelect.tsx:106
Function
fr
(n)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:27
Function
gO
(t,e,n)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
Function
ga
(n,t,r)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:102
Function
ge
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:35
Method
genCurrentMonthlyIndexNameWithVersion
(String templateName, Integer version)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/IndexNameUtils.java:61
Method
genDailyIndexNameWithVersion
(String templateName, int offsetDay, Integer version)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/IndexNameUtils.java:57
Function
genRandomContent
()
km-console/packages/layout-clusters-fe/src/pages/TestingProduce/component/CustomTextArea.tsx:13
Method
genReplicaMetricCacheKey
(Long clusterPhyId, Integer brokerId, String topicName, Integer partitionId, String metricName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/cache/CollectedMetricsLocalCache.java:103
Method
generateReassignmentJson
(Long clusterPhyId, String topicName,
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignServiceImpl.java:78
Method
generateReassignmentTask
根据均衡策略生成迁移任务详情 @param executionStrategy 均衡策略 @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/ReassignStrategyService.java:16
Method
generateReassignmentTask
(ReassignExecutionStrategy executionStrategy)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignStrategyServiceImpl.java:30
Method
generateReplicaChangeReassignmentJson
(Long clusterPhyId, String topicName,
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignServiceImpl.java:114
Method
generateScramCredential
(Long clusterPhyId, String token)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/KafkaUserService.java:42
Method
generateScramCredential
(Long clusterPhyId, String token)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/kafkauser/impl/KafkaUserServiceImpl.java:255
Method
getAclByKafkaClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/impl/KafkaAclServiceImpl.java:197
Method
getAclByZKClient
private method
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/acl/impl/KafkaAclServiceImpl.java:181
Method
getAclEnable
(VersionItemParam metricParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterMetricServiceImpl.java:561
Method
getAclGroups
(VersionItemParam metricParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterMetricServiceImpl.java:604
Method
getAclTopics
(VersionItemParam metricParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterMetricServiceImpl.java:594
Method
getAclUsers
(VersionItemParam metricParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterMetricServiceImpl.java:584
Method
getAcls
(VersionItemParam metricParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterMetricServiceImpl.java:574
Method
getAggMetricPointFromES
(Long clusterPhyId, List<String> topicNa
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/topic/impl/TopicMetricServiceImpl.java:206
Method
getAllAriusConfigs
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/operaterecord/ModuleEnum.java:95
Method
getAllDimensionHealthResult
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/health/state/impl/HealthStateServiceImpl.java:271
Method
getAllPartitionOffsetFromKafka
(Long clusterPhyId, KSOffsetSpec offsetSpec)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/partition/impl/PartitionServiceImpl.java:186
Method
getAllTopicMetadata
获取Topic元信息 @param clusterPhyId 物理集群ID @return @throws NotExistException 不存在异常 @throws KeeperException ZK异常 @throws AdminOperateException 操作异常
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/zookeeper/service/KafkaZKDAO.java:60
Method
getAllTopicMetadata
(Long clusterPhyId, boolean addWatch)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/zookeeper/service/impl/KafkaZKDAOImpl.java:132
Method
getAndUpdateSubJobExtendData
(Long jobId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignJobServiceImpl.java:406
Function
getAppNames
()
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
Function
getAppStatus
()
km-console/packages/layout-clusters-fe/static/js/single-spa.min.js:2
Method
getBasicCombineExist
connect method
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/cluster/ClusterConnectsController.java:63
Method
getBean
从静态变量applicationContext中去的Bean，自动转型为所复制对象的类型
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/component/SpringTool.java:34
Method
getBeforeDayCount
(Date before)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/DateUtils.java:262
Method
getBeforeMonths
(Date time, int before)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/DateUtils.java:88
Method
getBroker
(Long clusterPhyId, Integer brokerId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerServiceImpl.java:201
Method
getBrokerBasic
(@PathVariable Long clusterPhyId, @PathVariable Integer brokerId)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/broker/BrokerController.java:65
Method
getBrokerBasic
(Long clusterPhyId, Integer brokerId)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/broker/impl/BrokerManagerImpl.java:30
Method
getBrokerConfigByKafkaClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerConfigServiceImpl.java:183
Method
getBrokerConfigByZKClient
(VersionItemParam itemParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerConfigServiceImpl.java:151
Method
getBrokerConfigDetail
(Long clusterPhyId, Integer brokerId)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/broker/impl/BrokerConfigManagerImpl.java:32
Method
getBrokerConfigDetailFromKafka
(Long clusterPhyId, Integer brokerId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerConfigServiceImpl.java:77
Method
getBrokerConfigDiffFromDB
(Long clusterPhyId, Integer brokerId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerConfigServiceImpl.java:121
Method
getBrokerFromCacheFirst
(Long clusterPhyId, Integer brokerId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerServiceImpl.java:210
Method
getBrokerLogDirDescFromKafka
(Long clusterPhyId, Integer brokerId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerServiceImpl.java:226
Method
getBrokerLogDirs
(@PathVariable Long clusterPhyId, @PathVariable Integer
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/broker/BrokerController.java:72
Method
getBrokerLogDirs
(Long clusterPhyId, Integer brokerId, PaginationBaseDTO dto)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/broker/impl/BrokerManagerImpl.java:45
Method
getBrokerMetadata
(String zkAddress)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/zookeeper/service/impl/KafkaZKDAOImpl.java:46
Method
getBrokerMetadata
(@PathVariable Long clusterPhyId, @PathVariable Integer brokerId)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/broker/BrokerController.java:37
Method
getBrokerMetadataCombineExist
(@PathVariable Long clusterPhyId, @PathVariable Integer brokerId)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/broker/BrokerController.java:49
Method
getBrokerMetricsOverview
( @PathVariable Long clusterPhyId, @RequestBody MetricsBrokerDTO param)
km-rest/src/main/java/com/xiaojukeji/know/streaming/km/rest/api/v3/broker/BrokerMetricController.java:32
Method
getBrokerMetricsPointTest
()
km-rest/src/test/java/com/xiaojukeji/know/streaming/km/persistence/es/BrokerMetricESDAOTest.java:54
Method
getBrokerSpecMap
@param clusterPhyId @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/BrokerSpecService.java:14
Method
getBrokerSpecMap
(Long clusterPhyId)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerSpecServiceImpl.java:21
Method
getBrokerVersionFromKafka
获取Broker的版本信息
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/BrokerService.java:57
Method
getBrokerVersionFromKafkaWithCacheFirst
(Long clusterPhyId, Integer brokerId,Long startTime)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/impl/BrokerServiceImpl.java:250
Method
getBrokersAliveCount
(VersionItemParam metricParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterMetricServiceImpl.java:466
Method
getBrokersCount
(VersionItemParam metricParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterMetricServiceImpl.java:454
Method
getBrokersNotAliveCount
(VersionItemParam metricParam)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterMetricServiceImpl.java:478
Method
getByClusterAndGroup
(Long clusterPhyId, String group)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/config/PlatformClusterConfigService.java:16
Method
getByClusterAndGroup
(Long clusterPhyId, String group)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/config/impl/PlatformClusterConfigServiceImpl.java:39
Method
getByClusterAndGroupWithoutDefault
(Long clusterPhyId, String group)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/config/impl/PlatformClusterConfigServiceImpl.java:48
Method
getByClusterIdAndType
通过集群id和type获取任务 @param type 类型 @return clusterPhyId 集群id
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/JobService.java:59
Method
getByClusterIdAndType
(Long clusterPhyId, Integer type)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/impl/JobServiceImpl.java:152
Method
getByName
(Long clusterPhyId, String connectClusterName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/impl/ConnectClusterServiceImpl.java:101
Method
getByStr
(String str)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/MetricsUtils.java:203
Method
getByStr
(String str)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/MetricsUtils.java:228
Method
getByStr
(String str)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/EnvUtil.java:92
Method
getByTypeName
(String typeName)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/enums/SortTypeEnum.java:20
Method
getChangeData
(String entityPath)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/zookeeper/znode/config/ConfigChangeNotificationDataV2.java:23
Function
getChartConfig
(title: string)
km-console/packages/layout-clusters-fe/src/pages/TopicList/config.tsx:3
Method
getCheckService
()
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/ZookeeperHealthCheckTask.java:24
Method
getCheckService
()
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/GroupHealthCheckTask.java:25
Method
getCheckService
()
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/ClusterHealthCheckTask.java:23
Method
getCheckService
()
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/TopicHealthCheckTask.java:24
Method
getCheckService
()
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/kafka/health/BrokerHealthCheckTask.java:23
Method
getCheckService
()
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/connect/mm2/health/MirrorMakerHealthCheckTask.java:29
Method
getCheckService
()
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/connect/health/ConnectorHealthCheckTask.java:28
Method
getCheckService
()
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/connect/health/ConnectClusterHealthCheckTask.java:28
Method
getClient
(Long clusterPhyId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaConsumerClient.java:40
Method
getClient
(Long clusterPhyId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaAdminClient.java:31
Method
getClientWithCheck
(Long connectClusterId, String workerId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/connect/ConnectJMXClient.java:35
Function
getClusterBalanceColumns
(arg?: any)
km-console/packages/layout-clusters-fe/src/pages/Jobs/config.tsx:519
Method
getClusterByClusterName
(String clusterPhyName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/impl/ClusterPhyServiceImpl.java:68
← previous
next →
5,401–5,500 of 6,956, ranked by callers