This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git.
from 4d96d8e Merge pull request #9 from programer-0/main
new 81b41a8 Opertimize imports
new 3a59db7 change streams version
new 238e587 Add license and notice
new 9fe4669 Merge pull request #10 from duhenglucky/develop
The 46 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.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(-)
create mode 100644 .travis.yaml
create mode 100644 LICENSE
create mode 100644 NOTICE
