Warum schreibt meine Apache Beam Dataflow-Pipeline nicht in BigQuery?

Beim Versuch, diese Pipeline auszuführen, erhalte ich diese Ausnahme:
Exception has occurred: AttributeError module 'apache_beam.io.gcp.internal.clients.bigquery' has no attribute 'TableReference'...

Ich benutze Google BigQuery für mein Projekt
Im Moment versuche ich, eine neue Zeile in BQ zu fügen, basierend auf diesem
private void insertRowsToBQ(MyCustomObject data) {
String datasetName =...

Ich versuche, dieses Beispiel für einen gemeinsamen Cache zu verstehen:
Ich habe diesen Zähler zum hinzugefügt init :
> self.cache_load_counter = Metrics.counter(self.__class__, 'cache_loads')

Und...

Ich habe zwei unbegrenzte Quellen (pubsub):

Hauptquelle: gibt häufig Werte aus
Sekundärquelle: sendet ein Ereignis, das uns anweist, eine große Abfragetabelle zu lesen, da eine Änderung in der...

Im neuesten Apache Beam 2.68.0 haben sie das Verhalten von Codern für nicht-primitive Objekte geändert. (Siehe das Änderungsprotokoll hier).
Daher erhalte ich eine Warnung wie diese auf GCP...