Uploaded image for project: 'Cassandra'
  1. Cassandra
  2. CASSANDRA-8910

Conditional update based on UDF

Agile BoardAttach filesAttach ScreenshotBulk Copy AttachmentsBulk Move AttachmentsAdd voteVotersWatch issueWatchersCreate sub-taskConvert to sub-taskMoveLinkCloneLabelsUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    Description

      Building on what is suggested by: CASSANDRA-8488

      It would be great if conditional updates could accept a UDF in the IF clause.

      Use Case:
      We are doing real-time in-memory aggregations across many machines. We want to update a value (e.g. a dimensional count), but we only want the update applied if that time bucket has not already been incorporated by another machine. (protecting against partitioning, replays, etc.)

      In this case, we want something like:
      UPDATE value=v, slices+="1123213222-30" IF not_contains(slices, 1123213222-30)

      Where "slices" is a column that contains all time slices, and 112313222-30 represents a slice of time (start time, plus interval).

      Attachments

        Issue Links

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            Unassigned Unassigned Assign to me
            boneill Brian ONeill

            Dates

              Created:
              Updated:

              Slack

                Issue deployment