echauchot commented on a change in pull request #18544:
URL: https://github.com/apache/flink/pull/18544#discussion_r810092713
##########
File path:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
##########
@@ -206,6 +205,66 @@ protected Cluster buildCluster(Cluster.Builder builder) {
}
}
+ private static Class<? extends Pojo> annotatePojoWithTable(String
keyspace, String tableName) {
+ return new ByteBuddy()
+ .redefine(Pojo.class)
+ .name("org.apache.flink.streaming.connectors.cassandra.Pojo" +
tableName)
+ .annotateType(createTableAnnotation(keyspace, tableName))
+ .make()
+ .load(Pojo.class.getClassLoader())
+ .getLoaded();
+ }
+
+ @NotNull
+ private static Table createTableAnnotation(String keyspace, String
tableName) {
+ return new Table() {
+
+ @Override
+ public String keyspace() {
+ return keyspace;
+ }
+
+ @Override
+ public String name() {
+ return tableName;
+ }
+
+ @Override
+ public boolean caseSensitiveKeyspace() {
+ return false;
+ }
+
+ @Override
+ public boolean caseSensitiveTable() {
+ return false;
+ }
+
+ @Override
+ public String writeConsistency() {
+ return "";
+ }
+
+ @Override
+ public String readConsistency() {
+ return "";
+ }
+
+ @Override
+ public Class<? extends Annotation> annotationType() {
+ return Table.class;
+ }
+ };
+ }
+
+ @Test
Review comment:
+1
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
