MCPcopy Create free account

hub / github.com/didi/KnowStreaming / functions

Functions6,956 in github.com/didi/KnowStreaming

↓ 1 callersMethodrecordErrorResponseItem
(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 callersMethodrecoveryRetentionTime
还原保存时间
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignJobServiceImpl.java:799
↓ 1 callersFunctionreduceClick
(key: number)
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/BalanceFilter.tsx:57
↓ 1 callersFunctionregisterApps
(systemsConfig, props = {}, mountCbk)
km-console/packages/layout-clusters-fe/config/registerApps.js:101
↓ 1 callersFunctionreloadRangeTime
()
km-console/packages/layout-clusters-fe/src/components/ChartOperateBar/index.tsx:85
↓ 1 callersMethodremove
(ClusterPhy clusterPhy)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/AbstractClusterLoadedChangedHandler.java:25
↓ 1 callersMethodremove
(Long clusterPhyId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/cache/LoadedClusterPhyCache.java:29
↓ 1 callersMethodremove
(ClusterPhy clusterPhy)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaConsumerClient.java:82
↓ 1 callersMethodremove
(ConnectCluster connectCluster)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/connect/ConnectJMXClient.java:139
↓ 1 callersMethodremove
(ConnectCluster connectCluster)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/connect/AbstractConnectClusterChangeHandler.java:25
↓ 1 callersMethodremove
(Long connectClusterId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/connect/cache/LoadedConnectClusterCache.java:24
↓ 1 callersMethodremoveClusterPhyById
移除集群 @param clusterPhyId 集群ID @param operator 操作人 @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/cluster/ClusterPhyService.java:54
↓ 1 callersMethodremoveIndexNameDateIfHas
如果有日期信息,则移除日期 @param lastIndexNamePart @return
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/IndexNameUtils.java:328
↓ 1 callersFunctionremoveStylesheetLink
(ident)
km-console/packages/layout-clusters-fe/config/registerApps.js:51
↓ 1 callersFunctionremoveTask
(targetKey: string)
km-console/packages/layout-clusters-fe/src/pages/TestingConsumer/component/TaskTabs.tsx:180
↓ 1 callersFunctionrenderContent
()
km-console/packages/layout-clusters-fe/src/pages/Login/index.tsx:37
↓ 1 callersFunctionrenderFormContent
({ formMap, formData, layout, formLayout, formItemColSpan = 24 }: any)
km-console/packages/layout-clusters-fe/src/pages/TestingProduce/component/ConfigFrom.tsx:25
↓ 1 callersFunctionrenderInitCheckboxData
( tree: TreeTableData, curCheckboxData: CheckboxStatus, wholeCheckboxData: CheckboxStatus, key
km-console/packages/layout-clusters-fe/src/pages/ConnectDashboard/MetricSelect.tsx:178
↓ 1 callersFunctionrenderTabOpsSlot
()
km-console/packages/layout-clusters-fe/src/pages/TestingConsumer/component/TaskTabs.tsx:212
↓ 1 callersFunctionrenderValue
(v: string | number | ((visibleType?: boolean) => JSX.Element), visibleType?: boolean)
km-console/packages/layout-clusters-fe/src/components/CardBar/TopicDetailHealthCheck.tsx:13
↓ 1 callersMethodreplaceAll
(TopicPO topicPO)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/mysql/topic/TopicDAO.java:9
↓ 1 callersMethodreplaceAndReturnIdInDB
(ConnectClusterMetadata metadata)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/connect/cluster/ConnectClusterService.java:17
↓ 1 callersMethodreplaceBrokerConfigDiff
(BrokerConfigPO po)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/broker/BrokerConfigService.java:28
↓ 1 callersMethodrescheduleFindCoordinatorTask
(ConsumerGroupOperationContext<?, ?> context, Supplier<Call> nextCall, Call failedCall)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:1192
↓ 1 callersFunctionresolveAdditionChartData
(res: OriginMetricData[], timeRange: [number, number])
km-console/packages/layout-clusters-fe/src/components/DraggableCharts/Detail.tsx:392
↓ 1 callersFunctionresolveMetricsRank
(metricList: MetricInfo[])
km-console/packages/layout-clusters-fe/src/pages/ConnectDashboard/MetricsFilter.tsx:18
↓ 1 callersFunctionresolveMetricsRank
(metricList: MetricInfo[])
km-console/packages/layout-clusters-fe/src/constants/chartConfig.ts:115
↓ 1 callersMethodrestartMirrorMaker
(Long connectClusterId, String sourceConnectorName, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/MirrorMakerManager.java:28
↓ 1 callersMethodresumeMirrorMaker
(Long connectClusterId, String sourceConnectorName, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/MirrorMakerManager.java:30
↓ 1 callersMethodretrySleepTime
重试Sleep时间间隔 @param retryTimes 重试次数 @return
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/RetryExecutor.java:55
↓ 1 callersMethodreturnClient
(Long clusterPhyId, KafkaConsumer<String, String> kafkaConsumer)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/kafka/KafkaConsumerClient.java:50
↓ 1 callersFunctionrm
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionro
(n,t)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:74
↓ 1 callersFunctionrt
(t,n,r)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionru
(n,t,r,e)
km-console/packages/layout-clusters-fe/static/js/lodash.min.js:44
↓ 1 callersMethodrunCheck
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/FutureNoWaitUtil.java:63
↓ 1 callersFunctionrunClientConsumer
(values: any, params: any = {}, isFirst = false)
km-console/packages/layout-clusters-fe/src/pages/TestingConsumer/Consume.tsx:215
↓ 1 callersFunctionrunProduceClient
(values: any, isFirst = false)
km-console/packages/layout-clusters-fe/src/pages/TestingProduce/Produce.tsx:52
↓ 1 callersFunctionrv
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionry
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionrz
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctions
(e)
km-console/packages/layout-clusters-fe/static/js/moment.min.js:1
↓ 1 callersFunctionsE
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionsave
(editKey: number)
km-console/packages/layout-clusters-fe/src/pages/TestingProduce/component/EditTable.tsx:94
↓ 1 callersFunctionsc
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersMethodscheduleJobByClusterId
定时检查集群中是否有需要执行和正在执行的任务 @param clusterPhyId @return
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/JobService.java:117
↓ 1 callersFunctionsecondLevelChange
(value: any, rowId: number)
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/BalanceFilter.tsx:96
↓ 1 callersMethodselectAndEmptySuitableThreadPool
(Map<Long, List<Long>> shardIdPhysicalClusterIdListMap, List
km-collector/src/main/java/com/xiaojukeji/know/streaming/km/collector/service/CollectThreadPoolService.java:190
↓ 1 callersMethodselectByHostAndAppName
(String hostName, String appName)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/km/impl/KmNodeServiceImpl.java:95
↓ 1 callersMethodselectTask
挑选当前机器需要执行的任务 @param allTaskList 所有的任务 @return 需要执行的任务
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/AbstractDispatchTask.java:107
↓ 1 callersMethodsend4LetterWord
private method
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/zookeeper/FourLetterWordUtil.java:70
↓ 1 callersMethodsendEligibleCalls
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 callersMethodsetJobCanceled
(ReassignJobPO jobPO)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignJobServiceImpl.java:630
↓ 1 callersMethodsetJobInRunning
(ReassignJobPO jobPO)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignJobServiceImpl.java:605
↓ 1 callersMethodsetJobStartRunning
(Job job)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/impl/JobServiceImpl.java:387
↓ 1 callersFunctionsetPaginationAfterClick
(type: string)
km-console/packages/layout-clusters-fe/src/pages/TestingConsumer/component/TaskTabs.tsx:78
↓ 1 callersMethodsetPresentReplicaIdx
(Integer replicaIdx, Integer replicaNum)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/assign/TopicAssignedCount.java:64
↓ 1 callersFunctionsf
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionsh
(a,b)
km-console/packages/layout-clusters-fe/static/js/react-dom.production.min.js:91
↓ 1 callersFunctionsh
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersMethodshutdownNow
()
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/FutureWaitUtil.java:145
↓ 1 callersMethodsimpleUrl
(HttpRequest request)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/component/RestTemplateConfig.java:197
↓ 1 callersFunctionsizeof
(str: string, charset?: string)
km-console/packages/layout-clusters-fe/src/pages/TopicList/Create.tsx:27
↓ 1 callersMethodsortByReplaceLogSize
(ReassignExecutionStrategy executionStrategy)
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/reassign/impl/ReassignStrategyServiceImpl.java:131
↓ 1 callersMethodsortFuncNotCheckArgsDefaultDesc
(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 callersMethodsplitConnectorNameAndClusterId
(String connectorNameAndClusterId)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/connect/BaseConnectorMetricESDAO.java:308
↓ 1 callersFunctionss
(t,e,n,i,r,o,a,s,l,u)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionst
(e,t,r)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersMethodstartJob
private method
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/job/impl/JobServiceImpl.java:349
↓ 1 callersMethodstepWaitResult
(FutureTaskDelayQueueData<T> queueData, Integer stepWaitTimeUnitMs)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/FutureWaitUtil.java:149
↓ 1 callersFunctionstop
()
km-console/packages/layout-clusters-fe/src/pages/TestingProduce/Produce.tsx:138
↓ 1 callersMethodstopMirrorMaker
(Long connectClusterId, String sourceConnectorName, String operator)
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/MirrorMakerManager.java:29
↓ 1 callersMethodstrList2String
(List<String> strList)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/CommonUtils.java:94
↓ 1 callersFunctionsu
(e)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersFunctionsubmit
()
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/BalanceDrawer.tsx:195
↓ 1 callersMethodsubmitCommonTask
(String taskName, Integer timeoutUnisMs, Runnable runnable)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/service/TaskThreadPoolService.java:84
↓ 1 callersMethodsupplyData2ClusterConnectorOverviewVOList
(List<ClusterConnectorOverviewVO> voList,
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/ConnectConverter.java:125
↓ 1 callersMethodsupplyData2ClusterMirrorMakerOverviewVOList
(List<ClusterMirrorMakerOverviewVO> voList,
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/connect/mm2/impl/MirrorMakerManagerImpl.java:581
↓ 1 callersMethodsupplyLatestMetrics
private method
km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/reassign/impl/ReassignManagerImpl.java:157
↓ 1 callersMethodsupplyMetricLines
(List<ClusterPhyTopicsOverviewVO> voList, List<MetricMultiLinesVO> metricMultiLinesVOList)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/converter/TopicVOConverter.java:102
↓ 1 callersFunctiontP
(t,e)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctionta
(t,e,n,i)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:45
↓ 1 callersFunctiontableDataChange
(data: any[])
km-console/packages/layout-clusters-fe/src/pages/LoadRebalance/BalanceDrawer.tsx:352
↓ 1 callersFunctiontableLineChange
(keys: string[])
km-console/packages/layout-clusters-fe/src/components/DraggableCharts/Detail.tsx:515
↓ 1 callersFunctiontb
(e,t)
km-console/packages/layout-clusters-fe/static/js/antd.min.js:23
↓ 1 callersMethodtemplateExist
(String indexTemplateName)
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/ESOpClient.java:328
↓ 1 callersMethodthreadShouldExit
(long now, long curHardShutdownTimeMs)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/kafka/KSPartialKafkaAdminClient.java:1004
↓ 1 callersFunctiontimeFormater
(mss: number)
km-console/packages/layout-clusters-fe/src/constants/common.ts:245
↓ 1 callersMethodtimeoutCallsInFlight
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 callersMethodtimeoutPendingCalls
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 callersMethodtoHex
(byte[] bytes)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/CommonUtils.java:83
↓ 1 callersFunctiontooltipFormatter
(date: any, arr: any, tooltip: any)
km-console/packages/layout-clusters-fe/src/constants/chartConfig.ts:277
↓ 1 callersMethodtopicMetric2SinkPoint
(List<TopicMetrics> topicMetrics)
km-extends/km-monitor/src/main/java/com/xiaojukeji/know/streaming/km/monitor/component/AbstractMonitorSinkService.java:108
↓ 1 callersMethodtraceRequest
(HttpRequest request, String subFlag, byte[] body)
km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/component/RestTemplateConfig.java:100
↓ 1 callersFunctiontransUnitTimePro
(ms: number, num = 0)
km-console/packages/layout-clusters-fe/src/components/CardBar/LoadRebalanceCardBar.tsx:13
↓ 1 callersFunctiontraverse
(curKey: string, path: any[], data: DataNode[])
km-console/packages/layout-clusters-fe/src/pages/Zookeeper/config.tsx:105
↓ 1 callersMethodtriggerAllTask
(Long clusterPhyId, Long startTimeUnitMs)
km-task/src/main/java/com/xiaojukeji/know/streaming/km/task/service/listener/TaskClusterAddedListener.java:32
↓ 1 callersMethodtrimJsonBank
去除json中的空格 @param sourceDsl @return
km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/ESFileLoader.java:72
↓ 1 callersFunctiontt
(f)
km-console/packages/layout-clusters-fe/static/js/react-router-dom.min.js:1
↓ 1 callersFunctiontt
(t)
km-console/packages/layout-clusters-fe/static/js/echarts.min.js:35
← previousnext →4,101–4,200 of 6,956, ranked by callers