This is an automated email from the ASF dual-hosted git repository.
rzo1 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/storm.git
from aa6f418aa Bump curator.version from 5.8.0 to 5.9.0 (#8202)
add efb42e665 Drop storm-sql-* modules (#8174)
No new revisions were added by this update.
Summary of changes:
DEPENDENCY-LICENSES | 13 -
LICENSE-binary | 13 -
bin/storm.py | 65 -
docs/Implementation-docs.md | 1 -
docs/State-checkpointing.md | 2 +-
docs/index.md | 12 -
docs/storm-sql-example.md | 289 -----
docs/storm-sql-internal.md | 59 -
docs/storm-sql-reference.md | 1314 --------------------
docs/storm-sql.md | 198 ---
pom.xml | 17 -
sql/README.md | 28 -
sql/pom.xml | 59 -
sql/storm-sql-core/pom.xml | 331 -----
sql/storm-sql-core/src/codegen/config.fmpp | 23 -
sql/storm-sql-core/src/codegen/data/Parser.tdd | 80 --
.../src/codegen/includes/license.ftl | 17 -
.../src/codegen/includes/parserImpls.ftl | 113 --
.../apache/storm/sql/AbstractStreamsProcessor.java | 67 -
.../src/jvm/org/apache/storm/sql/StormSql.java | 45 -
.../jvm/org/apache/storm/sql/StormSqlContext.java | 169 ---
.../src/jvm/org/apache/storm/sql/StormSqlImpl.java | 123 --
.../jvm/org/apache/storm/sql/StormSqlRunner.java | 80 --
.../storm/sql/calcite/ParallelStreamableTable.java | 29 -
.../apache/storm/sql/calcite/ParallelTable.java | 28 -
.../storm/sql/calcite/StormStreamableTable.java | 26 -
.../org/apache/storm/sql/calcite/StormTable.java | 26 -
.../apache/storm/sql/compiler/CompilerUtil.java | 227 ----
.../sql/compiler/RexNodeToJavaCodeCompiler.java | 234 ----
.../sql/compiler/StormSqlTypeFactoryImpl.java | 42 -
.../storm/sql/javac/CompilingClassLoader.java | 227 ----
.../apache/storm/sql/parser/ColumnConstraint.java | 38 -
.../apache/storm/sql/parser/ColumnDefinition.java | 38 -
.../apache/storm/sql/parser/SqlCreateFunction.java | 88 --
.../apache/storm/sql/parser/SqlCreateTable.java | 164 ---
.../apache/storm/sql/parser/SqlDdlKeywords.java | 22 -
.../org/apache/storm/sql/parser/StormParser.java | 44 -
.../org/apache/storm/sql/parser/UnparseUtil.java | 54 -
.../storm/sql/planner/StormRelDataTypeSystem.java | 31 -
.../apache/storm/sql/planner/StormRelUtils.java | 62 -
.../sql/planner/UnsupportedOperatorsVisitor.java | 19 -
.../storm/sql/planner/rel/StormCalcRelBase.java | 25 -
.../storm/sql/planner/rel/StormFilterRelBase.java | 25 -
.../storm/sql/planner/rel/StormJoinRelBase.java | 29 -
.../storm/sql/planner/rel/StormProjectRelBase.java | 28 -
.../apache/storm/sql/planner/rel/StormRelNode.java | 18 -
.../sql/planner/rel/StormStreamInsertRelBase.java | 30 -
.../sql/planner/rel/StormStreamScanRelBase.java | 25 -
.../storm/sql/planner/streams/QueryPlanner.java | 158 ---
.../sql/planner/streams/StreamsPlanCreator.java | 126 --
.../sql/planner/streams/StreamsStormRuleSets.java | 109 --
.../sql/planner/streams/rel/StreamsCalcRel.java | 94 --
.../sql/planner/streams/rel/StreamsFilterRel.java | 66 -
.../streams/rel/StreamsLogicalConvention.java | 69 -
.../sql/planner/streams/rel/StreamsProjectRel.java | 69 -
.../storm/sql/planner/streams/rel/StreamsRel.java | 27 -
.../streams/rel/StreamsStreamInsertRel.java | 82 --
.../planner/streams/rel/StreamsStreamScanRel.java | 57 -
.../streams/rules/StreamsAggregateRule.java | 40 -
.../sql/planner/streams/rules/StreamsCalcRule.java | 46 -
.../planner/streams/rules/StreamsFilterRule.java | 47 -
.../sql/planner/streams/rules/StreamsJoinRule.java | 39 -
.../planner/streams/rules/StreamsModifyRule.java | 89 --
.../planner/streams/rules/StreamsProjectRule.java | 48 -
.../sql/planner/streams/rules/StreamsScanRule.java | 61 -
.../src/test/org/apache/storm/sql/SqlTestUtil.java | 59 -
.../apache/storm/sql/StormSqlLocalClusterImpl.java | 79 --
.../test/org/apache/storm/sql/TestStormSql.java | 297 -----
.../backends/streams/TestCompilerUtils.java | 217 ----
.../backends/streams/TestPlanCompiler.java | 231 ----
.../org/apache/storm/sql/parser/TestSqlParser.java | 50 -
sql/storm-sql-external/storm-sql-hdfs/pom.xml | 152 ---
.../storm/sql/hdfs/HdfsDataSourcesProvider.java | 131 --
...rg.apache.storm.sql.runtime.DataSourcesProvider | 16 -
.../sql/hdfs/TestHdfsDataSourcesProvider.java | 88 --
sql/storm-sql-external/storm-sql-kafka/pom.xml | 107 --
.../storm/sql/kafka/KafkaDataSourcesProvider.java | 175 ---
.../sql/kafka/RecordTranslatorSchemeAdapter.java | 48 -
...rg.apache.storm.sql.runtime.DataSourcesProvider | 16 -
.../sql/kafka/TestKafkaDataSourcesProvider.java | 59 -
sql/storm-sql-external/storm-sql-redis/pom.xml | 85 --
.../storm/sql/redis/RedisDataSourcesProvider.java | 213 ----
...rg.apache.storm.sql.runtime.DataSourcesProvider | 16 -
.../sql/redis/TestRedisDataSourcesProvider.java | 78 --
sql/storm-sql-runtime/pom.xml | 169 ---
.../apache/calcite/interpreter/StormContext.java | 32 -
.../storm/sql/runtime/DataSourcesProvider.java | 46 -
.../storm/sql/runtime/DataSourcesRegistry.java | 75 --
.../org/apache/storm/sql/runtime/FieldInfo.java | 54 -
.../storm/sql/runtime/IOutputSerializer.java | 32 -
.../storm/sql/runtime/ISqlStreamsDataSource.java | 40 -
.../calcite/DebuggableExecutableExpression.java | 45 -
.../sql/runtime/calcite/ExecutableExpression.java | 32 -
.../sql/runtime/calcite/StormDataContext.java | 84 --
.../socket/SocketDataSourcesProvider.java | 90 --
.../runtime/datasource/socket/bolt/SocketBolt.java | 105 --
.../datasource/socket/spout/SocketSpout.java | 195 ---
.../storm/sql/runtime/serde/avro/AvroScheme.java | 80 --
.../sql/runtime/serde/avro/AvroSerializer.java | 79 --
.../sql/runtime/serde/avro/CachedSchemas.java | 47 -
.../storm/sql/runtime/serde/csv/CsvScheme.java | 72 --
.../storm/sql/runtime/serde/csv/CsvSerializer.java | 60 -
.../storm/sql/runtime/serde/json/JsonScheme.java | 60 -
.../sql/runtime/serde/json/JsonSerializer.java | 59 -
.../storm/sql/runtime/serde/tsv/TsvScheme.java | 60 -
.../storm/sql/runtime/serde/tsv/TsvSerializer.java | 55 -
.../runtime/streams/functions/EvaluationCalc.java | 85 --
.../streams/functions/EvaluationFilter.java | 61 -
.../streams/functions/EvaluationFunction.java | 64 -
.../functions/StreamInsertMapToPairFunction.java | 38 -
.../functions/StreamsScanTupleValueMapper.java | 51 -
.../storm/sql/runtime/utils/FieldInfoUtils.java | 41 -
.../apache/storm/sql/runtime/utils/SerdeUtils.java | 144 ---
.../org/apache/storm/sql/runtime/utils/Utils.java | 56 -
...rg.apache.storm.sql.runtime.DataSourcesProvider | 16 -
.../org/apache/storm/sql/TestAvroSerializer.java | 72 --
.../org/apache/storm/sql/TestCsvSerializer.java | 54 -
.../apache/storm/sql/TestJsonRepresentation.java | 52 -
.../org/apache/storm/sql/TestTsvSerializer.java | 46 -
.../src/test/org/apache/storm/sql/TestUtils.java | 363 ------
storm-client/test/py/test_storm_cli.py | 18 -
.../final-package/src/main/assembly/binary.xml | 15 -
storm-dist/binary/pom.xml | 2 -
storm-dist/binary/storm-sql-core-bin/pom.xml | 71 --
.../src/main/assembly/storm-sql-core.xml | 33 -
storm-dist/binary/storm-sql-runtime-bin/pom.xml | 71 --
.../src/main/assembly/storm-sql-runtime.xml | 33 -
127 files changed, 1 insertion(+), 10997 deletions(-)
delete mode 100644 docs/storm-sql-example.md
delete mode 100644 docs/storm-sql-internal.md
delete mode 100644 docs/storm-sql-reference.md
delete mode 100644 docs/storm-sql.md
delete mode 100644 sql/README.md
delete mode 100644 sql/pom.xml
delete mode 100644 sql/storm-sql-core/pom.xml
delete mode 100644 sql/storm-sql-core/src/codegen/config.fmpp
delete mode 100644 sql/storm-sql-core/src/codegen/data/Parser.tdd
delete mode 100644 sql/storm-sql-core/src/codegen/includes/license.ftl
delete mode 100644 sql/storm-sql-core/src/codegen/includes/parserImpls.ftl
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/AbstractStreamsProcessor.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/StormSql.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/StormSqlContext.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/StormSqlImpl.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/StormSqlRunner.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/calcite/ParallelStreamableTable.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/calcite/ParallelTable.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/calcite/StormStreamableTable.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/calcite/StormTable.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/compiler/CompilerUtil.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/compiler/RexNodeToJavaCodeCompiler.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/compiler/StormSqlTypeFactoryImpl.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/javac/CompilingClassLoader.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/parser/ColumnConstraint.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/parser/ColumnDefinition.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/parser/SqlCreateFunction.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/parser/SqlCreateTable.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/parser/SqlDdlKeywords.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/parser/StormParser.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/parser/UnparseUtil.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/StormRelDataTypeSystem.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/StormRelUtils.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/UnsupportedOperatorsVisitor.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/rel/StormCalcRelBase.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/rel/StormFilterRelBase.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/rel/StormJoinRelBase.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/rel/StormProjectRelBase.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/rel/StormRelNode.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/rel/StormStreamInsertRelBase.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/rel/StormStreamScanRelBase.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/QueryPlanner.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/StreamsPlanCreator.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/StreamsStormRuleSets.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rel/StreamsCalcRel.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rel/StreamsFilterRel.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rel/StreamsLogicalConvention.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rel/StreamsProjectRel.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rel/StreamsRel.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rel/StreamsStreamInsertRel.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rel/StreamsStreamScanRel.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rules/StreamsAggregateRule.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rules/StreamsCalcRule.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rules/StreamsFilterRule.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rules/StreamsJoinRule.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rules/StreamsModifyRule.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rules/StreamsProjectRule.java
delete mode 100644
sql/storm-sql-core/src/jvm/org/apache/storm/sql/planner/streams/rules/StreamsScanRule.java
delete mode 100644
sql/storm-sql-core/src/test/org/apache/storm/sql/SqlTestUtil.java
delete mode 100644
sql/storm-sql-core/src/test/org/apache/storm/sql/StormSqlLocalClusterImpl.java
delete mode 100644
sql/storm-sql-core/src/test/org/apache/storm/sql/TestStormSql.java
delete mode 100644
sql/storm-sql-core/src/test/org/apache/storm/sql/compiler/backends/streams/TestCompilerUtils.java
delete mode 100644
sql/storm-sql-core/src/test/org/apache/storm/sql/compiler/backends/streams/TestPlanCompiler.java
delete mode 100644
sql/storm-sql-core/src/test/org/apache/storm/sql/parser/TestSqlParser.java
delete mode 100644 sql/storm-sql-external/storm-sql-hdfs/pom.xml
delete mode 100644
sql/storm-sql-external/storm-sql-hdfs/src/jvm/org/apache/storm/sql/hdfs/HdfsDataSourcesProvider.java
delete mode 100644
sql/storm-sql-external/storm-sql-hdfs/src/resources/META-INF/services/org.apache.storm.sql.runtime.DataSourcesProvider
delete mode 100644
sql/storm-sql-external/storm-sql-hdfs/src/test/org/apache/storm/sql/hdfs/TestHdfsDataSourcesProvider.java
delete mode 100644 sql/storm-sql-external/storm-sql-kafka/pom.xml
delete mode 100644
sql/storm-sql-external/storm-sql-kafka/src/jvm/org/apache/storm/sql/kafka/KafkaDataSourcesProvider.java
delete mode 100644
sql/storm-sql-external/storm-sql-kafka/src/jvm/org/apache/storm/sql/kafka/RecordTranslatorSchemeAdapter.java
delete mode 100644
sql/storm-sql-external/storm-sql-kafka/src/resources/META-INF/services/org.apache.storm.sql.runtime.DataSourcesProvider
delete mode 100644
sql/storm-sql-external/storm-sql-kafka/src/test/org/apache/storm/sql/kafka/TestKafkaDataSourcesProvider.java
delete mode 100644 sql/storm-sql-external/storm-sql-redis/pom.xml
delete mode 100644
sql/storm-sql-external/storm-sql-redis/src/jvm/org/apache/storm/sql/redis/RedisDataSourcesProvider.java
delete mode 100644
sql/storm-sql-external/storm-sql-redis/src/resources/META-INF/services/org.apache.storm.sql.runtime.DataSourcesProvider
delete mode 100644
sql/storm-sql-external/storm-sql-redis/src/test/org/apache/storm/sql/redis/TestRedisDataSourcesProvider.java
delete mode 100644 sql/storm-sql-runtime/pom.xml
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/calcite/interpreter/StormContext.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/DataSourcesProvider.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/DataSourcesRegistry.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/FieldInfo.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/IOutputSerializer.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/ISqlStreamsDataSource.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/calcite/DebuggableExecutableExpression.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/calcite/ExecutableExpression.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/calcite/StormDataContext.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/datasource/socket/SocketDataSourcesProvider.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/datasource/socket/bolt/SocketBolt.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/datasource/socket/spout/SocketSpout.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/serde/avro/AvroScheme.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/serde/avro/AvroSerializer.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/serde/avro/CachedSchemas.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/serde/csv/CsvScheme.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/serde/csv/CsvSerializer.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/serde/json/JsonScheme.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/serde/json/JsonSerializer.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/serde/tsv/TsvScheme.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/serde/tsv/TsvSerializer.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/streams/functions/EvaluationCalc.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/streams/functions/EvaluationFilter.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/streams/functions/EvaluationFunction.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/streams/functions/StreamInsertMapToPairFunction.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/streams/functions/StreamsScanTupleValueMapper.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/utils/FieldInfoUtils.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/utils/SerdeUtils.java
delete mode 100644
sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/utils/Utils.java
delete mode 100644
sql/storm-sql-runtime/src/resources/META-INF/services/org.apache.storm.sql.runtime.DataSourcesProvider
delete mode 100644
sql/storm-sql-runtime/src/test/org/apache/storm/sql/TestAvroSerializer.java
delete mode 100644
sql/storm-sql-runtime/src/test/org/apache/storm/sql/TestCsvSerializer.java
delete mode 100644
sql/storm-sql-runtime/src/test/org/apache/storm/sql/TestJsonRepresentation.java
delete mode 100644
sql/storm-sql-runtime/src/test/org/apache/storm/sql/TestTsvSerializer.java
delete mode 100644
sql/storm-sql-runtime/src/test/org/apache/storm/sql/TestUtils.java
delete mode 100644 storm-dist/binary/storm-sql-core-bin/pom.xml
delete mode 100644
storm-dist/binary/storm-sql-core-bin/src/main/assembly/storm-sql-core.xml
delete mode 100644 storm-dist/binary/storm-sql-runtime-bin/pom.xml
delete mode 100644
storm-dist/binary/storm-sql-runtime-bin/src/main/assembly/storm-sql-runtime.xml
