Ayman Khalil

Add solution downsampling feature

7

This PR enables downsampling a solution to save on write time & disk space should the solution be written out to files. It uses local averaging over user defined averaging...

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version pulsar-client 2.10.2 ### Minimal reproduce step 1. Produce a POJO schema with `JSR310ConversionEnabled`...

A table with primary key only columns with cdc enabled, will results in errors in the connector. My initial guess is primary key only tables are not supported because we...

[Source][Utilization] Enable processing multiple C* in a single source instance

1

Today, the C* source connectors only allows 1:1 between tables and sinks. In order to increate the utilization of the underling resources associated with a single source instance (e.g. Memory...

[Improvement][Source]: Infuse the key values returned from the mutation keys instead of reading from DB

1

This performance improvement applies only to the JSON only format introduced here #79 #74 In AVRO and JSON Key Value schemas, the Key is populated based on the mutation key...

For logical types, the AVRO `schema.getLogicalType()` always returns null although the name of the logical type is populated. The NativeJsonConverter for now relies on the `schema.getName()` instead to select the...

While the CDC agent publish mutations to the dirty topic in Pulsar, the deployed C* source needs to query back Cassandra nodes for the converged record before publishing to the...

CNDB-8772 Add sensors for index access

3

Addresses: https://github.com/riptano/cndb/issues/8772 Added INDEX_BYTES & SEARCH_BYTES sensors tracking for SAI and Seconday Index.

Track internode msg bytes and counts

1

Draft PR on tracking internode message bytes and counts. More generic implementation (i.e. leveraging `InboundMessageHandlers` like [InternodeInboundMetrics](https://github.com/datastax/cassandra/blob/a062ff5f9f0d3221deaaaaf8fccbcd21e933e7cd/src/java/org/apache/cassandra/metrics/InternodeInboundMetrics.java#L50) have the following complications: * The work if we want to track internode...

CNDB-9192 Track Sensor WRITE_BYTES for Counter Mutation on leader replica

1

Addresses: https://github.com/riptano/cndb/issues/9192 Implementation notes: * The counter mutation on non-leader replica will be accommodated for out of the box because they translated into regular mutations (accounted for in `WRITE_BYTES` sensors)...