Suchergebnisse für Anfrage "google-cloud-dataflow"
Duplikate über Fenster hinweg entfernen Trigger / Brände
Nehmen wir an, ich habe eine unbegrenzte Sammlung von Sätzen, die von userid eingegeben wurden, und ich möchte einen ständig aktualisierten Wert dafür, ob der Benutzer ärgerlich ist. Wir können berechnen, ob ein Benutzer ärgerlich ist, indem wir ...
Erkennen von Änderungen des Tastenzustands
Ich bin neu im Dataflow-Programmiermodell und habe Probleme, mich mit dem zu befassen, was meiner Meinung nach ein einfacher Anwendungsfall sein sollte: Ich habe eine Pipeline, die Live-Daten von Pub / Sub liest. Diese Daten enthalten ...
Wie kann man lösen, dass weder Jetty ALPN noch OpenSSL über netty-tcnative richtig konfiguriert wurden?
Ich versuche, einen Datenflussjob zu erstellen, um Zeilen in BigTable einzufügen. Beim lokalen Testen des Datenflussjobs wird jedoch die folgende Fehlermeldung angezeigt: Exception in thread ...
Wie lade ich Daten aus Google BigQuery in Google Cloud Bigtable?
Ich muss Daten in Google Cloud Bigtable einfügen und die Datenquelle ist Google BigQuery. ls Übung kann ichLesen Sie die Daten von ...
Lesen Sie mehrere .gz-Dateien und identifizieren Sie, welche Zeile zu welcher Datei gehört
Ich lese mehrere .gz-Dateien, die mit Google Data Flow verarbeitet werden sollen. Endziel der Daten ist BigQuery. Die BigQuery-Tabelle enthält dedizierte Spalten für jede Spalte in der CSV-Datei in der GZ-Datei. Es gibt eine zusätzliche Spalte in ...
Wie erhalte ich den maximalen Zeitstempel des aktuellen Schiebefensters?
Ich verwende ein gleitendes Zeitfenster mit X-Größe und Y-Periode. Um die Ausgabe jedes Fensters zu markieren, möchte ich den Zeitstempel des aktuellen Fensters von PCollection erhalten. PCollection<T> windowedInput = input ...