flink-sql

1Hitze

1Antwort

Apache Flink Tabelle 1.4: Externe SQL-Ausführung in Tabelle möglich?

ist es möglich, ein vorhandenes StreamTable extern abzufragen, ohne ein .jar hochzuladen, die Ausführungsumgebung zu erhalten und die Tabellenumgebung abzurufen? Ich hatte aufgrund der dynamischen (ko

0Hitze

1Antwort

Apache Flink: Wie man eine relationale Datenbank mit der Tabellen-API abfragt?

Der folgende Codeausschnitt wird aus diesem blog post genommen: val sensorTable = ??? // can be a CSV file, Kafka topic, database, or ... // register the table source tEnv.registerTableSource("sens

0Hitze

1Antwort

Flink 1.4 Spalte 'rowtime' in keiner Tabelle gefunden

Ich befolge die Dokumentation zu configure a TableSource with a rowtime attribute. Ich registrieren timestamp Feld als KafkaTableSource source = Kafka08JsonTableSource.builder()// set Kafka topic

0Hitze

1Antwort

Apache Flink: INFER Schema einer CSV-Datei wie Funken

In Funken wir schließen Schema Schema aus der Datei dynamisch lesen z.B .: df = sqlContext.read.format('com.databricks.spark.csv').options(delimiter='|',header='true', inferschema='true').load('cars.c

0Hitze

1Antwort

Apache Flink: LEFT JOIN mit einem TableFunction nicht erwartetes Ergebnis

Flink Version zurückgibt: 1.3.1 ich zwei Tabellen erstellt, ein aus dem Speicher, ein anderes ist von UDTF. Als ich Join und Left Join getestet habe, haben sie dasselbe Ergebnis zurückgegeben. Was ich