This is an automated email from the ASF dual-hosted git repository.
michaelsembwever pushed a change to branch cassandra-6.0
in repository https://gitbox.apache.org/repos/asf/cassandra.git
from fe5c4da8fc Merge branch 'cassandra-5.0' into cassandra-6.0
add 8f6787959e Support query paging by bytes
No new revisions were added by this update.
Summary of changes:
CHANGES.txt | 1 +
NEWS.txt | 11 +
build.xml | 1 +
conf/cassandra.yaml | 15 +-
.../cassandra/pages/developing/cql/dml.adoc | 53 ++
.../cassandra/pages/managing/tools/cqlsh.adoc | 2 +
doc/native_protocol_v5.spec | 69 +-
.../cassandra/auth/CIDRGroupsMappingManager.java | 3 +-
.../apache/cassandra/batchlog/BatchlogManager.java | 4 +-
src/java/org/apache/cassandra/config/Config.java | 6 +-
.../cassandra/config/DatabaseDescriptor.java | 21 +
.../apache/cassandra/config/GuardrailsOptions.java | 28 +
src/java/org/apache/cassandra/cql3/PageSize.java | 146 ++++
.../org/apache/cassandra/cql3/QueryOptions.java | 34 +-
.../org/apache/cassandra/cql3/QueryProcessor.java | 10 +-
.../apache/cassandra/cql3/UntypedResultSet.java | 12 +-
.../cql3/statements/DescribeStatement.java | 51 +-
.../cql3/statements/ModificationStatement.java | 4 +-
.../cassandra/cql3/statements/SelectStatement.java | 152 +++--
.../cassandra/db/AbstractReadCommandBuilder.java | 43 +-
.../cassandra/db/SinglePartitionReadCommand.java | 3 +
.../cassandra/db/SinglePartitionReadQuery.java | 3 +
.../org/apache/cassandra/db/SystemKeyspace.java | 3 +-
.../cassandra/db/SystemKeyspaceMigrator41.java | 10 +-
.../org/apache/cassandra/db/filter/DataLimits.java | 518 ++++++++++----
.../apache/cassandra/db/guardrails/Guardrails.java | 36 +-
.../cassandra/db/guardrails/GuardrailsConfig.java | 16 +-
.../cassandra/db/guardrails/GuardrailsMBean.java | 26 +-
.../org/apache/cassandra/db/rows/AbstractCell.java | 6 +
.../org/apache/cassandra/db/rows/BTreeRow.java | 12 +
.../org/apache/cassandra/db/rows/ColumnData.java | 10 +-
.../cassandra/db/rows/ComplexColumnData.java | 15 +-
src/java/org/apache/cassandra/db/rows/Row.java | 10 +-
.../cassandra/index/SecondaryIndexManager.java | 46 +-
.../index/internal/CollatedViewIndexBuilder.java | 11 +-
.../cassandra/index/sai/utils/CellWithSource.java | 6 +
.../cassandra/index/sai/utils/RowWithSource.java | 6 +
.../repair/autorepair/AutoRepairUtils.java | 3 +-
.../cassandra/repair/consistent/LocalSessions.java | 3 +-
.../service/pager/AbstractQueryPager.java | 243 +++++--
.../service/pager/AggregationQueryPager.java | 189 ++++--
.../service/pager/MultiPartitionPager.java | 274 +++++---
.../cassandra/service/pager/PagingState.java | 13 +-
.../service/pager/PartitionRangeQueryPager.java | 26 +-
.../apache/cassandra/service/pager/QueryPager.java | 33 +-
.../service/pager/SinglePartitionPager.java | 47 +-
.../service/reads/ReplicaFilteringProtection.java | 19 +-
.../service/reads/ShortReadRowsProtection.java | 10 +-
.../org/apache/cassandra/transport/Client.java | 5 +-
.../transport/messages/ExecuteMessage.java | 9 +-
.../transport/messages/OptionsMessage.java | 6 +
.../cassandra/transport/messages/QueryMessage.java | 11 +-
.../transport/messages/StartupMessage.java | 1 +
.../apache/cassandra/transport/BurnTestUtil.java | 3 +-
.../cassandra/distributed/api/ICoordinator.java | 10 +
.../cassandra/distributed/impl/Coordinator.java | 24 +-
.../distributed/impl/CoordinatorHelper.java | 3 +-
.../apache/cassandra/distributed/impl/Query.java | 3 +-
.../test/BytePagingCollectionsTest.java | 291 ++++++++
.../test/BytePagingReplicaFilteringTest.java | 100 +++
.../test/ShortReadProtectionByteLimitTest.java | 124 ++++
.../IndexBuildFailsAfterStreamingTest.java | 3 +-
.../service/pager/BytePagingHarryTest.java | 52 ++
.../harry/execution/InJvmDTestVisitExecutor.java | 8 +
.../config/DatabaseDescriptorRefTest.java | 2 +
.../cassandra/config/GuardrailsOptionsTest.java | 26 +
.../cassandra/cql3/BytePagingUpgradeTest.java | 256 +++++++
.../cassandra/cql3/CustomNowInSecondsTest.java | 2 +-
.../org/apache/cassandra/cql3/PageSizeTest.java | 95 +++
.../cassandra/cql3/PagingAggregationQueryTest.java | 749 +++++++++++++++++++++
.../org/apache/cassandra/cql3/PagingQueryTest.java | 512 +++++++++++++-
.../cassandra/cql3/PstmtPersistenceTest.java | 6 +-
.../apache/cassandra/db/filter/DataLimitsTest.java | 331 +++++++++
.../guardrails/GuardrailPageSizeInBytesTest.java | 363 ++++++++++
.../db/guardrails/GuardrailPageSizeTest.java | 18 +
.../cassandra/db/guardrails/GuardrailTester.java | 3 +-
.../db/rows/ByteLimitComplexProofTest.java | 138 ++++
.../cassandra/db/rows/PagerBytesVerifyTest.java | 110 +++
.../rows/ReviewVerifyComplexLiveDataSizeTest.java | 147 ++++
.../org/apache/cassandra/db/rows/RowsTest.java | 59 ++
.../db/rows/Verify11745ComplexBytesTest.java | 130 ++++
.../apache/cassandra/index/CustomIndexTest.java | 15 +-
.../index/sai/cql/VectorInvalidQueryTest.java | 3 +-
.../apache/cassandra/service/QueryPagerTest.java | 552 ---------------
.../service/pager/AbstractPartitionsPagerTest.java | 263 ++++++++
.../service/pager/AbstractQueryPagerTest.java | 119 ++++
.../service/pager/AggregationPagerTest.java | 296 ++++++++
.../pager/BytePagingExpiredLivenessTest.java | 160 +++++
.../service/pager/BytePagingStaticColumnsTest.java | 208 ++++++
.../service/pager/MultiPartitionPagerTest.java | 111 +++
.../service/pager/PartitionRangePagerTest.java | 86 +++
.../cassandra/service/pager/QueryPagerTest.java | 528 +++++++++++++++
.../service/pager/SinglePartitionPagerTest.java | 265 ++++++++
.../service/reads/range/RangeCommandsTest.java | 35 +-
.../nodetool/GuardrailsConfigCommandsTest.java | 24 +
.../apache/cassandra/transport/SerDeserTest.java | 38 +-
.../cassandra/fqltool/commands/DumpTest.java | 5 +-
97 files changed, 7408 insertions(+), 1163 deletions(-)
create mode 100644 src/java/org/apache/cassandra/cql3/PageSize.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/BytePagingCollectionsTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/BytePagingReplicaFilteringTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/ShortReadProtectionByteLimitTest.java
create mode 100644
test/distributed/org/apache/cassandra/service/pager/BytePagingHarryTest.java
create mode 100644
test/unit/org/apache/cassandra/cql3/BytePagingUpgradeTest.java
create mode 100644 test/unit/org/apache/cassandra/cql3/PageSizeTest.java
create mode 100644
test/unit/org/apache/cassandra/cql3/PagingAggregationQueryTest.java
create mode 100644 test/unit/org/apache/cassandra/db/filter/DataLimitsTest.java
create mode 100644
test/unit/org/apache/cassandra/db/guardrails/GuardrailPageSizeInBytesTest.java
create mode 100644
test/unit/org/apache/cassandra/db/rows/ByteLimitComplexProofTest.java
create mode 100644
test/unit/org/apache/cassandra/db/rows/PagerBytesVerifyTest.java
create mode 100644
test/unit/org/apache/cassandra/db/rows/ReviewVerifyComplexLiveDataSizeTest.java
create mode 100644
test/unit/org/apache/cassandra/db/rows/Verify11745ComplexBytesTest.java
delete mode 100644 test/unit/org/apache/cassandra/service/QueryPagerTest.java
create mode 100644
test/unit/org/apache/cassandra/service/pager/AbstractPartitionsPagerTest.java
create mode 100644
test/unit/org/apache/cassandra/service/pager/AbstractQueryPagerTest.java
create mode 100644
test/unit/org/apache/cassandra/service/pager/AggregationPagerTest.java
create mode 100644
test/unit/org/apache/cassandra/service/pager/BytePagingExpiredLivenessTest.java
create mode 100644
test/unit/org/apache/cassandra/service/pager/BytePagingStaticColumnsTest.java
create mode 100644
test/unit/org/apache/cassandra/service/pager/MultiPartitionPagerTest.java
create mode 100644
test/unit/org/apache/cassandra/service/pager/PartitionRangePagerTest.java
create mode 100644
test/unit/org/apache/cassandra/service/pager/QueryPagerTest.java
create mode 100644
test/unit/org/apache/cassandra/service/pager/SinglePartitionPagerTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
