безопасные классы BigQuery типа scio - проблема с аннотациями - PullRequest
0 голосов
/ 15 мая 2018

Я пытаюсь использовать безопасные классы BigQuery. Я также установил intellij scio плагин . Но я получаю ошибку,

Ошибка: (37, 21) аргументы типа [RowElement] не соответствуют границам параметра типа метода typedBigQuery [T <: com.spotify.scio.bigquery.types.BigQueryType.HasAnnotation] sc.typedBigQueryRowElement </p>

Вот мой код scala:

def main(args: Array[String]): Unit = {

  @BigQueryType.fromQuery("select id, org, env from TABLE") 
  class RowElement

  val (sc: ScioContext, arg) = ContextAndArgs(args)
  sc.typedBigQuery[RowElement]("select id, org, env from TABLE")
    .saveAsTypedBigQuery("TABLE_DEST")
  sc.close()
}

1 Ответ

0 голосов
/ 21 сентября 2018

Все @BigQueryType аннотации должны быть на верхнем уровне object, чтобы избежать каких-либо проблем расширения макроса. Например:

object MyPipeline { @BigQueryType.fromQuery("...") class MyRecord }

...