Как создать ClassTagна Яве

Question

Я пишу запрос spark-sql, который должен что-то транслировать.

Теперь у меня есть несколько подобных кодов. Неверный параметр универсального типа.

final Broadcast<Dataset<Row>> b = sparkSession.sparkContext().broadcast(
                sparkSession.sql("My SQL"),
                classTag(Dataset.class)
        );

Метод createTag:

private static <T> ClassTag<T> classTag(final Class<T> clazz) {
        return scala.reflect.ClassManifestFactory.fromClass(clazz);
}

Как создать код для компиляции?

Answer 1

Вам придется разыграть его в некотором роде ужасным образом:

classTag((Class<Dataset<Row>>) (Class<?>) Dataset.class)

К сожалению, я не знаю лучшего решения.