该项目是一款基于Java和TypeScript构建的xl-lighthouse通用型流式大数据统计系统源码，包含1355个文件，其中Java源文件710个，TypeScript文件共计374个（包括tsx和ts两种格式）。系统支持包括Shell、Scala、JavaScript、HTML等多种语言，旨在处理海量数据和高并发场景。xl-lighthouse适用于多种统计需求，如PV、UV统计、电商交易额和下单用户数统计、日志量统计、接口调用量和异常量统计，以及服务器运维指标监控等。系统提供多维度统计、复杂条件筛选和逻辑判断功能，支持一键部署和简易接入，助力企业低成本、快速搭建数据指标体系，实现降本增效。
关键词
Java 流式数据处理 TypeScript 大数据统计 系统开发
目录结构
├── .gitattributes
├── .gitignore
├── LICENSE
├── bin
├── check
├── check.sh
├── check_cmd_exist.exp
├── check_command.sh
├── check_env.exp
├── check_file_exist.exp
├── check_process.sh
├── clean
├── clean.sh
├── common
├── common.sh
├── const.sh
├── delete.exp
├── exclude_sync.exp
├── exec.exp
├── exec_sql.exp
├── getback_files.exp
├── kill.exp
├── lib.sh
├── sync.exp
├── sync_files.exp
├── verify.exp
├── compile
├── compile.sh
├── compile_redis.exp
├── compile_roaring.exp
├── config
├── cluster-config.json
├── cluster-deploy.json
├── nodelist
├── sourcelist
├── standalone-config.json
├── standalone-deploy.json
├── deploy
├── create_mysqldb.exp
├── create_topic.exp
├── del_zk_node.exp
├── deploy.sh
├── deploy_hadoop.exp
├── deploy_kafka.exp
├── deploy_mysql.exp
├── deploy_redis.exp
├── redis_cluster.exp
├── easy-deploy.sh
├── install
├── base_install.sh
├── dependency.sh
├── install.sh
├── install_ice.sh
├── prepare
├── basic.sh
├── init_hosts.exp
├── init_path.sh
├── init_pre.exp
├── init_system.sh
├── prepare.sh
├── ssh_keygen.exp
├── stop_firewall.sh
├── restart-all.sh
├── restart.sh
├── run
├── reload.sh
├── start.sh
├── start_hadoop.exp
├── start_hbase.exp
├── start_ice.exp
├── start_kafka.exp
├── start_lighthouse_ice.exp
├── start_mysql.exp
├── start_redis.exp
├── start_spark.exp
├── start_zookeeper.exp
├── stop.sh
├── stop_hadoop.exp
├── stop_hbase.exp
├── stop_kafka.exp
├── stop_mysql.exp
├── stop_redis.exp
├── stop_spark.exp
├── stop_zookeeper.exp
├── start-all.sh
├── start.sh
├── stop-all.sh
├── stop.sh
├── templates
├── hadoop
├── etc
├── hadoop
├── capacity-scheduler.xml
├── configuration.xsl
├── container-executor.cfg
├── core-site.xml
├── hadoop-env.cmd
├── hadoop-env.sh
├── hadoop-metrics2.properties
├── hadoop-policy.xml
├── hadoop-user-functions.sh.example
├── hdfs-rbf-site.xml
├── hdfs-site.xml
├── httpfs-env.sh
├── httpfs-log4j.properties
├── httpfs-site.xml
├── kms-acls.xml
├── kms-env.sh
├── kms-log4j.properties
├── kms-site.xml
├── log4j.properties
├── mapred-env.cmd
├── mapred-env.sh
├── mapred-queues.xml.template
├── mapred-site.xml
├── ssl-client.xml.example
├── ssl-server.xml.example
├── user_ec_policies.xml.template
├── workers
├── yarn-env.cmd
├── yarn-env.sh
├── yarn-site.xml
├── yarnservice-log4j.properties
├── hbase
├── conf
├── hadoop-metrics2-hbase.properties
├── hbase-env.cmd
├── hbase-env.sh
├── hbase-policy.xml
├── hbase-site.xml
├── log4j2-hbtop.properties
├── log4j2.properties
├── regionservers
├── kafka
├── bin
├── kafka-server-start.sh
├── config
├── connect-console-sink.properties
├── connect-console-source.properties
├── connect-distributed.properties
├── connect-file-sink.properties
├── connect-file-source.properties
├── connect-log4j.properties
├── connect-mirror-maker.properties
├── connect-standalone.properties
├── consumer.properties
├── log4j.properties
├── producer.properties
├── server.properties
├── tools-log4j.properties
├── trogdor.conf
├── zookeeper.properties
├── lighthouse
├── conf
├── ice_app.xml
├── ice_node.cfg
├── ice_registry_master.cfg
├── ice_registry_slaver.cfg
├── ldp-site-cluster.xml
├── ldp-site-standalone.xml
├── ldp_db.sql
├── ldp_upgrade.sql
├── lighthouse-insights.yml
├── log4j2-ice.xml
├── log4j2-insights.xml
├── log4j2-standalone.xml
├── log4j2-tasks.xml
├── light-webapps
├── public
├── config.json
├── mysql
├── support-files
├── my.cnf
├── nginx
├── conf
├── nginx.conf
├── redis
├── conf
├── redis.conf
├── spark
├── conf
├── fairscheduler.xml.template
├── log4j2.properties.template
├── metrics.properties.template
├── spark-defaults.conf
├── spark-env.sh
├── workers
├── zookeeper
├── bin
├── zkEnv.sh
├── conf
├── configuration.xsl
├── log4j.properties
├── zoo.cfg
├── data
├── myid
├── tools
├── examples
├── start_example.sh
├── stop_example.sh
├── logpack
├── collect.sh
├── logpack.sh
├── redisfix
├── redis_clear.sh
├── redis_fix.exp
├── redis_fix.sh
├── snapshot
├── restore.sh
├── snapshot.sh
├── track.exp
├── light-webapps
├── index.html
├── package.json
├── public
├── config.json
├── logo.png
├── scripts
├── follow_process.js
├── src
├── api
├── authorize.ts
├── component.ts
├── data.ts
├── department.ts
├── export.ts
├── favorites.ts
├── filter.ts
├── group.ts
├── home.ts
├── metricset.ts
├── order.ts
├── permission.ts
├── project.ts
├── record.ts
├── stat.ts
├── track.ts
├── user.ts
├── assets
├── dark-logo.svg
├── dark.svg
├── light-logo.svg
├── light.svg
├── logo.png
├── logo.svg
├── world.json
├── components
├── Chart
├── customer-tooltip.tsx
├── lib.ts
├── style
├── index.module.less
├── themes
├── dark1-theme.json
├── light1-theme.json
├── Footer
├── index.tsx
├── style
├── index.module.less
├── MessageBox
├── index.tsx
├── list.tsx
├── style
├── index.module.less
├── NavBar
├── IconButton.tsx
├── index.tsx
├── style
├── icon-button.module.less
├── index.module.less
├── Panel
├── index.tsx
├── style
├── index.module.less
├── PermissionWrapper
├── index.tsx
├── Settings
├── block.tsx
├── color.tsx
├── index.tsx
├── style
├── block.module.less
├── color-panel.module.less
├── context.tsx
├── declaration.d.ts
├── layout.tsx
├── locale
├── common.ts
├── index.ts
├── main.tsx
├── mock
├── index.ts
├── message-box.ts
├── pages
├── caller
├── create
├── CreateCallerModal.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── list
├── index.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── common
├── context.tsx
├── desc
├── base.tsx
├── editable_v2
├── EditTableV2.tsx
├── style
├── index.module.less
├── edittable
├── EditTable.tsx
├── style
├── index.module.less
├── error.tsx
├── popmenu
├── PopMenu.tsx
├── style
├── index.module.less
├── prompt.ts
├── component
├── create
├── ComponentCreateModal.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── list
├── constants.tsx
├── form.tsx
├── index.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── mock
├── index.ts
├── update
├── ComponentUpdateModal.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── components
├── common.ts
├── transfer
├── department_transfer
├── index.tsx
├── style
├── index.module.less
├── tree_transfer.tsx
├── user_transfer
├── index.tsx
├── style
├── index.module.less
├── tree_transfer.tsx
├── dashboard
├── monitor
├── chat-panel.tsx
├── data-statistic-list.tsx
├── data-statistic.tsx
├── index.tsx
├── locale
├── index.ts
├── message-list
├── index.tsx
├── item.tsx
├── style
├── index.module.less
├── mock
├── index.ts
├── quick-operation.tsx
├── studio-information.tsx
├── studio-status.tsx
├── studio.tsx
├── style
├── index.module.less
├── workplace
├── StatPieChart.tsx
├── announcement.tsx
├── assets
├── calendar.svg
├── comments.svg
├── content.svg
├── increase.svg
├── carousel.tsx
├── index.tsx
├── locale
├── index.ts
├── mock
├── index.ts
├── overview.tsx
├── popular-contents.tsx
├── shortcuts.tsx
├── style
├── announcement.module.less
├── docs.module.less
├── index.module.less
├── overview.module.less
├── popular-contents.module.less
├── shortcuts.module.less
├── department
├── base.ts
├── common
├── depart.tsx
├── manage
├── index.tsx
├── locale
├── index.ts
├── manage.tsx
├── style
├── index.module.less
├── mock
├── index.ts
├── exception
├── 403
├── index.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── 404
├── index.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── 500
├── index.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── form
├── group
├── index.tsx
├── locale
├── index.ts
├── mock
├── index.ts
├── style
├── index.module.less
├── step
├── index.tsx
├── locale
├── index.ts
├── mock
├── index.ts
├── style
├── index.module.less
├── group
├── basic
├── constants.tsx
├── index.tsx
├── locale
├── index.ts
├── secret_key.tsx
├── style
├── index.module.less
├── create
├── group_create.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── limiting
├── LimitingSettingsModal.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── manage
├── index.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── mock
├── index.ts
├── update
├── index.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── license
├── index.tsx
├── license.md
├── list
├── card
├── card-add.tsx
├── card-block.tsx
├── index.tsx
├── interface.ts
├── locale
├── index.ts
├── mock
├── index.ts
├── style
├── index.module.less
├── useRequest.ts
├── search-table
├── constants.tsx
├── form.tsx
├── icons
├── horizontal.svg
├── text.svg
├── vertical.svg
├── index.tsx
├── locale
├── index.ts
├── mock
├── index.ts
├── style
├── index.module.less
├── login
├── form.tsx
├── index.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── metricset
├── binded
├── binded
├── binded_project.tsx
├── binded_stat.tsx
├── constants.tsx
├── index.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── list
├── constants.tsx
├── index.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── reverse-binded
├── constants.tsx
├── index.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── common
├── MetricNavModal.tsx
├── MetricSetStar.tsx
├── index.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── tree
├── index.tsx
├── create
├── index.tsx
├── locale
├── index.ts
├── list
├── MetricSetCardBox.tsx
├── card-add.tsx
├── card-block.tsx
├── index.tsx
├── interface.ts
├── locale
├── index.ts
├── style
├── index.module.less
├── mock
├── index.ts
├── preview
├── dataview
├── MetricSetDataViewMenu.tsx
├── MetricSetDataViewPanel.tsx
├── detail.tsx
├── header.tsx
├── history.ts
├── index.tsx
├── locale
├── index.ts
├── preview.tsx
├── style
├── index.module.less
├── shortcuts.module.less
├── structure
├── MetricRepositoryModal.tsx
├── constants.tsx
├── index.tsx
├── locale
├── index.ts
├── structure.tsx
├── style
├── index.module.less
├── update
├── index.tsx
├── locale
├── index.ts
├── order
├── apply
├── list
├── constants.tsx
├── form.tsx
├── index.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── mock
├── index.ts
├── modal
├── ApplyModal.tsx
├── approve
├── list
├── constants.tsx
├── form.tsx
├── index.tsx
├── locale
├── index.ts
├── process_modal.tsx
├── style
├── index.module.less
├── common
├── constants.tsx
├── detail.tsx
├── detail_modal.tsx
├── locale
├── index.ts
├── index.tsx
├── permission
├── PermissionManageModal.tsx
├── PermissionPanel.tsx
├── constants.tsx
├── locale
├── index.ts
├── styles
├── index.module.less
├── privilege
├── mock
├── index.ts
├── profile
├── basic
├── index.tsx
├── item.tsx
├── locale
├── index.ts
├── mock
├── index.ts
├── style
├── index.module.less
├── project
├── apply
├── index.tsx
├── locale
├── index.ts
├── card
├── ProjectCardBox.tsx
├── card-block.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── common
├── ProjectLabel.tsx
├── ProjectNavModal.tsx
├── ProjectStar.tsx
├── locale
├── index.ts
├── project-tree.tsx
├── projectTermQuery.tsx
├── styles
├── index.module.less
├── create
├── index.tsx
├── locale
├── index.ts
├── list
├── ProjectListPanel.tsx
├── constants.tsx
├── detail.tsx
├── form.tsx
├── icons
├── horizontal.svg
├── text.svg
├── vertical.svg
├── index.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── manage
├── index.tsx
├── locale
├── index.ts
├── menu.tsx
├── message-list
├── index.tsx
├── item.tsx
├── style
├── index.module.less
├── mock
├── index.ts
├── style
├── index.module.less
├── mock
├── index.ts
├── preview
├── head.tsx
├── index.tsx
├── locale
├── index.ts
├── menu.tsx
├── style
├── index.module.less
├── update
├── index.tsx
├── locale
├── index.ts
├── record
├── common.ts
├── locale
├── index.ts
├── records_panel.tsx
├── register
├── form.tsx
├── index.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── result
├── error
├── index.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── success
├── index.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── stat
├── apply
├── index.tsx
├── locale
├── index.ts
├── common
├── StatLabel.tsx
├── lib.tsx
├── create
├── locale
├── index.ts
├── stat_create.tsx
├── filter
├── custom_component.tsx
├── filter_set.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── system_component.tsx
├── limiting
├── StatLimitingModal.tsx
├── limit_records_panel.tsx
├── locale
├── index.ts
├── list
├── constants.tsx
├── detail.tsx
├── form.tsx
├── index.tsx
├── locale
├── index.ts
├── stat_list.tsx
├── style
├── index.module.less
├── mock
├── index.ts
├── preview
├── basic.tsx
├── chart_panel.tsx
├── common.ts
├── index.tsx
├── line_chart_v1.tsx
├── locale
├── index.ts
├── preview.tsx
├── search_form.tsx
├── settings
├── StatPreviewSettingsModal.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── timeline_bar_chart.tsx
├── update
├── index.tsx
├── locale
├── index.ts
├── track
├── index.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── user
├── common
├── groups.tsx
├── locale
├── index.ts
├── userTermQuery.tsx
├── list
├── constants.tsx
├── form.tsx
├── icons
├── horizontal.svg
├── text.svg
├── vertical.svg
├── index.tsx
├── locale
├── index.ts
├── style
├── index.module.less
├── mock
├── index.ts
├── settings
├── basic.tsx
├── header.tsx
├── index.tsx
├── locale
├── index.ts
├── mock
├── index.ts
├── security.tsx
├── style
├── header.module.less
├── index.module.less
├── view
├── common
├── ViewLabel.tsx
├── routes.ts
├── settings.json
├── store
├── index.ts
├── style
├── global.less
├── layout.module.less
├── types
├── insights-common.ts
├── insights-web.ts
├── rollback.ts
├── utils
├── authentication.ts
├── changeTheme.ts
├── checkLogin.tsx
├── clipboard.ts
├── configLoader.ts
├── constants.ts
├── date.ts
├── getUrlParams.ts
├── is.ts
├── lazyload.tsx
├── localCache.ts
├── request.ts
├── setupMock.ts
├── useLocale.ts
├── useSingleAndDoubleClick.ts
├── useStorage.ts
├── util.ts
├── vite-env.d.ts
├── tsconfig.json
├── vite.config.ts
├── lighthouse-assembly
├── pom.xml
├── src
├── main
├── resources
├── assembly-all.xml
├── assembly.xml
├── lighthouse-build-configuration
├── pom.xml
├── lighthouse-client
├── dependency-reduced-pom.xml
├── pom.xml
├── src
├── main
├── java
├── com
├── dtstep
├── lighthouse
├── client
├── AuxHandler.java
├── Consumer.java
├── DelayRunnable.java
├── LightHouse.java
├── Producer.java
├── rpc
├── RPCClient.java
├── RPCClientProxy.java
├── ice
├── ICEHandler.java
├── ICERPCClientImpl.java
├── standalone
├── StandaloneClientImpl.java
├── StandaloneHandler.java
├── test
├── java
├── com
├── dtstep
├── lighthouse
├── client
├── cluster
├── ClientBaseTest.java
├── TestClient.java
├── TestDataQuery.java
├── TestICE.java
├── TestQueryGroupInfo.java
├── standalone
├── StandaloneBaseTest.java
├── TestQueryGroupInfo.java
├── TestStat.java
├── resources
├── log4j2.xml
├── lighthouse-common
├── pom.xml
├── src
├── main
├── java
├── com
├── dtstep
├── lighthouse
├── common
├── aggregator
├── BlockingEventPool.java
├── EventPool.java
├── SlotsGroup.java
├── annotation
├── BLengthValidation.java
├── BLengthValidator.java
├── constant
├── FormulaConst.java
├── RedisConst.java
├── StatConst.java
├── SysConst.java
├── counter
├── CycleCounterAdvisor.java
├── entity
├── ApiResultCode.java
├── ApiResultData.java
├── FlowNode.java
├── ListData.java
├── ResultCode.java
├── Role.java
├── ServiceResult.java
├── annotation
├── DBColumnAnnotation.java
├── DBNameAnnotation.java
├── TemplateAttrAnnotation.java
├── valid
├── S_Email.java
├── S_Illegal.java
├── S_Integer.java
├── S_Length.java
├── S_NotNull.java
├── S_Numeric.java
├── S_Pattern.java
├── S_Phone.java
├── authorize
├── LicenceEntity.java
├── LicenceViewEntity.java
├── VoucherEntity.java
├── VoucherViewEntity.java
├── calculate
├── MicroBucket.java
├── MicroCalculateEnum.java
├── event
├── DimensBucket.java
├── IceEvent.java
├── LimitBucket.java
├── SimpleSlotEvent.java
├── SlotEvent.java
├── group
├── GroupExtEntity.java
├── GroupVerifyEntity.java
├── list
├── IListEntity.java
├── message
├── LightMessage.java
├── monitor
├── ClusterInfo.java
├── rpc
├── RpcMsgType.java
├── RpcRequest.java
├── RpcResponse.java
├── stat
├── FilterParam.java
├── FilterParamElement.java
├── StatExtEntity.java
├── StatVariableEntity.java
├── StatVerifyEntity.java
├── TemplateEntity.java
├── TimeParam.java
├── state
├── StatState.java
├── StatUnit.java
├── tree
├── EChartTreeNode.java
├── ZTreeNode.java
├── ZTreeViewNode.java
├── view
├── LimitValue.java
├── OperatorValue.java
├── StatDataSeries.java
├── StatValue.java
├── StateValue.java
├── WidgetDataObject.java
├── enums
├── ApproveStateEnum.java
├── AuthRoleTypeEnum.java
├── ChartTypeEnum.java
├── ColumnTypeEnum.java
├── Component.java
├── ComponentTypeEnum.java
├── GroupStateEnum.java
├── LimitTypeEnum.java
├── LimitingStrategyEnum.java
├── MetaTableStateEnum.java
├── MetaTableTypeEnum.java
├── OrderStateEnum.java
├── OrderTypeEnum.java
├── OwnerTypeEnum.java
├── PrivateTypeEnum.java
├── RecordTypeEnum.java
├── RelationTypeEnum.java
├── ResourceTypeEnum.java
├── RoleTypeEnum.java
├── RollbackStateEnum.java
├── RollbackTypeEnum.java
├── RunningMode.java
├── StatStateEnum.java
├── SwitchStateEnum.java
├── UserStateEnum.java
├── ViewStateEnum.java
├── authorize
├── AuthorizeStateEnum.java
├── formula
├── CharTypeEnum.java
├── function
├── EmbedFunctionEnum.java
├── FunctionEnum.java
├── fusing
├── FusingRules.java
├── limiting
├── LimitingRelationTypeEnum.java
├── relations
├── RelationTypeEnum.java
├── result
├── MessageCaptchaEnum.java
├── RequestCodeEnum.java
├── variable
├── EmbedVariableEnum.java
├── volume
├── DataVolumeEnums.java
├── exception
├── AbnormalStateException.java
├── Attempt.java
├── AuthorizeException.java
├── BlockException.java
├── CheckedFunction.java
├── ComponentsCheckException.java
├── ConfigParseException.java
├── FormulaCalculateException.java
├── FunctionFormatException.java
├── InitializationException.java
├── KeyVerificationFailedException.java
├── LDPUncaughtExceptionHandler.java
├── LightSendException.java
├── LightTimeOutException.java
├── LightViewIllegalException.java
├── LimitingException.java
├── LoginException.java
├── PermissionException.java
├── ProcessException.java
├── RoleDefendException.java
├── StateValidException.java
├── StatisticNotFoundException.java
├── SystemException.java
├── TableNotExistException.java
├── TemplateParseException.java
├── TokenNotExistException.java
├── fusing
├── FusingSwitch.java
├── FusingToken.java
├── hash
├── CityHash.java
├── HashUtil.java
├── MurmurHash.java
├── ice
├── LightRpcException.java
├── LongListHelper.java
├── RemoteLightServer.java
├── RemoteLightServerPrx.java
├── StringListHelper.java
├── _Marker.java
├── _RemoteLightServerPrxI.java
├── lru
├── Cache.java
├── LRU.java
├── impl
├── LDPCache.java
├── modal
├── Column.java
├── CommonTreeNode.java
├── Component.java
├── DBStatistics.java
├── DebugParam.java
├── Department.java
├── Domain.java
├── FlatTreeNode.java
├── Group.java
├── GroupExtendConfig.java
├── IDParam.java
├── IDParams.java
├── Indicator.java
├── KV.java
├── LimitDataObject.java
├── LimitedRecord.java
├── LimitingParam.java
├── ListSearchObject.java
├── MetaTable.java
├── MetricBindElement.java
├── MetricSet.java
├── Order.java
├── OrderDetail.java
├── Pagination.java
├── Permission.java
├── PermissionEnum.java
├── Project.java
├── Record.java
├── Relation.java
├── RenderChartConfig.java
├── RenderConfig.java
├── RenderDateConfig.java
├── RenderFilterConfig.java
├── ResourceDto.java
├── Role.java
├── RolePair.java
├── RollbackModal.java
├── Stat.java
├── StatDataObject.java
├── SystemEnv.java
├── TreeNode.java
├── User.java
├── UserView.java
├── View.java
├── ViewQueryParam.java
├── queue
├── BoundedPriorityBlockingQueue.java
├── random
├── RandomID.java
├── SnowFlake.java
├── rpc
├── BasicRemoteLightServerPrx.java
├── netty
├── CustomIdleServerHandler.java
├── NettyClientAdapter.java
├── NettyClientHandler.java
├── ProcessedFuture.java
├── RemoteProxy.java
├── RpcDecoder.java
├── RpcEncoder.java
├── sbr
├── StringBuilderHolder.java
├── schedule
├── DelaySchedule.java
├── ScheduledThreadPoolBuilder.java
├── serializer
├── JDKSerializer.java
├── KryoSerializer.java
├── Serializer.java
├── SerializerProxy.java
├── util
├── AesUtil.java
├── Base64.java
├── BeanCopyUtil.java
├── BinaryUtil.java
├── BitSetUtil.java
├── CalculateUtil.java
├── CopierUtil.java
├── DateUtil.java
├── Encode64.java
├── EncryptUtil.java
├── FileUtil.java
├── IpUtils.java
├── JsonUtil.java
├── ListUtil.java
├── Md5Util.java
├── MessageHelper.java
├── NumberUtil.java
├── ObjectSize.java
├── OkHttpUtil.java
├── PropertiesUtil.java
├── ReflectUtil.java
├── SnappyUtil.java
├── StopWatch.java
├── StringUtil.java
├── SystemUtil.java
├── TreeViewUtil.java
├── ZipUtil.java
├── resources
├── log4j2.xml
├── test
├── com
├── dtstep
├── lighthouse
├── common
├── base
├── BaseTest.java
├── fusing
├── FusingTest.java
├── key
├── KeyGeneratorTest.java
├── RandomIDTest.java
├── lru
├── LRUCacheTest.java
├── protobuf
├── ProtobufTest.java
├── sbr
├── StringBuilderHolderTest.java
├── schedule
├── ScheduleTest.java
├── util
├── BinaryUtilTest.java
├── CityHashTest.java
├── CopyUtil.java
├── DateUtilTest.java
├── EncryptUtilTest.java
├── JsonUtilTest.java
├── LangUtilTest.java
├── LockTest.java
├── Md5UtilTest.java
├── MessageHelperTest.java
├── NumberUtilTest.java
├── OKhttpTest.java
├── RandomUtilTest.java
├── SnappyUtilTest.java
├── StringUtilTest.java
├── ZipUtilTest.java
├── lighthouse-core
├── pom.xml
├── src
├── main
├── java
├── com
├── dtstep
├── lighthouse
├── core
├── batch
├── BatchAdapter.java
├── BatchInterface.java
├── IntervalBatchHandler.java
├── quartz
├── CronSequenceGenerator.java
├── Nullable.java
├── StringUtils.java
├── builtin
├── BuiltinLoader.java
├── builtin-stats.xml
├── callback
├── CacheValue.java
├── CaffeineExpiry.java
├── CallBack.java
├── CallBackMain.java
├── config
├── LDPConfig.java
├── consumer
├── AggregateEvent.java
├── ExpandedConsumer.java
├── ExpandedEventRunnable.java
├── RealTimeProcessor.java
├── dao
├── DBConnectionSource.java
├── RDBMSConfiguration.java
├── distinct
├── RedisRoaringFilter.java
├── expression
├── embed
├── AviatorHandler.java
├── EmbedFunction.java
├── aviator
├── ContainsFunction.java
├── DateFormatFunction.java
├── DateParseFunction.java
├── DaySubFunction.java
├── EndsWithFunction.java
├── HashCodeFunction.java
├── HourSubFunction.java
├── IsEmptyFunction.java
├── IsInFunction.java
├── IsNullFunction.java
├── IsNumericFunction.java
├── LeftFunction.java
├── LenFunction.java
├── LowerFunction.java
├── MD5Function.java
├── MinuteSubFunction.java
├── ReplaceFunction.java
├── ReverseFunction.java
├── RightFunction.java
├── SectionFunction.java
├── SplitFunction.java
├── StartWithFunction.java
├── SubStrFunction.java
├── TrimFunction.java
├── UpperFunction.java
├── variable
├── EmbedVariable.java
├── formula
├── FormulaCalculate.java
├── FormulaTranslate.java
├── ImitateCompile.java
├── TemplateUtil.java
├── VariableEvaluate.java
├── functions
├── BitCountStatProcess.java
├── CountStatProcess.java
├── DimensStatProcess.java
├── DimensStorageThread.java
├── LimitStatProcess.java
├── LimitStorageThread.java
├── MaxStatProcess.java
├── MinStatProcess.java
├── Process.java
├── ResultStorageThread.java
├── SeqStatProcess.java
├── StatProcess.java
├── SumStatProcess.java
├── http
├── HttpProcessor.java
├── HttpServiceHandler.java
├── LightHouseHttpService.java
├── ipc
├── DisruptorEventHandler.java
├── DisruptorEventProducer.java
├── RPCServer.java
├── impl
├── RPCServerImpl.java
├── kafka
├── KafkaProducerFactory.java
├── KafkaProducerPool.java
├── limiting
├── LimitingContext.java
├── RedisLimitingAspect.java
├── device
├── CountingDevice.java
├── impl
├── DefaultLimitingCountingDevice.java
├── strategy
├── AbstractStrategy.java
├── Strategy.java
├── impl
├── GroupMsgStrategyService.java
├── StatResultStrategyService.java
├── trigger
├── Trigger.java
├── impl
├── GroupLimitingTrigger.java
├── StatLimitingTrigger.java
├── lock
├── RedissonLock.java
├── message
├── RetrenchMessage.java
├── preparing
├── handler
├── expand
├── DefaultExpandHandler.java
├── ExpandEvent.java
├── ExpandHandler.java
├── translate
├── DefaultTranslateHandler.java
├── TranslateHandler.java
├── valid
├── DefaultValidHandler.java
├── MessageValid.java
├── ValidHandler.java
├── pipe
├── Pipeline.java
├── PipelineBuilder.java
├── PreparingCollector.java
├── PreparingInput.java
├── stage
├── ExpandStageImpl.java
├── PreparingStage.java
├── TranslateStageImpl.java
├── ValidStageImpl.java
├── redis
├── RedisClient.java
├── RedisOperator.java
├── cluster
├── RedisClusterOperator.java
├── standalone
├── RedisStandaloneOperator.java
├── roaring
├── BitSetFilterSupplier.java
├── service
├── RoaringBitMapEmbed.java
├── RoaringBitMapExtend.java
├── rowkey
├── KeyGenerator.java
├── impl
├── DefaultKeyGenerator.java
├── sort
├── SortOperator.java
├── sql
├── SqlBinder.java
├── storage
├── cmdb
├── CMDBStorageEngine.java
├── CMDBStorageEngineProxy.java
├── mysql
├── MySQLCMDBStorageEngine.java
├── common
├── CompareOperator.java
├── LdpGet.java
├── LdpIncrement.java
├── LdpPut.java
├── LdpResult.java
├── dimens
├── DimensStorageHandler.java
├── DimensStorageSelector.java
├── impl
├── DefaultDimensStorageHandler.java
├── limit
├── LimitStorageEngine.java
├── LimitStorageSelector.java
├── impl
├── RedisLimitStorageEngine.java
├── result
├── ResultStorageHandler.java
├── ResultStorageSelector.java
├── impl
├── DefaultResultStorageHandler.java
├── warehouse
├── WarehouseStorageEngine.java
├── WarehouseStorageEngineProxy.java
├── hbase
├── HBaseWarehouseStorageEngine.java
├── mysql
├── MySQLWarehouseStorageEngine.java
├── tasks
├── EventSender.java
├── EventSenderFactory.java
├── kafka
├── KafkaEventSender.java
├── standalone
├── StandaloneEventSender.java
├── template
├── ImitateCompile.java
├── IterativeParsePattern.java
├── Parser.java
├── TemplateContext.java
├── TemplateParser.java
├── tools
├── HBaseTableRegionMerge.java
├── wrapper
├── DimensDBWrapper.java
├── GroupDBWrapper.java
├── LimitingWrapper.java
├── MetaTableWrapper.java
├── StatDBWrapper.java
├── google
├── common
├── hash_snp
├── AbstractByteHasher.java
├── AbstractCompositeHashFunction.java
├── AbstractHasher.java
├── AbstractNonStreamingHashFunction.java
├── AbstractStreamingHashFunction.java
├── BloomFilter.java
├── BloomFilterStrategies.java
├── ChecksumHashFunction.java
├── Funnel.java
├── Funnels.java
├── HashCode.java
├── HashFunction.java
├── Hasher.java
├── Hashing.java
├── HashingInputStream.java
├── HashingOutputStream.java
├── MessageDigestHashFunction.java
├── Murmur3_128HashFunction.java
├── Murmur3_32HashFunction.java
├── PrimitiveSink.java
├── SipHashFunction.java
├── package-info.java
├── resources
├── log4j2.xml
├── test
├── java
├── com
├── dtstep
├── lighthouse
├── core
├── test
├── CoreBaseTest.java
├── api
├── DataQueryTest.java
├── HttpApiTest.java
├── RpcAPITest.java
├── builtin
├── BuiltinLoaderTest.java
├── config
├── TestLDPConfig.java
├── dimens
├── ArrangementTest.java
├── engine
├── HBaseStorageEngineTest.java
├── dimens
├── DimensStorageHandlerTest.java
├── warehouse
├── MySQLWarehouseEngineTest.java
├── formula
├── TestFormula.java
├── hbase
├── TestHbaseAdmin.java
├── TestPrePartition.java
├── http
├── HttpProcessorTest.java
├── limit
├── LimitTest.java
├── limiting
├── LimitingTest.java
├── preparing
├── TestPipeline.java
├── redis
├── RedisHandlerTest.java
├── redisson
├── RedissonTest.java
├── result
├── ResultStorageHandler.java
├── rowkey
├── KeyGeneratorTest.java
├── stat
├── HelloWorld.java
├── TestClient.java
├── track
├── TrackTest.java
├── wrapper
├── GroupDBWrapperTest.java
├── StatDBWrapperTest.java
├── resources
├── log4j2.xml
├── lighthouse-ice
├── pom.xml
├── src
├── main
├── java
├── com
├── dtstep
├── lighthouse
├── ice
├── servant
├── rpc
├── ice
├── ICELightHouseService.java
├── ICERemoteLightServerImpl.java
├── resources
├── assembly.xml
├── lighthouse.ice
├── test
├── java
├── com
├── dtstep
├── lighthouse
├── ice
├── test
├── servant
├── rpc
├── http
├── TestHttpService.java
├── lighthouse-insights
├── pom.xml
├── src
├── main
├── java
├── com
├── dtstep
├── lighthouse
├── insights
├── LightHouseInsightsApplication.java
├── aspect
├── RecordAspect.java
├── config
├── AuthenticationTokenFilter.java
├── CaffeineCacheConfig.java
├── CorsConfig.java
├── DefaultAccessDeniedHandler.java
├── DefaultAuthenticationProvider.java
├── DefaultUnauthorizedHandler.java
├── LocalDateTimeSerdeConfig.java
├── MyBatisConfig.java
├── PermissionInterceptor.java
├── RepeatableRequestWrapper.java
├── SecurityConfig.java
├── SeedAuthenticationToken.java
├── WebConfig.java
├── controller
├── ApplyController.java
├── ApproveController.java
├── ComponentController.java
├── DataController.java
├── DefaultExceptionHandler.java
├── DepartmentController.java
├── GroupController.java
├── HomePageController.java
├── LoginController.java
├── MetricSetController.java
├── OrderController.java
├── PermissionController.java
├── ProjectController.java
├── RecordsController.java
├── StatController.java
├── TrackController.java
├── UserController.java
├── annotation
├── AuthPermission.java
├── AuthPermissions.java
├── AuthResourcePermission.java
├── RecordAnnotation.java
├── dao
├── ComponentDao.java
├── DepartmentDao.java
├── DomainDao.java
├── GroupDao.java
├── MetaTableDao.java
├── MetricSetDao.java
├── OrderDao.java
├── OrderDetailDao.java
├── PermissionDao.java
├── ProjectDao.java
├── RecordDao.java
├── RelationDao.java
├── RoleDao.java
├── RollbackDao.java
├── StatDao.java
├── SystemEnvDao.java
├── UserDao.java
├── ViewDao.java
├── dto
├── ActivationParam.java
├── ApplyOrderQueryParam.java
├── ApproveOrderQueryParam.java
├── ChangePasswordParam.java
├── ChangeStatStateParam.java
├── ChangeUserStateParam.java
├── ComponentCreateParam.java
├── ComponentQueryParam.java
├── ComponentUpdateParam.java
├── ComponentVerifyParam.java
├── DataStatQueryParam.java
├── DeleteParam.java
├── FilterQueryParam.java
├── GroupCreateParam.java
├── GroupQueryParam.java
├── GroupUpdateLimitingParam.java
├── GroupUpdateParam.java
├── LimitStatQueryParam.java
├── LoginParam.java
├── MetaTableQueryParam.java
├── MetricBindParam.java
├── MetricBindQueryParam.java
├── MetricBindRemoveParam.java
├── MetricPendQueryParam.java
├── MetricSetCreateParam.java
├── MetricSetQueryParam.java
├── MetricSetUpdateParam.java
├── MetricUpdateStructureParam.java
├── OrderCreateParam.java
├── OrderProcessParam.java
├── PermissionGrantParam.java
├── PermissionListQueryParam.java
├── PermissionQueryParam.java
├── PermissionReleaseParam.java
├── ProjectCreateParam.java
├── ProjectQueryParam.java
├── QueryParam.java
├── RecordQueryParam.java
├── RelationDeleteParam.java
├── RelationQueryParam.java
├── RollbackCreateParam.java
├── RollbackQueryParam.java
├── StatFilterConfigParam.java
├── StatQueryParam.java
├── StatRenderConfigParam.java
├── TextParam.java
├── TrackParam.java
├── UserCreateParam.java
├── UserQueryParam.java
├── UserUpdateParam.java
├── ViewCreateParam.java
├── ViewInfoQueryParam.java
├── ViewPublishParam.java
├── exception
├── UserNotExistException.java
├── init
├── InitialListener.java
├── service
├── BaseService.java
├── ComponentService.java
├── DataService.java
├── DepartmentService.java
├── DomainService.java
├── FilterService.java
├── GroupService.java
├── HomePageService.java
├── InitService.java
├── MetaTableService.java
├── MetricSetService.java
├── OrderDetailService.java
├── OrderService.java
├── PermissionService.java
├── ProjectService.java
├── RecordService.java
├── RelationService.java
├── ResourceService.java
├── RoleService.java
├── RollbackService.java
├── StatService.java
├── SystemEnvService.java
├── UserService.java
├── ViewService.java
├── impl
├── AuthUserDetails.java
├── BaseServiceImpl.java
├── ComponentServiceImpl.java
├── DataServiceImpl.java
├── DepartmentServiceImpl.java
├── DomainServiceImpl.java
├── FilterServiceImpl.java
├── GroupServiceImpl.java
├── HomePageServiceImpl.java
├── InitServiceImpl.java
├── MetaTableServiceImpl.java
├── MetricSetServiceImpl.java
├── OrderDetailServiceImpl.java
├── OrderServiceImpl.java
├── PermissionServiceImpl.java
├── ProjectServiceImpl.java
├── RecordServiceImpl.java
├── RelationServiceImpl.java
├── ResourceServiceImpl.java
├── RoleServiceImpl.java
├── RollbackServiceImpl.java
├── StatServiceImpl.java
├── SystemEnvServiceImpl.java
├── UserDetailsServiceImpl.java
├── UserServiceImpl.java
├── ViewServiceImpl.java
├── types
├── ApproveStateEnumTypeHandler.java
├── BaseObjectTypeHandler.java
├── ComponentTypeEnumTypeHandler.java
├── DebugParamTypeHandler.java
├── GroupColumnArrayTypeHandler.java
├── GroupExtendConfigTypeHandler.java
├── GroupStateEnumTypeHandler.java
├── LimitingParamTypeHandler.java
├── ListConfigTypeHandler.java
├── ListTreeNodeTypeHandler.java
├── MapConfigTypeHandler.java
├── MetaTableStateEnumTypeHandler.java
├── MetaTableTypeEnumTypeHandler.java
├── OrderStateEnumTypeHandler.java
├── OrderTypeEnumTypeHandler.java
├── OwnerTypeEnumTypeHandler.java
├── PrivateTypeEnumTypeHandler.java
├── RecordTypeEnumTypeHandler.java
├── RelationTypeEnumTypeHandler.java
├── RenderConfigTypeHandler.java
├── ResourceTypeEnumTypeHandler.java
├── RoleTypeEnumTypeHandler.java
├── RollbackStateEnumTypeHandler.java
├── RollbackTypeEnumTypeHandler.java
├── StatStateEnumTypeHandler.java
├── SwitchStateEnumTypeHandler.java
├── TreeNodeTypeHandler.java
├── UserStateEnumTypeHandler.java
├── ViewStateEnumTypeHandler.java
├── util
├── SpringUtil.java
├── TreeUtil.java
├── vo
├── AuthorizeVO.java
├── ComponentVO.java
├── DebugModeSwitchVO.java
├── ExportVO.java
├── GroupVO.java
├── HomeVO.java
├── MetricSetVO.java
├── OrderDetailVO.java
├── OrderVO.java
├── PermissionVO.java
├── ProjectVO.java
├── RelationVO.java
├── ResourceVO.java
├── ResultData.java
├── StatExtendVO.java
├── StatVO.java
├── TrackMessageVO.java
├── UserVO.java
├── VersionVO.java
├── ViewVO.java
├── resources
├── Dump20231220.sql
├── i18n
├── messages.properties
├── messages_en_US.properties
├── messages_zh_CN.properties
├── light-insights
├── .husky
├── pre-commit
├── lighthouse-insights.yml
├── log4j2.xml
├── mybatis-config.xml
├── mybatis
├── mapper
├── ComponentMapper.xml
├── DepartmentMapper.xml
├── DomainMapper.xml
├── GroupMapper.xml
├── MetaTableMapper.xml
├── MetricSetMapper.xml
├── OrderDetailMapper.xml
├── OrderMapper.xml
├── PermissionMapper.xml
├── ProjectMapper.xml
├── RecordMapper.xml
├── RelationMapper.xml
├── RoleMapper.xml
├── RollbackMapper.xml
├── StatMapper.xml
├── SystemEnvMapper.xml
├── UserMapper.xml
├── ViewMapper.xml
├── test
├── java
├── com
├── dtstep
├── lighthouse
├── insights
├── test
├── components
├── ComponentUtil.java
├── dao
├── TestDepartmentDao.java
├── TestGroupDao.java
├── TestOrderDao.java
├── TestOrderDetail.java
├── TestOrderDetailDao.java
├── TestPermissionInfoDao.java
├── TestProjectDao.java
├── TestRecordDao.java
├── TestRelationDao.java
├── TestRoleDao.java
├── TestStatDao.java
├── TestUserDao.java
├── TestViewDao.java
├── listener
├── SpringTestExecutionListener.java
├── service
├── TestComponentService.java
├── TestDataService.java
├── TestDepartmentService.java
├── TestDomainService.java
├── TestGroupService.java
├── TestLoginService.java
├── TestMetricSetService.java
├── TestOrderDetailService.java
├── TestPermissionService.java
├── TestProjectService.java
├── TestRelationService.java
├── TestResultData.java
├── TestStatService.java
├── TestSystemEnvService.java
├── utils
├── TestAviator.java
├── TestCopyUtil.java
├── TestDateUtil.java
├── TestJson.java
├── TestJwt.java
├── TestMd5Util.java
├── TestPattern.java
├── TestPbkdfUtil.java
├── TestTreeUtil.java
├── TestUtil.java
├── lighthouse-shaded-client
├── pom.xml
├── src
├── main
├── java
├── com
├── dtstep
├── lighthouse
├── client
├── shade
├── Shade.java
├── lighthouse-standalone
├── pom.xml
├── src
├── main
├── java
├── com
├── dtstep
├── lighthouse
├── standalone
├── executive
├── LightStandaloneEntrance.java
├── LightStandaloneService.java
├── rpc
├── NettyServerHandler.java
├── ServerInitializer.java
├── provider
├── StandaloneRemoteServiceImpl.java
├── resources
├── log4j2.xml
├── lighthouse-tasks
├── pom.xml
├── src
├── main
├── java
├── com
├── dtstep
├── lighthouse
├── tasks
├── executive
├── LightHouseEntrance.scala
├── extract
├── DefaultMessageExtract.scala
├── MessageExtract.scala
├── init
├── InitialServant.scala
├── listener
├── ListenerTrigger.scala
├── part
├── ItemStatPartition.scala
├── Partition.scala
├── stream
├── NormalStream.scala
├── Stream.scala
├── transform
├── PreTransform.scala
├── Transform.scala
├── valid
├── DefaultValidHandler.scala
├── ValidHandler.scala
├── resources
├── assembly.xml
├── test
├── com
├── dtstep
├── lighthouse
├── tasks
├── test
├── HBaseStorageEngineTest.java
├── lighthouse-test
├── pom.xml
├── src
├── main
├── java
├── com
├── dtstep
├── lighthouse
├── test
├── LDPFlowTestInstance.java
├── LDPOnceTestInstance.java
├── LDPSimulationInstance.java
├── config
├── TestConfigContext.java
├── dao
├── DaoBase.java
├── DaoHandler.java
├── DaoHelper.java
├── IDao.java
├── entity
├── BehaviorSampleEntity.java
├── SampleEntity.java
├── example
├── StartExample.java
├── StopExample.java
├── impl
├── FlowModeTestImpl.java
├── OnceModeTestImpl.java
├── TestModel.java
├── local
├── LocalUtil.java
├── mode
├── AiShortVideoTrainMonitorSample.java
├── BehaviorModalSample.java
├── BizHousePriceChangeDTSample.java
├── BizOrderConversionRateSample.java
├── BizOrderStatSample.java
├── FeAppStartAdvStatSample.java
├── ITKVDBRequestMonitorSample.java
├── ModalSample.java
├── OmAppStartDauStatSample.java
├── OmDauPromoteMonitor.java
├── OpsNodesLoadStateMonitorSample.java
├── OpsNodesLoginStateDTSample.java
├── OpsNodesRunStatusMonitorSample.java
├── PMFeedNewsBehaviorStatSample.java
├── PMSocialPrichatEnvelopeSample.java
├── PMSocialPrivateChatMsgStat.java
├── RDShortRecallCostSample.java
├── RDShortVideoRecallSizeSample.java
├── RDShortVideoRequestStatSample.java
├── SimulationModalSample.java
├── relation
├── ExampleContext.java
├── GroupHandler.java
├── MetaHandler.java
├── PermissionHandler.java
├── ProjectHandler.java
├── RoleHandler.java
├── StatHandler.java
├── UserHandler.java
├── util
├── BeanUtil.java
├── resources
├── ldp-db.sql
├── log4j2.xml
├── lighthouse-upgrade
├── fix_upgrade.sh
├── pom.xml
├── src
├── main
├── resources
├── assembly.xml
├── upgrade.sh
├── plugins
├── hadoop-auth
├── hadoop-auth-ldp-3.3.5.jar
├── redis-roaring-2.0.tar.gz
├── pom.xml
├── readme.txt