Re: How to identify inserts/deletes/updates from CDC data
Your questions seem more appropriate for the user list because you are trying
to solve for use cases.
On Feb 11, 2019, 6:48 AM -0500, Sreenivasulu Nallapati
, wrote:
> Hi,
> I am parsing the commit log files and I could not able to segregate the
> inserts/deletes/updates from the mutations. Is there any way that we can
> identify the event that is executed from commit logs?
>
> Here is the partial code:
>
> public class CustomCommitLogReadHandler implements CommitLogReadHandler {
>
> private static final Logger LOGGER =
> LoggerFactory.getLogger(CustomCommitLogReadHandler.class);
>
> private final String keyspace;
> private final String table;
>
> public CustomCommitLogReadHandler(Map configuration) {
> keyspace = (String) YamlUtils.select(configuration,
> "cassandra.keyspace");
> table = (String) YamlUtils.select(configuration, "cassandra.table");
> }
>
> @Override
> public void handleMutation(Mutation mutation, int size, int
> entryLocation, CommitLogDescriptor descriptor) {
> LOGGER.debug("Handle mutation started...");
> for (PartitionUpdate partitionUpdate :
> mutation.getPartitionUpdates()) {
> process(partitionUpdate);
> }
> LOGGER.debug("Handle mutation finished...");
> }
>
> @SuppressWarnings("unchecked")
> private void process(Partition partition) {
> LOGGER.debug("Process method started...");
> if (!partition.metadata().ksName.equals(keyspace)) {
> LOGGER.debug("Keyspace should be '{}' but is '{}'.", keyspace,
> partition.metadata().ksName);
> return;
> }
> if (!partition.metadata().cfName.equals(table)) {
> LOGGER.debug("Table should be '{} but is '{}'.", table,
> partition.metadata().cfName);
> return;
> }
> String key = getKey(partition);
> JSONObject obj = new JSONObject();
>
>
> Thanks
> Sreeni
Re: Capturing all events from a given timestamp
If you streamed CDC into Cassandra via something like Kafka Connect, then yes. On Feb 10, 2019, 7:00 PM -0500, Sreenivasulu Nallapati , wrote: > Hi, > > I have a requirement to be capture any changes to tables, inserts deletes > or updates from a given timestamp. > However, with CDC enabled, I want to know if there is yet a way to read the > data inserts,updates or deletes to a table through CQL. I want to know if > it is possible to read the changes using CQL. If yes, how? > > > Please advise. > > Thanks. > Sreeni
Re: JIRA Workflow Proposals
On 2018/11/26 13:39:50, Benedict Elliott Smith wrote: > We’ve concluded our efforts to produce a proposal for changes to the JIRA workflow, and they can be found here: https://cwiki.apache.org/confluence/display/CASSANDRA/JIRA+Workflow+Proposals < https://cwiki.apache.org/confluence/display/CASSANDRA/JIRA+Workflow+Proposals>> > > I hope there will be broad consensus, but I’m sure it won’t be plain sailing. It would be great to get a discussion going around the proposal, so please take some time to read and respond if you think you’ll have a strong opinion on this topic.> > > There remains an undecided question in our initial proposal, that is highlighted in the wiki. Specifically, there was no seemingly objective winner for the suggested changes to Component (though I have a preference, that I will express in the ensuing discussion).> > > Other contentious issues may be:> > - The removal of ‘labels’ - which is very noisy, the vast majority of which provide no value, and we expect can be superseded by other suggestions> > - The introduction of required fields for certain transitions, some of which are new (complexity, severity, bug/feature category)> > - The introduction of some new transitions (Triage, Review in Progress, Change Requested)> > > Look forward to hearing your thoughts!>
