You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by am...@apache.org on 2021/11/16 11:30:32 UTC
[ignite-3] branch ignite-15901 updated (c76139b -> 994454f)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-15901
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from c76139b Drop live schema support.
add ba18299 IGNITE-15783 Mapper API and initial implementation. (#424)
add af06c65 IGNITE-14484 Implement RecordView API. (#435)
add bb7e13c IGNITE-15900 Disable javadoc style checks for test methods. (#442)
add d3149c5 IGNITE-15060 IGNITE-15060 Added support of node working directory to CLI. #210
add 8eb62bb IGNITE-15691 Common thread pool is used for snapshotting all rocksdb-based partitions. (#405)
add cc88e41 IGNITE-15833 Provide interfaces for SQL Extension API (#439)
add 1957cf3 IGNITE-15492 Check schema availability on local node. Fixes #344
add f3b2dd3 IGNITE-15919 Missing inspection UnusedImports (#447)
add 9529e4c IGNITE-15920 Fix Maven warnings (#449)
add ff077ba IGNITE-15846 Provide Interface for external table (#443)
add 5826d81 IGNITE-15841 Starting a node should be failed if the user configuration is invalid. Fixes #423
add ecb7d28 IGNITE-15853 Add api description of polymorphic configuration to modules/configuration/README.md (#425)
add 994454f Merge branch 'main' into ignite-15901
No new revisions were added by this update.
Summary of changes:
check-rules/checkstyle-rules.xml | 7 +-
.../java/org/apache/ignite/table/KeyValueView.java | 3 +-
.../java/org/apache/ignite/table/RecordView.java | 1 +
.../main/java/org/apache/ignite/table/Table.java | 6 +-
.../ignite/table/mapper/DefaultColumnMapper.java} | 42 +-
.../apache/ignite/table/mapper/IdentityMapper.java | 63 ++
.../org/apache/ignite/table/mapper/Mapper.java | 82 +--
.../apache/ignite/table/mapper/MapperBuilder.java | 129 ++++
.../org/apache/ignite/table/mapper/Mappers.java | 94 ---
.../query/calcite/exec/ExecutionServiceImpl.java | 16 +-
.../query/calcite/exec/PlannerHelper.java | 7 +-
.../CatalogUpdateListener.java} | 19 +-
.../query/calcite/extension/SqlExtension.java | 149 +++++
.../query/calcite/externalize/RelJson.java | 4 +-
.../calcite/metadata/IgniteMdFragmentMapping.java | 6 +-
.../query/calcite/prepare/FieldsMetadata.java | 37 -
.../query/calcite/prepare/FieldsMetadataImpl.java | 52 --
.../query/calcite/prepare/PlannerHelper.java | 7 +-
.../query/calcite/rel/AbstractIgniteSpool.java | 2 +-
.../query/calcite/rel/IgniteAggregate.java | 2 +-
.../query/calcite/rel/IgniteConvention.java | 2 +-
.../query/calcite/rel/IgniteExchange.java | 2 +-
.../query/calcite/rel/IgniteHashIndexSpool.java | 2 +-
.../processors/query/calcite/rel/IgniteLimit.java | 2 +-
.../query/calcite/rel/IgniteReceiver.java | 2 +-
.../processors/query/calcite/rel/IgniteSender.java | 2 +-
.../processors/query/calcite/rel/IgniteSort.java | 2 +-
.../query/calcite/rel/IgniteSortedIndexSpool.java | 2 +-
.../query/calcite/rel/IgniteTableFunctionScan.java | 2 +-
.../query/calcite/rel/IgniteTableModify.java | 2 +-
.../query/calcite/rel/IgniteTableSpool.java | 2 +-
.../processors/query/calcite/rel/IgniteValues.java | 2 +-
...eAwareIgniteRel.java => InternalIgniteRel.java} | 11 +-
.../query/calcite/rel/SourceAwareIgniteRel.java | 2 +-
.../rel/logical/IgniteLogicalIndexScan.java | 4 +-
.../calcite/rule/logical/ExposeIndexRule.java | 6 +-
.../query/calcite/schema/IgniteIndex.java | 6 +-
.../query/calcite/schema/IgniteSchema.java | 4 +-
.../query/calcite/schema/IgniteTable.java | 117 ++--
.../query/calcite/schema/IgniteTableImpl.java | 2 +-
.../{IgniteTable.java => InternalIgniteTable.java} | 52 +-
.../query/calcite/trait/TraitsAwareIgniteRel.java | 4 +-
.../query/calcite/StopCalciteModuleTest.java | 9 +-
.../query/calcite/planner/AbstractPlannerTest.java | 4 +-
.../java/org/apache/ignite/cli/IgnitePaths.java | 18 +-
.../ignite/cli/builtins/node/NodeManager.java | 48 +-
.../apache/ignite/cli/spec/NodeCommandSpec.java | 5 +-
.../apache/ignite/cli/IgniteCliInterfaceTest.java | 7 +-
.../handler/requests/table/ClientTableCommon.java | 1 -
.../ignite/client/fakes/FakeSchemaRegistry.java | 13 +
modules/configuration/README.md | 154 ++++-
modules/core/pom.xml | 2 +-
.../apache/ignite/internal/util/IgniteUtils.java | 7 +-
.../internal/testframework/IgniteTestUtils.java | 63 ++
.../metastorage/watch/WatchAggregator.java | 22 +-
.../raft/jraft/rpc/impl/RaftGroupServiceImpl.java | 43 +-
modules/runner/pom.xml | 11 +
.../internal/runner/app/IgniteCliRunnerTest.java} | 34 +-
.../internal/runner/app/ItDataSchemaSyncTest.java | 261 ++++++++
.../ignite/internal/runner/app/ItIgnitionTest.java | 33 +-
.../internal/runner/app/ItTablesApiTest.java | 122 +---
.../internal/test/WatchListenerInhibitor.java | 149 +++++
.../org/apache/ignite/app/IgniteCliRunner.java | 157 ++---
.../org/apache/ignite/internal/app/IgniteImpl.java | 139 ++--
.../apache/ignite/internal/app/IgnitionImpl.java | 18 +-
modules/schema/pom.xml | 18 +
.../apache/ignite/internal/schema/NativeTypes.java | 2 +
.../ignite/internal/schema/SchemaRegistry.java | 16 +
.../internal/schema/marshaller/BinaryMode.java | 16 +-
.../internal/schema/marshaller/KvMarshaller.java | 27 +-
...tionException.java => MarshallerException.java} | 8 +-
.../schema/marshaller/MarshallerFactory.java | 72 ++
.../internal/schema/marshaller/MarshallerUtil.java | 36 +-
.../schema/marshaller/RecordMarshaller.java} | 40 +-
.../internal/schema/marshaller/Serializer.java | 19 +-
.../schema/marshaller/SerializerFactory.java | 4 +
.../marshaller/asm/AsmSerializerGenerator.java | 10 +-
.../marshaller/asm/ColumnAccessCodeGenerator.java | 48 +-
.../marshaller/reflection/FieldAccessor.java | 426 +++++++-----
.../marshaller/reflection/JavaSerializer.java | 12 +-
.../reflection/JavaSerializerFactory.java | 2 +
.../{JavaSerializer.java => KvMarshallerImpl.java} | 79 ++-
.../schema/marshaller/reflection/Marshaller.java | 230 ++++---
...vaSerializer.java => RecordMarshallerImpl.java} | 114 ++--
...ctory.java => ReflectionMarshallerFactory.java} | 20 +-
.../schema/registry/SchemaRegistryImpl.java | 68 +-
.../org/apache/ignite/internal/schema/RowTest.java | 2 +-
.../{TestUtils.java => SchemaTestUtils.java} | 4 +-
.../schema/marshaller/JavaSerializerTest.java | 300 ++-------
.../schema/marshaller/KvMarshallerTest.java | 745 +++++++++++++++++++++
.../internal/schema/marshaller/MapperTest.java | 75 +++
.../schema/marshaller/RecordMarshallerTest.java | 597 +++++++++++++++++
.../marshaller/reflection/FieldAccessorTest.java | 321 +++------
.../schema/registry/SchemaRegistryImplTest.java | 16 +-
.../schema/registry/UpgradingRowAdapterTest.java | 9 +-
.../schema/testobjects/TestObjectWithAllTypes.java | 370 ++++++++++
.../TestObjectWithNoDefaultConstructor.java} | 51 +-
.../TestObjectWithPrivateConstructor.java} | 55 +-
.../schema/testobjects/TestSimpleObject.java | 72 ++
.../internal/storage/engine/StorageEngine.java | 17 +-
.../storage/rocksdb/RocksDbPartitionStorage.java | 263 ++++----
.../storage/rocksdb/RocksDbStorageEngine.java | 24 +
.../storage/rocksdb/RocksDbTableStorage.java | 13 +-
modules/table/pom.xml | 7 +
.../ignite/distributed/ItDistributedTableTest.java | 11 +-
.../schema/marshaller/TupleMarshallerImpl.java | 28 +-
.../ignite/internal/table/KeyValueViewImpl.java | 300 +++++----
.../internal/table/RecordBinaryViewImpl.java | 13 +-
.../ignite/internal/table/RecordViewImpl.java | 237 +++++--
.../internal/table/distributed/TableManager.java | 585 ++++++++++------
.../TupleMarshallerFixlenOnlyBenchmark.java | 4 +-
.../TupleMarshallerVarlenOnlyBenchmark.java | 3 +-
.../org/apache/ignite/internal/table/Example.java | 14 +-
...=> KeyValueViewOperationsSimpleSchemaTest.java} | 97 ++-
.../internal/table/KeyValueViewOperationsTest.java | 416 ++++++++++++
.../internal/table/RecordViewOperationsTest.java | 340 ++++++++++
.../ignite/internal/table/TableManagerTest.java | 4 +-
.../table/impl/DummySchemaManagerImpl.java | 19 +-
parent/pom.xml | 7 +
119 files changed, 6203 insertions(+), 2363 deletions(-)
copy modules/{metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/AbstractCondition.java => api/src/main/java/org/apache/ignite/table/mapper/DefaultColumnMapper.java} (51%)
create mode 100644 modules/api/src/main/java/org/apache/ignite/table/mapper/IdentityMapper.java
create mode 100644 modules/api/src/main/java/org/apache/ignite/table/mapper/MapperBuilder.java
delete mode 100644 modules/api/src/main/java/org/apache/ignite/table/mapper/Mappers.java
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/{externalize/RelInputEx.java => extension/CatalogUpdateListener.java} (63%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/extension/SqlExtension.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/FieldsMetadata.java
delete mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/FieldsMetadataImpl.java
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/{SourceAwareIgniteRel.java => InternalIgniteRel.java} (74%)
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/{IgniteTable.java => InternalIgniteTable.java} (58%)
copy modules/{metastorage-server/src/test/java/org/apache/ignite/internal/metastorage/server/RocksDbKeyValueStorageTest.java => runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/IgniteCliRunnerTest.java} (52%)
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ItDataSchemaSyncTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/test/WatchListenerInhibitor.java
rename modules/{table => schema}/src/main/java/org/apache/ignite/internal/schema/marshaller/KvMarshaller.java (68%)
rename modules/schema/src/main/java/org/apache/ignite/internal/schema/marshaller/{SerializationException.java => MarshallerException.java} (82%)
create mode 100644 modules/schema/src/main/java/org/apache/ignite/internal/schema/marshaller/MarshallerFactory.java
rename modules/{table/src/main/java/org/apache/ignite/internal/schema/marshaller/RecordSerializer.java => schema/src/main/java/org/apache/ignite/internal/schema/marshaller/RecordMarshaller.java} (52%)
copy modules/schema/src/main/java/org/apache/ignite/internal/schema/marshaller/reflection/{JavaSerializer.java => KvMarshallerImpl.java} (74%)
copy modules/schema/src/main/java/org/apache/ignite/internal/schema/marshaller/reflection/{JavaSerializer.java => RecordMarshallerImpl.java} (62%)
copy modules/schema/src/main/java/org/apache/ignite/internal/schema/marshaller/reflection/{JavaSerializerFactory.java => ReflectionMarshallerFactory.java} (56%)
rename modules/schema/src/test/java/org/apache/ignite/internal/schema/{TestUtils.java => SchemaTestUtils.java} (98%)
create mode 100644 modules/schema/src/test/java/org/apache/ignite/internal/schema/marshaller/KvMarshallerTest.java
create mode 100644 modules/schema/src/test/java/org/apache/ignite/internal/schema/marshaller/MapperTest.java
create mode 100644 modules/schema/src/test/java/org/apache/ignite/internal/schema/marshaller/RecordMarshallerTest.java
create mode 100644 modules/schema/src/test/java/org/apache/ignite/internal/schema/testobjects/TestObjectWithAllTypes.java
copy modules/{configuration/src/main/java/org/apache/ignite/internal/configuration/validation/MemberKey.java => schema/src/test/java/org/apache/ignite/internal/schema/testobjects/TestObjectWithNoDefaultConstructor.java} (55%)
copy modules/{configuration/src/main/java/org/apache/ignite/internal/configuration/validation/MemberKey.java => schema/src/test/java/org/apache/ignite/internal/schema/testobjects/TestObjectWithPrivateConstructor.java} (53%)
create mode 100644 modules/schema/src/test/java/org/apache/ignite/internal/schema/testobjects/TestSimpleObject.java
rename modules/table/src/test/java/org/apache/ignite/internal/table/{KeyValueOperationsTest.java => KeyValueViewOperationsSimpleSchemaTest.java} (72%)
create mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/KeyValueViewOperationsTest.java
create mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/RecordViewOperationsTest.java