cassandra-alpakka

[justcoon]

Problem

Context with alpakka cassandra session
https://doc.akka.io/docs/alpakka/current/cassandra.html

Solution

added new module with CassandraAlpakkaContext

Notes

open problems:

• keyspace configuration
• Await in case of underlying CqlSession - used for UDT

Checklist

• Unit test all changes
• Update README.md if applicable
• Add [WIP] to the pull request title if it's work in progress
• Squash commits that aren't meaningful changes
• Run sbt scalariformFormat test:scalariformFormat to make sure that the source files are formatted

@getquill/maintainers

[deusaquilus]

Hey @justcoon. I think we should take out the batching implementation since it's just a sequence of individual actions (just change the function to fail and say it's not supported). At some point we are going to want to implement actual cassandra native-batching in all the contexts but I don't know what that's supposed to look like yet.
Let's get a build of this working and I can approve. Please let me know if you need anything from my end.

[justcoon]

@deusaquilus

I assume you mean CassandraAlpakkaContext.executeBatchAction

in general other CassandraContext-s got this function, so personally I think it will be better, if this context will also support that

if implementation of batching will be changed later, it will have to be changed also in other CassandraContext-s

[justcoon]

Hello @deusaquilus,

if I do

  def executeBatchAction(
    groups: List[BatchGroup]
  )(info: ExecutionInfo, dc: Runner)(implicit executionContext: ExecutionContext): Result[RunBatchActionResult] = {
    Future.failed(new UnsupportedOperationException("Batch action is not supported"))
  }

current tests (which was made in similar way, like in quill-cassandra module) will also fail

[info] PeopleCassandraSpec:
[info] io.getquill.context.cassandra.alpakka.PeopleCassandraSpec *** ABORTED ***
[info]   java.lang.UnsupportedOperationException: Batch action is not supported
[info]   at io.getquill.CassandraAlpakkaContext.executeBatchAction(CassandraAlpakkaContext.scala:90)
[info]   at io.getquill.context.cassandra.alpakka.PeopleCassandraSpec.beforeAll(PeopleCassandraSpec.scala:25)

of course, it is expected ..., (test will have to be also fixed with this change).

Please, can you confirm, that now you prefer to have the operation as unsupported? Or we will support that like in other CassandraContext-s.

Thank you

[deusaquilus]

Please, can you confirm, that now you prefer to have the operation as unsupported? Or we will support that like in other CassandraContext-s.

If the others already do that you can leave it. This looks complete.

[deusaquilus]

If the batching implementation is just sequencing a single operation I don't think it's worth implementing. I think Cassandra supports batching natively which we should try to use sometime in the future.

[deusaquilus]

Great to see that this supports UDTs!

[deusaquilus]

Thanks for the contribution @justcoon! Let me know if you're interested in also adding this into ProtoQuill.