This is an automated email from the ASF dual-hosted git repository. duhengforever pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git
commit 9fe46692bfbd67b5742460b77575283b20617d3b Merge: 4d96d8e 238e587 Author: Heng Du <[email protected]> AuthorDate: Thu Aug 5 20:53:53 2021 +0800 Merge pull request #10 from duhenglucky/develop Optimize code imports .gitignore | 1 + .travis.yaml | 20 ++ LICENSE | 201 +++++++++++++++++++++ NOTICE | 5 + QUICKSTART.md | 2 +- README.md | 2 +- pom.xml | 11 +- rocketmq-streams-channel-db/pom.xml | 2 +- .../streams/db/sink/AbstractMultiTableSink.java | 11 +- .../apache/rocketmq/streams/db/sink/DBSink.java | 10 +- .../rocketmq/streams/db/sink/DBSinkBuilder.java | 5 +- .../streams/db/sink/db/DBWriteOnlyChannelTest.java | 1 - rocketmq-streams-channel-http/pom.xml | 2 +- .../rocketmq/streams/http/source/HttpSource.java | 7 +- .../streams/http/source/server/HttpServer.java | 26 ++- .../http/source/server/HttpServerManager.java | 3 +- .../streams/http/source/util/HttpUtil.java | 2 - rocketmq-streams-channel-rocketmq/pom.xml | 2 +- .../rocketmq/streams/RocketMQChannelBuilder.java | 3 +- .../apache/rocketmq/streams/sink/RocketMQSink.java | 11 +- .../rocketmq/streams/source/RocketMQSource.java | 11 +- .../rocketmq/streams/RocketMQChannelTest.java | 9 +- rocketmq-streams-clients/pom.xml | 2 +- .../rocketmq/streams/client/DataStreamAction.java | 7 +- .../streams/client/source/DataStreamSource.java | 3 +- .../client/strategy/CheckpointStrategy.java | 3 +- .../streams/client/transform/DataStream.java | 11 +- .../streams/client/transform/JoinStream.java | 9 +- .../streams/client/transform/SplitStream.java | 3 +- .../streams/client/transform/WindowStream.java | 3 +- .../rocketmq/streams/client/DBDriverTest.java | 1 - .../rocketmq/streams/client/DataStreamTest.java | 9 +- .../rocketmq/streams/client/ORMUtilTest.java | 2 +- .../apache/rocketmq/streams/client/WindowTest.java | 2 - .../client/windows/AbstractWindowFireModeTest.java | 4 +- .../streams/client/windows/WindowFromFileTest.java | 4 +- .../client/windows/WindowHighAvailabilityTest.java | 4 +- rocketmq-streams-commons/pom.xml | 2 +- .../streams/common/cache/CompressTable.java | 10 +- .../cache/compress/impl/FixedLenRowCacheKV.java | 18 +- .../common/cache/compress/impl/IntValueKV.java | 17 +- .../common/cache/compress/impl/ListValueKV.java | 3 +- .../common/cache/compress/impl/MultiValueKV.java | 3 +- .../common/cache/compress/impl/StringValueKV.java | 7 +- .../softreference/impl/SoftReferenceCache.java | 5 +- .../streams/common/calssscaner/AbstractScan.java | 19 +- .../streams/common/channel/AbstractChannel.java | 10 +- .../rocketmq/streams/common/channel/IChannel.java | 3 +- .../AbstractSupportShuffleChannelBuilder.java | 1 - .../common/channel/builder/IChannelBuilder.java | 3 +- .../common/channel/impl/OutputPrintChannel.java | 4 +- .../common/channel/impl/PrintChannelBuilder.java | 3 +- .../channel/impl/file/FileChannelBuilder.java | 7 +- .../streams/common/channel/impl/file/FileSink.java | 14 +- .../common/channel/impl/file/FileSource.java | 3 - .../common/channel/impl/file/FileSplit.java | 4 +- .../common/channel/impl/memory/MemoryCache.java | 6 +- .../common/channel/impl/memory/MemoryChannel.java | 6 +- .../channel/impl/memory/MemoryChannelBuilder.java | 9 +- .../common/channel/impl/memory/MemorySink.java | 2 - .../streams/common/channel/sink/AbstractSink.java | 13 +- .../channel/sink/AbstractSupportShuffleSink.java | 3 - .../streams/common/channel/sink/ISink.java | 7 +- .../channel/sinkcache/DataSourceAutoFlushTask.java | 2 - .../common/channel/sinkcache/IMessageCache.java | 2 - .../channel/sinkcache/IMessageFlushCallBack.java | 2 - .../impl/AbstractMutilSplitMessageCache.java | 7 +- .../channel/sinkcache/impl/MessageCache.java | 7 +- .../common/channel/source/AbstractBatchSource.java | 4 +- .../common/channel/source/AbstractSource.java | 6 +- .../channel/source/AbstractUnreliableSource.java | 9 +- .../streams/common/channel/source/ISource.java | 2 - .../channel/source/ISplitChangedListener.java | 1 - .../source/systemmsg/SplitChangedMessage.java | 1 - .../streams/common/channel/split/ISplit.java | 3 +- .../streams/common/checkpoint/CheckPoint.java | 5 - .../common/checkpoint/CheckPointManager.java | 3 - .../common/checkpoint/CheckPointMessage.java | 5 +- .../streams/common/checkpoint/CheckPointState.java | 3 - .../common/classloader/FileClassLoader.java | 6 +- .../common/compiler/CustomJavaCompiler.java | 14 +- .../common/component/AbstractComponent.java | 9 +- .../streams/common/component/ComponentCreator.java | 14 +- .../PropertyConfigureDescriptorManager.java | 8 +- .../PropertyConfigureDiscriptorManager.java | 8 +- .../common/configurable/AbstractConfigurable.java | 7 +- .../common/configurable/BasedConfigurable.java | 11 +- .../streams/common/configurable/IConfigurable.java | 3 +- .../streams/common/context/AbstractContext.java | 9 +- .../streams/common/context/BatchMessageOffset.java | 5 +- .../rocketmq/streams/common/context/IMessage.java | 2 - .../rocketmq/streams/common/context/Message.java | 5 +- .../streams/common/context/MessageHeader.java | 4 +- .../streams/common/context/MessageOffset.java | 5 +- .../streams/common/context/UserDefinedMessage.java | 18 +- .../streams/common/datatype/ArrayDataType.java | 5 +- .../streams/common/datatype/BaseDataType.java | 7 +- .../streams/common/datatype/BooleanDataType.java | 3 +- .../streams/common/datatype/ByteDataType.java | 1 - .../streams/common/datatype/DateDataType.java | 7 +- .../streams/common/datatype/DoubleDataType.java | 3 +- .../streams/common/datatype/FloatDataType.java | 3 +- .../streams/common/datatype/IntDataType.java | 3 +- .../streams/common/datatype/ListDataType.java | 9 +- .../streams/common/datatype/LongDataType.java | 5 +- .../streams/common/datatype/MapDataType.java | 7 +- .../streams/common/datatype/NumberDataType.java | 1 - .../streams/common/datatype/SetDataType.java | 9 +- .../streams/common/datatype/ShortDataType.java | 3 +- .../streams/common/functions/ForEachFunction.java | 2 - .../common/functions/ForEachMessageFunction.java | 1 - .../common/functions/MultiTableSplitFunction.java | 2 - .../streams/common/interfaces/IFilterService.java | 3 +- .../streams/common/interfaces/IPropertyEnable.java | 3 +- .../streams/common/logger/LoggerOutputChannel.java | 9 +- .../common/logger/MyDailyRollingFileAppender.java | 19 +- .../streams/common/metadata/AbstractMetaData.java | 7 +- .../rocketmq/streams/common/metadata/MetaData.java | 11 +- .../streams/common/metadata/MetaDataAdapter.java | 3 +- .../streams/common/metadata/MetaDataField.java | 8 +- .../rocketmq/streams/common/model/NameCreator.java | 5 +- .../rocketmq/streams/common/model/ServiceName.java | 6 +- .../rocketmq/streams/common/monitor/IMonitor.java | 3 +- .../streams/common/monitor/MonitorFactory.java | 9 +- .../common/monitor/TopologyFilterMonitor.java | 6 +- .../common/monitor/group/MonitorCommander.java | 19 +- .../streams/common/monitor/impl/DipperMonitor.java | 13 +- .../streams/common/monitor/impl/MonitorItem.java | 3 +- .../common/monitor/impl/NothingMontior.java | 3 +- .../optimization/CalculationResultCache.java | 5 +- .../common/optimization/HyperscanRegex.java | 12 +- .../streams/common/optimization/LikeRegex.java | 5 +- .../common/optimization/OptimizationRegex.java | 9 +- .../AbstractMutilPipelineChainPipline.java | 9 +- .../streams/common/topology/ChainPipeline.java | 11 +- .../streams/common/topology/ChainStage.java | 9 +- .../common/topology/builder/PipelineBuilder.java | 9 +- .../common/topology/model/AbstractRule.java | 7 +- .../common/topology/model/AbstractScript.java | 5 +- .../common/topology/model/AbstractStage.java | 6 +- .../streams/common/topology/model/Pipeline.java | 5 +- .../topology/stages/AbstractWindowStage.java | 3 - .../common/topology/stages/FilterChainStage.java | 20 +- .../common/topology/stages/OpenAPIChainStage.java | 1 - .../common/topology/stages/OutputChainStage.java | 1 - .../common/topology/stages/PythonChainStage.java | 1 - .../common/topology/stages/SQLChainStage.java | 1 - .../common/topology/stages/ScriptChainStage.java | 4 +- .../topology/stages/SubPiplineChainStage.java | 11 +- .../common/topology/stages/UnionChainStage.java | 3 +- .../topology/stages/udf/FlatMapOperator.java | 5 +- .../common/topology/stages/udf/IReducer.java | 3 +- .../common/topology/stages/udf/IRedurce.java | 3 +- .../common/topology/stages/udf/StageBuilder.java | 1 - .../common/topology/stages/udf/UDFChainStage.java | 1 - .../topology/stages/udf/UDFUnionChainStage.java | 4 +- .../common/transport/AbstractFileTransport.java | 3 +- .../rocketmq/streams/common/utils/AESUtil.java | 4 +- .../rocketmq/streams/common/utils/Base64Utils.java | 6 +- .../rocketmq/streams/common/utils/ClassUtil.java | 13 +- .../rocketmq/streams/common/utils/CommandUtil.java | 1 - .../streams/common/utils/ConfigurableUtil.java | 9 +- .../streams/common/utils/ContantsUtil.java | 6 +- .../rocketmq/streams/common/utils/DESUtils.java | 9 +- .../streams/common/utils/DataTypeUtil.java | 36 +++- .../rocketmq/streams/common/utils/DateUtil.java | 13 +- .../rocketmq/streams/common/utils/FileUtil.java | 19 +- .../rocketmq/streams/common/utils/IOUtil.java | 9 +- .../rocketmq/streams/common/utils/IPUtil.java | 5 +- .../rocketmq/streams/common/utils/JarUtil.java | 13 +- .../streams/common/utils/JsonableUtil.java | 5 +- .../rocketmq/streams/common/utils/MapKeyUtil.java | 7 +- .../rocketmq/streams/common/utils/MessageUtil.java | 3 +- .../rocketmq/streams/common/utils/PrintUtil.java | 13 +- .../streams/common/utils/PropertiesUtils.java | 12 +- .../rocketmq/streams/common/utils/ReflectUtil.java | 28 ++- .../rocketmq/streams/common/utils/SQLUtil.java | 8 +- .../rocketmq/streams/common/utils/ShellUtil.java | 7 +- .../rocketmq/streams/common/utils/StringUtil.java | 12 +- .../rocketmq/streams/common/utils/TraceUtil.java | 7 +- .../softreference/SoftReferenceCacheTest.java | 2 - .../rocketmq/streams/common/channel/SinkTest.java | 1 - .../streams/common/channel/SourceTest.java | 1 - .../streams/common/datatype/DataTypeTest.java | 1 - rocketmq-streams-configurable/pom.xml | 2 +- .../streams/configuable/ConfigurableComponent.java | 9 +- .../service/AbstractConfigurableService.java | 2 - .../AbstractSupportParentConfigureService.java | 12 +- .../service/ConfigurableServiceFactory.java | 3 +- .../service/impl/FileConfigureService.java | 17 +- .../impl/FileSupportParentConfigureService.java | 9 +- .../service/impl/MemoryConfigureService.java | 3 +- .../impl/MemorySupportParentConfigureService.java | 7 +- .../configurable/ConfigurableComponent.java | 7 +- .../service/AbstractConfigurableService.java | 21 ++- .../AbstractSupportParentConfigureService.java | 11 +- .../service/ConfigurableServiceFactory.java | 7 +- .../service/impl/FileConfigureService.java | 17 +- .../impl/FileSupportParentConfigureService.java | 9 +- .../service/impl/MemoryConfigureService.java | 3 +- .../impl/MemorySupportParentConfigureService.java | 7 +- .../configuable/ConfiguableComponentTest.java | 1 - .../rocketmq/streams/configuable/model/Person.java | 1 - .../configurable/ConfigurableComponentTest.java | 1 - .../streams/configurable/model/Person.java | 1 - rocketmq-streams-db-operator/pom.xml | 2 +- .../streams/db/configuable/DBConfigureService.java | 18 +- .../DBSupportParentConfigureService.java | 7 +- .../rocketmq/streams/db/driver/DriverBuilder.java | 5 +- .../rocketmq/streams/db/driver/JDBCDriver.java | 15 +- .../db/driver/batchloader/BatchRowLoader.java | 10 +- .../rocketmq/streams/db/driver/orm/ORMUtil.java | 9 +- .../rocketmq/streams/db/operator/SQLOperator.java | 11 +- .../org/apache/rocketmq/streams/db/Person.java | 1 - .../streams/db/driver/orm/ORMUtilTest.java | 1 - rocketmq-streams-dbinit/pom.xml | 2 +- .../dbinit/mysql/delegate/MysqlDelegate.java | 5 +- rocketmq-streams-dim/pom.xml | 2 +- .../apache/rocketmq/streams/dim/DimComponent.java | 7 +- .../rocketmq/streams/dim/builder/DimBuilder.java | 2 +- .../function/expression/InExpressionResource.java | 3 +- .../dim/function/script/IntelligenceFunction.java | 12 +- .../dim/function/script/NameListFunction.java | 16 +- .../rocketmq/streams/dim/index/DimIndex.java | 9 +- .../rocketmq/streams/dim/index/IndexExecutor.java | 10 +- .../intelligence/AbstractIntelligenceCache.java | 20 +- .../dim/intelligence/AccountIntelligenceCache.java | 5 +- .../dim/intelligence/DomainIntelligenceCache.java | 5 +- .../dim/intelligence/IPIntelligenceCache.java | 7 +- .../dim/intelligence/URLIntelligenceCache.java | 5 +- .../rocketmq/streams/dim/model/AbstractDim.java | 23 +-- .../streams/dim/model/BooleanFieldDBDim.java | 1 - .../apache/rocketmq/streams/dim/model/DBDim.java | 10 +- .../streams/dim/service/impl/DimServiceImpl.java | 4 +- .../com/aliyun/service/ConfigureLoaderTest.java | 5 +- .../com/aliyun/service/ExpressionExecutorTest.java | 5 +- .../com/aliyun/service/NameListFunctionTest.java | 4 +- rocketmq-streams-filter/pom.xml | 2 +- .../rocketmq/streams/filter/FilterComponent.java | 20 +- .../streams/filter/builder/ExpressionBuilder.java | 26 ++- .../streams/filter/builder/RuleBuilder.java | 29 +-- .../streams/filter/builder/RuleElementBuilder.java | 19 +- .../streams/filter/contants/RuleElementType.java | 5 +- .../streams/filter/context/RuleContext.java | 26 ++- .../streams/filter/context/RuleMessage.java | 2 +- .../streams/filter/engine/IRuleEngine.java | 3 +- .../rocketmq/streams/filter/engine/SplitFlow.java | 3 +- .../filter/engine/impl/DefaultRuleEngine.java | 19 +- .../filter/function/etl/RenameFunction.java | 4 +- .../expression/AbstractExpressionFunction.java | 11 +- .../function/expression/CompareFunction.java | 9 +- .../ContainsCaseInsensitiveFunction.java | 5 +- .../streams/filter/function/expression/Equals.java | 5 +- .../filter/function/expression/GreaterEquals.java | 5 +- .../filter/function/expression/GreaterThan.java | 5 +- .../filter/function/expression/InFunction.java | 11 +- .../function/expression/IpContainsFunction.java | 8 +- .../filter/function/expression/LessEquals.java | 5 +- .../filter/function/expression/LessThan.java | 5 +- .../filter/function/expression/LikeFunction.java | 8 +- .../NotContainsCaseInsensitiveFunction.java | 5 +- .../filter/function/expression/NotEquals.java | 5 +- .../filter/function/expression/RegexFunction.java | 10 +- .../filter/function/expression/ScriptFunction.java | 12 +- .../filter/function/script/CaseFunction.java | 8 +- .../rocketmq/streams/filter/monitor/Monitor.java | 3 +- .../filter/monitor/rule/MessageMonitor.java | 7 +- .../streams/filter/monitor/rule/RuleMonitor.java | 6 +- .../rocketmq/streams/filter/operator/Rule.java | 38 ++-- .../filter/operator/action/impl/ChannelAction.java | 10 +- .../operator/action/impl/MetaDataAction.java | 22 +-- .../filter/operator/expression/Expression.java | 25 ++- .../expression/ExpressionRelationParser.java | 3 +- .../operator/expression/GroupExpression.java | 7 +- .../expression/GroupExpressionManager.java | 6 +- .../operator/expression/OptimizationRule.java | 1 - .../operator/expression/RelationExpression.java | 10 +- .../operator/expression/SimpleExpression.java | 13 +- .../streams/filter/operator/var/ConstantVar.java | 4 +- .../streams/filter/operator/var/ContextVar.java | 4 +- .../rocketmq/streams/filter/operator/var/Var.java | 11 +- .../optimization/EqualsExpressionOptimization.java | 2 +- .../optimization/ExpressionOptimization.java | 7 +- .../optimization/LikeExpressionOptimization.java | 2 +- .../PiplineLogFingerprintAnalysis.java | 7 +- .../optimization/RegexExpressionOptimization.java | 2 +- .../streams/filter/service/IRuleEngineService.java | 6 +- .../filter/service/impl/RuleEngineServiceImpl.java | 21 +-- .../rocketmq/streams/filter/utils/IPUtil.java | 5 +- .../rocketmq/streams/filter/utils/RegexUtil.java | 5 +- .../streams/filter/FilterComponentTest.java | 2 - .../streams/filter/operator/ExpressionTest.java | 1 - .../rocketmq/streams/filter/operator/RuleTest.java | 1 - .../test/resources/credible/ChannelComponent.xml | 7 +- rocketmq-streams-lease/pom.xml | 2 +- .../rocketmq/streams/lease/LeaseComponent.java | 3 +- .../streams/lease/service/ILeaseService.java | 2 - .../streams/lease/service/ILeaseStorage.java | 2 - .../lease/service/impl/BasedLesaseImpl.java | 5 +- .../lease/service/impl/LeaseServiceImpl.java | 17 +- .../streams/lease/service/impl/MockLeaseImpl.java | 5 - .../lease/service/storages/DBLeaseStorage.java | 3 +- .../rocketmq/streams/lease/LeaseComponentTest.java | 1 - rocketmq-streams-schedule/pom.xml | 2 +- .../streams/schedule/ScheduleComponent.java | 7 +- .../schedule/job/ConfigurableExecutorJob.java | 4 +- .../streams/schedule/service/IScheduleService.java | 3 +- .../schedule/service/impl/ScheduleServiceImpl.java | 13 +- rocketmq-streams-script/pom.xml | 2 +- .../rocketmq/streams/script/ScriptComponent.java | 3 +- .../function/aggregation/AverageAccumulator.java | 1 - .../function/aggregation/ConcatAccumulator.java | 3 +- .../aggregation/ConcatDistinctAccumulator.java | 3 +- .../function/aggregation/CountAccumulator.java | 3 +- .../function/aggregation/DistinctAccumulator.java | 3 +- .../function/aggregation/MaxAccumulator.java | 3 +- .../function/aggregation/MinAccumulator.java | 3 +- .../function/aggregation/SumAccumulator.java | 3 +- .../script/function/impl/bool/BooleanFunction.java | 4 +- .../impl/condition/ExecuteByConditionFuction.java | 2 +- .../function/impl/context/ContextFunction.java | 4 +- .../function/impl/date/AddMonthFunction.java | 7 +- .../impl/date/CurrentTimestampFunction.java | 5 +- .../script/function/impl/date/DateAddFunction.java | 15 +- .../function/impl/date/DateDiffFunction.java | 3 +- .../function/impl/date/DateFormatFunction.java | 7 +- .../function/impl/date/DatePartFunction.java | 11 +- .../function/impl/date/DateToCharFunction.java | 7 +- .../function/impl/date/DateTruncFunction.java | 16 +- .../function/impl/date/DateUtilFunction.java | 3 +- .../script/function/impl/date/DayFunction.java | 9 +- .../function/impl/date/FromUnixTimeFunction.java | 13 +- .../script/function/impl/date/GetDateFunction.java | 9 +- .../script/function/impl/date/LastDayFunction.java | 15 +- .../script/function/impl/date/NextDayFunction.java | 13 +- .../script/function/impl/date/NowFuntion.java | 3 +- .../script/function/impl/date/QuarterFunction.java | 11 +- .../function/impl/date/UnixTimeStampFunction.java | 11 +- .../function/impl/date/WeekOfYearFunction.java | 3 +- .../script/function/impl/date/WeekdayFunction.java | 11 +- .../impl/field/AdditionalFiledFunction.java | 5 +- .../function/impl/field/CoalesceFunction.java | 7 +- .../function/impl/field/RetainFieldFunction.java | 5 +- .../script/function/impl/filter/BreakFunction.java | 5 +- .../function/impl/flatmap/SplitArrayFunction.java | 5 +- .../function/impl/header/HeaderFunction.java | 8 +- .../function/impl/json/JsonArrayFunction.java | 5 +- .../function/impl/json/JsonValueFunction.java | 7 +- .../script/function/impl/math/AbsFunction.java | 11 +- .../script/function/impl/math/AcosFunction.java | 11 +- .../function/impl/math/AdditionFunction.java | 7 +- .../script/function/impl/math/AsinFunction.java | 11 +- .../script/function/impl/math/AtanFunction.java | 8 +- .../script/function/impl/math/BinFunction.java | 8 +- .../script/function/impl/math/BitFunction.java | 8 +- .../script/function/impl/math/BroundFunction.java | 13 +- .../function/impl/math/CardinalityFunction.java | 6 +- .../script/function/impl/math/CbrtFunction.java | 8 +- .../script/function/impl/math/CeilFunction.java | 11 +- .../script/function/impl/math/ConvFunction.java | 8 +- .../script/function/impl/math/CosFunction.java | 11 +- .../script/function/impl/math/CosHFunction.java | 11 +- .../script/function/impl/math/CotFunction.java | 11 +- .../script/function/impl/math/DegreesFunction.java | 11 +- .../function/impl/math/DivisionFunction.java | 7 +- .../script/function/impl/math/EFunction.java | 6 +- .../script/function/impl/math/ExpFunction.java | 11 +- .../function/impl/math/FactorialFunction.java | 8 +- .../script/function/impl/math/FloorFunction.java | 5 +- .../script/function/impl/math/HexFunction.java | 8 +- .../script/function/impl/math/LnFunction.java | 11 +- .../script/function/impl/math/Log10Function.java | 11 +- .../script/function/impl/math/Log2Function.java | 11 +- .../script/function/impl/math/LogFunction.java | 11 +- .../script/function/impl/math/MathFunction.java | 4 +- .../function/impl/math/MultiplicationFunction.java | 7 +- .../function/impl/math/OperationFunction.java | 8 +- .../script/function/impl/math/PIFunction.java | 6 +- .../script/function/impl/math/PowerFunction.java | 11 +- .../script/function/impl/math/RadiansFunction.java | 8 +- .../script/function/impl/math/RandFunction.java | 8 +- .../script/function/impl/math/RoundFunction.java | 11 +- .../function/impl/math/ShiftLeftFunction.java | 8 +- .../function/impl/math/ShiftRightFunction.java | 8 +- .../impl/math/ShiftRightUnSignedFunction.java | 8 +- .../script/function/impl/math/SignFunction.java | 8 +- .../script/function/impl/math/SinFunction.java | 11 +- .../script/function/impl/math/SinHFunction.java | 11 +- .../script/function/impl/math/SqrtFunction.java | 11 +- .../function/impl/math/SubtractionFunction.java | 7 +- .../script/function/impl/math/TanFunction.java | 8 +- .../script/function/impl/math/TanHFunction.java | 11 +- .../script/function/impl/math/TruncFunction.java | 11 +- .../script/function/impl/math/UnHexFunction.java | 8 +- .../script/function/impl/mock/MockFunction.java | 4 +- .../function/impl/offset/OffsetFunction.java | 7 +- .../script/function/impl/parser/GrokFunction.java | 13 +- .../function/impl/parser/LogParserFunction.java | 11 +- .../function/impl/parser/Paser2JsonFunction.java | 9 +- .../function/impl/parser/PaserBySplitFunction.java | 17 +- .../function/impl/parser/RegexParserFunction.java | 15 +- .../function/impl/python/GroovyFunction.java | 6 +- .../script/function/impl/router/RouteFunction.java | 4 +- .../script/function/impl/sql/SQLFunction.java | 4 +- .../script/function/impl/string/AsciiFunction.java | 8 +- .../function/impl/string/Base64Function.java | 7 +- .../impl/string/CharMatchCountFunction.java | 13 +- .../function/impl/string/HashCodeFunction.java | 8 +- .../function/impl/string/InitCapFunction.java | 8 +- .../script/function/impl/string/InstrFunction.java | 8 +- .../function/impl/string/Ip2RegionFunction.java | 6 +- .../function/impl/string/IsEncodingFunction.java | 13 +- .../function/impl/string/KeyValueFunction.java | 9 +- .../script/function/impl/string/LTrimFunction.java | 8 +- .../function/impl/string/LengthBFunction.java | 8 +- .../function/impl/string/LengthFunction.java | 8 +- .../script/function/impl/string/Md5Function.java | 11 +- .../script/function/impl/string/NullFunction.java | 4 +- .../function/impl/string/ParseUrlFunction.java | 15 +- .../script/function/impl/string/RTrimFunction.java | 8 +- .../function/impl/string/RegexCountFunction.java | 13 +- .../script/function/impl/string/RegexFunction.java | 7 +- .../function/impl/string/RegexInstrFunction.java | 13 +- .../function/impl/string/RegexReplaceFunction.java | 8 +- .../function/impl/string/RegexSubStrFunction.java | 13 +- .../function/impl/string/RepeatFunction.java | 8 +- .../function/impl/string/ReplaceFunction.java | 8 +- .../function/impl/string/ReverseFunction.java | 8 +- .../function/impl/string/SoundxFunction.java | 8 +- .../script/function/impl/string/SpaceFunction.java | 8 +- .../function/impl/string/SplitPartFunction.java | 8 +- .../impl/string/SubStringIndexFunction.java | 13 +- .../function/impl/string/ToCharFunction.java | 11 +- .../function/impl/string/ToLowerFunction.java | 8 +- .../function/impl/string/ToUpperFunction.java | 8 +- .../function/impl/string/TransLateFunction.java | 8 +- .../script/function/impl/string/TrimFunction.java | 8 +- .../script/function/impl/string/UUIDFunction.java | 6 +- .../function/impl/string/UrlDecodeFunction.java | 13 +- .../function/impl/string/UrlEncodeFunction.java | 13 +- .../script/function/impl/type/CastFunction.java | 7 +- .../script/function/impl/udtf/UDTFFunction.java | 3 +- .../function/impl/window/WindowFunction.java | 6 +- .../script/function/model/FunctionConfigure.java | 18 +- .../function/model/FunctionConfigureMap.java | 1 - .../script/function/model/FunctionInfo.java | 3 +- .../script/function/service/IFunctionService.java | 7 +- .../service/impl/DefaultFunctionServiceImpl.java | 26 ++- .../function/service/impl/ScanFunctionService.java | 5 +- .../script/operator/AbstractScriptOperator.java | 12 +- .../operator/expression/GroupScriptExpression.java | 3 +- .../operator/expression/ScriptExpression.java | 11 +- .../operator/expression/ScriptParameter.java | 3 +- .../script/operator/impl/AggregationScript.java | 5 +- .../script/operator/impl/FunctionScript.java | 15 +- .../script/operator/impl/GroovyScriptOperator.java | 25 ++- .../operator/impl/JPythonScriptOperator.java | 16 +- .../script/operator/impl/JavaScriptOperator.java | 2 +- .../optimization/AbstractFunctionOptimization.java | 4 +- .../script/optimization/CompileParameter.java | 2 +- .../optimization/CompileScriptExpression.java | 8 +- .../script/optimization/EqualsOptimization.java | 2 +- .../script/optimization/RegexOptimization.java | 2 +- .../script/optimization/ScriptOptimization.java | 7 +- .../parser/ScriptExpressionParserFactory.java | 1 - .../parser/imp/ConditionExpressionParser.java | 3 +- .../parser/imp/FunctionExpressionParser.java | 9 +- .../streams/script/parser/imp/FunctionParser.java | 1 - .../streams/script/service/IAccumulator.java | 2 - .../streams/script/service/IScriptExpression.java | 3 +- .../streams/script/service/IScriptParamter.java | 2 +- .../streams/script/service/IScriptService.java | 9 +- .../script/service/impl/ScriptServiceImpl.java | 11 +- .../streams/script/service/udf/UDAFScript.java | 3 +- .../streams/script/service/udf/UDFScript.java | 13 +- .../streams/script/service/udf/UDTFScript.java | 5 +- .../streams/script/utils/FunctionUtils.java | 1 - .../rocketmq/streams/script/utils/MatchUtil.java | 1 - .../streams/script/function/FunctionTest.java | 5 +- .../streams/script/function/GrokFunctionTest.java | 3 +- .../script/function/GroovyFunctionTest.java | 5 +- .../script/function/JPythonFunctionTest.java | 4 +- .../function/aggregation/AccumulatorTest.java | 1 - .../script/operator/ScriptOperatorTest.java | 4 +- .../streams/script/parser/ScriptParserTest.java | 1 - .../src/test/resources/python_script.py | 2 +- rocketmq-streams-serviceloader/pom.xml | 2 +- .../serviceloader/ServiceLoaderComponent.java | 12 +- .../impl/AnnotationServiceNameGetter.java | 2 +- .../streams/serviceloader/utils/FileUtil.java | 9 +- rocketmq-streams-transport-minio/pom.xml | 2 +- .../transport/minio/MinioFileTransport.java | 15 +- .../yundun/dipper/configurable/DataTpyeTest.java | 4 +- .../streams/configurable/model/Person.java | 3 +- .../src/test/resources/python_script.py | 2 +- rocketmq-streams-window/pom.xml | 2 +- .../streams/window/builder/WindowBuilder.java | 6 +- .../streams/window/model/FunctionExecutor.java | 1 - .../rocketmq/streams/window/model/WindowCache.java | 15 +- .../streams/window/model/WindowInstance.java | 22 +-- .../window/offset/IWindowMaxValueManager.java | 3 +- .../streams/window/offset/WindowMaxValue.java | 1 - .../window/offset/WindowMaxValueManager.java | 1 - .../window/operator/AbstractShuffleWindow.java | 11 +- .../streams/window/operator/AbstractWindow.java | 49 +++-- .../streams/window/operator/impl/OverWindow.java | 7 +- .../window/operator/impl/SessionWindow.java | 9 +- .../window/operator/impl/WindowOperator.java | 12 +- .../streams/window/operator/join/DBOperator.java | 16 +- .../streams/window/operator/join/JoinWindow.java | 27 +-- .../streams/window/operator/join/Operator.java | 1 - .../window/shuffle/AbstractSystemChannel.java | 22 ++- .../streams/window/shuffle/ShuffleChannel.java | 36 ++-- .../streams/window/source/WindowRireSource.java | 1 - .../streams/window/state/WindowBaseValue.java | 6 +- .../streams/window/state/impl/JoinState.java | 1 - .../streams/window/state/impl/WindowValue.java | 34 ++-- .../window/storage/AbstractWindowStorage.java | 11 +- .../window/storage/IShufflePartitionManager.java | 3 +- .../rocketmq/streams/window/storage/IStorage.java | 3 +- .../streams/window/storage/IWindowStorage.java | 7 +- .../streams/window/storage/WindowStorage.java | 18 +- .../streams/window/storage/db/DBStorage.java | 1 - .../streams/window/storage/file/FileStorage.java | 12 +- .../window/storage/rocksdb/RocksdbStorage.java | 33 +++- .../streams/configruation/model/Person.java | 3 +- .../streams/configurable/model/Person.java | 3 +- .../streams/window/WindowInstanceTest.java | 3 +- .../streams/window/WindowMaxValueTest.java | 3 +- 529 files changed, 2030 insertions(+), 2147 deletions(-)
