Add ScyllaDB connector

[ebyhr]

Fixes #10276

[findepi]

cc @haaawk

[ebyhr]

@robd003 Can you test this PR with your ScyllaDB cluster?

[robd003]

Yes! Traveling today but will push the testEnvironment for Scylla and test this PR.

[hashhar]

Looks good to me, mostly test changes and new tests.

[hashhar]

Which dependency does it get duplicated by?

[hashhar]

Please rebase.

[findinpath]

Is there any reason for keeping the following commits separate :

• Allow extending Cassandra connector test
• Restore Cassandra connector test

?

[ebyhr]

@findinpath To keep clean diff.

[findinpath]

I get locally while trying to run:

testing/bin/ptl test  run --environment multinode-scylla -- -t  io.trino.tests.product.scylla.TestScylla

the following exception:

2022-05-16 10:24:25 INFO: Using native clock for microsecond precision
tests               | java.lang.RuntimeException: error invoking methods annotated with io.trino.tempto.BeforeTestWithContext
tests               | 	at io.trino.tempto.internal.initialization.TestInitializationListener.invokeMethodsAnnotatedWith(TestInitializationListener.java:265)
tests               | 	at io.trino.tempto.internal.initialization.TestInitializationListener.runBeforeWithContextMethods(TestInitializationListener.java:243)
tests               | 	at io.trino.tempto.internal.initialization.TestInitializationListener.onTestStart(TestInitializationListener.java:200)
tests               | 	at org.testng.internal.Invoker.runTestListeners(Invoker.java:1724)
tests               | 	at org.testng.internal.Invoker.runTestListeners(Invoker.java:1699)
tests               | 	at org.testng.internal.Invoker.invokeMethod(Invoker.java:622)
tests               | 	at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:851)
tests               | 	at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:1177)
tests               | 	at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:129)
tests               | 	at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:112)
tests               | 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
tests               | 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
tests               | 	at java.base/java.lang.Thread.run(Thread.java:829)
tests               | Caused by: java.lang.reflect.InvocationTargetException
tests               | 	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
tests               | 	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
tests               | 	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
tests               | 	at java.base/java.lang.reflect.Method.invoke(Method.java:566)
tests               | 	at io.trino.tempto.internal.initialization.TestInitializationListener.invokeMethodsAnnotatedWith(TestInitializationListener.java:262)
tests               | 	... 12 more
tests               | Caused by: java.lang.IllegalStateException: Since you provided explicit contact points, the local DC must be explicitly set (see basic.load-balancing-policy.local-datacenter in the config, or set it programmatically with SessionBuilder.withLocalDatacenter). Current contact points are: Node(endPoint=scylla/172.19.0.2:9042, hostId=6dcdd0ad-5fac-403d-ac54-ae2c3b0d38e5, hashCode=39fb7c7f)=datacenter1. Current DCs in this cluster are: datacenter1

[ebyhr]

@robd003 Gentler reminder.

[ebyhr]

I will reopen if necessary.

[mkorolyov]

@ebyhr Hey sir, just wondering why this wonderful PR was closed? what could i do to merge scylladb connector?

[ebyhr]

I closed this PR as the requested contributor ghosted. I will reopen this PR if many people are interested in this connector.

[danielhe4rt]

Hey! Anything that we can do to make this PR merged? I work at ScyllaDB, maybe we can help you guys in some way to make it happen.

Cheers!

[ebyhr]

Reopened the PR in #18074