   {:never (InsertRetryPolicy/neverRetry)
    :always (InsertRetryPolicy/alwaysRetry)
    :retry-transient (InsertRetryPolicy/retryTransientErrors)})
+
+(def write-method-enum
+  {:default BigQueryIO$Write$Method/DEFAULT
+   :load BigQueryIO$Write$Method/FILE_LOADS
+   :streaming BigQueryIO$Write$Method/STREAMING_INSERTS})
 
 (def write-bq-table-schema
   (merge

                                  :create-disposition
                                  create-disposition-enum
                                  (fn [transform enum] (.withCreateDisposition transform enum)))}
    :without-validation {:docstr "Disables validation until runtime."
                         :action (fn [transform without-validation]
                                   (if without-validation

   [org.apache.beam.sdk.io.gcp.bigquery
    BigQueryIO BigQueryIO$Read BigQueryIO$Write
    BigQueryIO$Write$WriteDisposition
    BigQueryIO$Write$CreateDisposition TableRowJsonCoder TableDestination InsertRetryPolicy
    BigQueryIO$Write$Method]
   [org.apache.beam.sdk.values PBegin PCollection]))

(defn read-bq-raw
