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
↓ 1 callers
Method
recordErrorResponseItem
(String indexName, List<? extends BaseESPO> pos, int errorItemIndex, IndexResultItemNode item)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/ESOpClient.java:476
↓ 1 callers
Method
recoveryRetentionTime
还原保存时间
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignJobServiceImpl.java:799
↓ 1 callers
Function
reduceClick
(key: number)
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/BalanceFilter.tsx:57
↓ 1 callers
Function
registerApps
(systemsConfig, props = {}, mountCbk)
km-console/packages/layout-clusters-fe/config/registerApps.js:101
↓ 1 callers
Function
reloadRangeTime
()
km-console/packages/layout-clusters-fe/src/components/ChartOperateBar/index.tsx:85
↓ 1 callers
Method
remove
(ClusterPhy clusterPhy)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/AbstractClusterLoadedChangedHandler.java:25
↓ 1 callers
Method
remove
(Long clusterPhyId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/cache/LoadedClusterPhyCache.java:29
↓ 1 callers
Method
remove
(ClusterPhy clusterPhy)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaConsumerClient.java:82
↓ 1 callers
Method
remove
(ConnectCluster connectCluster)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/connect/ConnectJMXClient.java:139
↓ 1 callers
Method
remove
(ConnectCluster connectCluster)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/connect/AbstractConnectClusterChangeHandler.java:25
↓ 1 callers
Method
remove
(Long connectClusterId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/connect/cache/LoadedConnectClusterCache.java:24
↓ 1 callers
Method
removeClusterPhyById
移除集群 @param clusterPhyId 集群ID @param operator 操作人 @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/ClusterPhyService.java:54
↓ 1 callers
Method
removeIndexNameDateIfHas
如果有日期信息,则移除日期 @param lastIndexNamePart @return
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/IndexNameUtils.java:328
↓ 1 callers
Function
removeStylesheetLink
(ident)
km-console/packages/layout-clusters-fe/config/registerApps.js:51
↓ 1 callers
Function
removeTask
(targetKey: string)
km-console/packages/layout-clusters-fe/src/pages/TestingConsumer/component/TaskTabs.tsx:180
↓ 1 callers
Function
renderContent
()
km-console/packages/layout-clusters-fe/src/pages/Login/index.tsx:37
↓ 1 callers
Function
renderFormContent
({ formMap, formData, layout, formLayout, formItemColSpan = 24 }: any)
km-console/packages/layout-clusters-fe/src/pages/TestingProduce/component/ConfigFrom.tsx:25
↓ 1 callers
Function
renderInitCheckboxData
( tree: TreeTableData, curCheckboxData: CheckboxStatus, wholeCheckboxData: CheckboxStatus, key
km-console/packages/layout-clusters-fe/src/pages/ConnectDashboard/MetricSelect.tsx:178
↓ 1 callers
Function
renderTabOpsSlot
()
km-console/packages/layout-clusters-fe/src/pages/TestingConsumer/component/TaskTabs.tsx:212
↓ 1 callers
Function
renderValue
(v: string | number | ((visibleType?: boolean) => JSX.Element), visibleType?: boolean)
km-console/packages/layout-clusters-fe/src/components/CardBar/TopicDetailHealthCheck.tsx:13
↓ 1 callers
Method
replaceAll
(TopicPO topicPO)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/mysql/topic/TopicDAO.java:9
↓ 1 callers
Method
replaceAndReturnIdInDB
(ConnectClusterMetadata metadata)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/ConnectClusterService.java:17
↓ 1 callers
Method
replaceBrokerConfigDiff
(BrokerConfigPO po)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/BrokerConfigService.java:28
↓ 1 callers
Method
rescheduleFindCoordinatorTask
(ConsumerGroupOperationContext<?, ?> context, Supplier<Call> nextCall, Call failedCall)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:1192
↓ 1 callers
Function
resolveAdditionChartData
(res: OriginMetricData[], timeRange: [number, number])
km-console/packages/layout-clusters-fe/src/components/DraggableCharts/Detail.tsx:392
↓ 1 callers
Function
resolveMetricsRank
(metricList: MetricInfo[])
km-console/packages/layout-clusters-fe/src/pages/ConnectDashboard/MetricsFilter.tsx:18
↓ 1 callers
Function
resolveMetricsRank
(metricList: MetricInfo[])
km-console/packages/layout-clusters-fe/src/constants/chartConfig.ts:115
↓ 1 callers
Method
restartMirrorMaker
(Long connectClusterId, String sourceConnectorName, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/MirrorMakerManager.java:28
↓ 1 callers
Method
resumeMirrorMaker
(Long connectClusterId, String sourceConnectorName, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/MirrorMakerManager.java:30
↓ 1 callers
Method
retrySleepTime
重试Sleep时间间隔 @param retryTimes 重试次数 @return
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/RetryExecutor.java:55
↓ 1 callers
Method
returnClient
(Long clusterPhyId, KafkaConsumer<String, String> kafkaConsumer)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaConsumerClient.java:50
↓ 1 callers
Function
rm
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callers
Function
ro
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:74
↓ 1 callers
Function
rt
(t,n,r)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callers
Function
ru
(n,t,r,e)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:44
↓ 1 callers
Method
runCheck
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/FutureNoWaitUtil.java:63
↓ 1 callers
Function
runClientConsumer
(values: any, params: any = {}, isFirst = false)
km-console/packages/layout-clusters-fe/src/pages/TestingConsumer/Consume.tsx:215
↓ 1 callers
Function
runProduceClient
(values: any, isFirst = false)
km-console/packages/layout-clusters-fe/src/pages/TestingProduce/Produce.tsx:52
↓ 1 callers
Function
rv
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callers
Function
ry
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callers
Function
rz
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callers
Function
s
(e)
km-console/packages/layout-clusters-fe/static/js/moment.min.js:1
↓ 1 callers
Function
sE
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callers
Function
save
(editKey: number)
km-console/packages/layout-clusters-fe/src/pages/TestingProduce/component/EditTable.tsx:94
↓ 1 callers
Function
sc
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callers
Method
scheduleJobByClusterId
定时检查集群中是否有需要执行和正在执行的任务 @param clusterPhyId @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/JobService.java:117
↓ 1 callers
Function
secondLevelChange
(value: any, rowId: number)
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/BalanceFilter.tsx:96
↓ 1 callers
Method
selectAndEmptySuitableThreadPool
(Map<Long, List<Long>> shardIdPhysicalClusterIdListMap, List
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/service/CollectThreadPoolService.java:190
↓ 1 callers
Method
selectByHostAndAppName
(String hostName, String appName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/km/impl/KmNodeServiceImpl.java:95
↓ 1 callers
Method
selectTask
挑选当前机器需要执行的任务 @param allTaskList 所有的任务 @return 需要执行的任务
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/AbstractDispatchTask.java:107
↓ 1 callers
Method
send4LetterWord
private method
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/zookeeper/FourLetterWordUtil.java:70
↓ 1 callers
Method
sendEligibleCalls
Send the calls which are ready. @param now The current time in milliseconds. @return The minimum timeout we ne
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:827
↓ 1 callers
Method
setJobCanceled
(ReassignJobPO jobPO)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignJobServiceImpl.java:630
↓ 1 callers
Method
setJobInRunning
(ReassignJobPO jobPO)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignJobServiceImpl.java:605
↓ 1 callers
Method
setJobStartRunning
(Job job)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/impl/JobServiceImpl.java:387
↓ 1 callers
Function
setPaginationAfterClick
(type: string)
km-console/packages/layout-clusters-fe/src/pages/TestingConsumer/component/TaskTabs.tsx:78
↓ 1 callers
Method
setPresentReplicaIdx
(Integer replicaIdx, Integer replicaNum)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/assign/TopicAssignedCount.java:64
↓ 1 callers
Function
sf
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callers
Function
sh
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:91
↓ 1 callers
Function
sh
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callers
Method
shutdownNow
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/FutureWaitUtil.java:145
↓ 1 callers
Method
simpleUrl
(HttpRequest request)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/component/RestTemplateConfig.java:197
↓ 1 callers
Function
sizeof
(str: string, charset?: string)
km-console/packages/layout-clusters-fe/src/pages/TopicList/Create.tsx:27
↓ 1 callers
Method
sortByReplaceLogSize
(ReassignExecutionStrategy executionStrategy)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignStrategyServiceImpl.java:131
↓ 1 callers
Method
sortFuncNotCheckArgsDefaultDesc
(Object a1, Object a2, Field firstField, Field secondField, boolean end)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/PaginationUtil.java:270
↓ 1 callers
Method
splitConnectorNameAndClusterId
(String connectorNameAndClusterId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/connect/BaseConnectorMetricESDAO.java:308
↓ 1 callers
Function
ss
(t,e,n,i,r,o,a,s,l,u)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callers
Function
st
(e,t,r)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callers
Method
startJob
private method
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/impl/JobServiceImpl.java:349
↓ 1 callers
Method
stepWaitResult
(FutureTaskDelayQueueData<T> queueData, Integer stepWaitTimeUnitMs)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/FutureWaitUtil.java:149
↓ 1 callers
Function
stop
()
km-console/packages/layout-clusters-fe/src/pages/TestingProduce/Produce.tsx:138
↓ 1 callers
Method
stopMirrorMaker
(Long connectClusterId, String sourceConnectorName, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/MirrorMakerManager.java:29
↓ 1 callers
Method
strList2String
(List<String> strList)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/CommonUtils.java:94
↓ 1 callers
Function
su
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callers
Function
submit
()
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/BalanceDrawer.tsx:195
↓ 1 callers
Method
submitCommonTask
(String taskName, Integer timeoutUnisMs, Runnable runnable)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/service/TaskThreadPoolService.java:84
↓ 1 callers
Method
supplyData2ClusterConnectorOverviewVOList
(List<ClusterConnectorOverviewVO> voList,
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/ConnectConverter.java:125
↓ 1 callers
Method
supplyData2ClusterMirrorMakerOverviewVOList
(List<ClusterMirrorMakerOverviewVO> voList,
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/impl/MirrorMakerManagerImpl.java:581
↓ 1 callers
Method
supplyLatestMetrics
private method
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/reassign/impl/ReassignManagerImpl.java:157
↓ 1 callers
Method
supplyMetricLines
(List<ClusterPhyTopicsOverviewVO> voList, List<MetricMultiLinesVO> metricMultiLinesVOList)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/TopicVOConverter.java:102
↓ 1 callers
Function
tP
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callers
Function
ta
(t,e,n,i)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callers
Function
tableDataChange
(data: any[])
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/BalanceDrawer.tsx:352
↓ 1 callers
Function
tableLineChange
(keys: string[])
km-console/packages/layout-clusters-fe/src/components/DraggableCharts/Detail.tsx:515
↓ 1 callers
Function
tb
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callers
Method
templateExist
(String indexTemplateName)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/ESOpClient.java:328
↓ 1 callers
Method
threadShouldExit
(long now, long curHardShutdownTimeMs)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:1004
↓ 1 callers
Function
timeFormater
(mss: number)
km-console/packages/layout-clusters-fe/src/constants/common.ts:245
↓ 1 callers
Method
timeoutCallsInFlight
Time out expired calls that are in flight. Calls that are in flight may have been partially or completely sent over the wire. They may even be in the
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:873
↓ 1 callers
Method
timeoutPendingCalls
Time out the elements in the pendingCalls list which are expired. @param processor The timeout processor.
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:736
↓ 1 callers
Method
toHex
(byte[] bytes)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/CommonUtils.java:83
↓ 1 callers
Function
tooltipFormatter
(date: any, arr: any, tooltip: any)
km-console/packages/layout-clusters-fe/src/constants/chartConfig.ts:277
↓ 1 callers
Method
topicMetric2SinkPoint
(List<TopicMetrics> topicMetrics)
km-extends/km-monitor/src/main/java/com/xiaojukeji/know/streaming/km/monitor/component/AbstractMonitorSinkService.java:108
↓ 1 callers
Method
traceRequest
(HttpRequest request, String subFlag, byte[] body)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/component/RestTemplateConfig.java:100
↓ 1 callers
Function
transUnitTimePro
(ms: number, num = 0)
km-console/packages/layout-clusters-fe/src/components/CardBar/LoadRebalanceCardBar.tsx:13
↓ 1 callers
Function
traverse
(curKey: string, path: any[], data: DataNode[])
km-console/packages/layout-clusters-fe/src/pages/Zookeeper/config.tsx:105
↓ 1 callers
Method
triggerAllTask
(Long clusterPhyId, Long startTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/service/listener/TaskClusterAddedListener.java:32
↓ 1 callers
Method
trimJsonBank
去除json中的空格 @param sourceDsl @return
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/ESFileLoader.java:72
↓ 1 callers
Function
tt
(f)
km-console/packages/layout-clusters-fe/static/js/react-router-dom.min.js:1
↓ 1 callers
Function
tt
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:35
← previous
next →
4,101–4,200 of 6,956, ranked by callers