問題タブ [partition-by]

いくつかの一時テーブルを作成し、それらをデータベースに結合して、これに似たテーブルを作成しました。

私が達成したいのはこれです：

どうすればこれを達成できますか?

要件は、10 秒の時間間隔に基づいてテーブルのレコードをグループ化することです。与えられたテーブル

グループはこうあるべき

ランク 1 の場合、最小時間は 18:36:15 であり、これに基づいて、18:36:15 から 18:36:24 までのすべてのレコードがグループ内にある必要があります。

同じテーブルに GroupRank が必要です。したがって、dense_Rank() Over 句を使用したものになります。SQLでクエリを書くのを手伝ってくれる人はいますか?

工場のリストを含むテーブルがあります（工場IDと工場名）

ユーザーは、毎月、各工場の履歴テーブルにいくつかのデータをアップロードします。また、同じ月の既存の工場データも別のユーザーによって上書きされます。したがって、履歴テーブルは次のようになります。

ここで、各工場と毎月のレポートを生成する必要があります。これは最新のアップロード (誰がいつアップロードしたか) であり、アップロードがない場合は「アップロードなし」と表示されます。これは以下のようになります。

これを手に入れるのを手伝ってください。解析機能をつけてみました。しかし運がない。

ここで、パーティション化されたハイブ テーブルにデータ フレームを永続化しようとして、このばかげた例外が発生します。何度も調べましたが、間違いを見つけることができませんでした。

org.apache.spark.sql.AnalysisException: 指定されたパーティション列 (タイムスタンプ値) がテーブルのパーティション列と一致しません。() をパーティション列として使用してください。;

外部テーブルを作成するスクリプトは次のとおりです。

これはテーブル " events2 "のフォーマットされた記述の結果です。

これは、データが分割されてテーブルに格納されるコード行です。

アプリケーションの実行中に、以下を取得しています

指定されたパーティション列 (timestamp_val) がテーブルのパーティション列と一致しません。パーティション列として () を使用してください。

私は明らかなエラーを犯している可能性があります。賛成票で助けていただければ幸いです:)

顧客 ID と顧客支出を含む顧客データ セットがあります。顧客の送信に基づいて、顧客データセットを 3 つのグループ (高支出顧客、中支出顧客、低支出顧客) に分割する必要があります。RANK と Partitio by を使用してみましたが、グループの数を指定できませんでした(3)。Teradataでこれを行うことができる他の方法はありますか? 顧客が 9 人いる場合は、最初にすべての顧客を支出額で並べ替え、次にそれらを 3 つのグループに分けて、各グループに何人の顧客がいるかを数えます (3)。また、各グループで費やされた金額の最小値と最大値を決定します

たとえば、顧客 F、G、私は 9 ドルから 12 ドルの間で支出し、高い支出を下回っています。顧客 A、B、D は 4 ドルから 8 ドルの間で支出しており、支出は中程度です。顧客 C、E、H は 1 ドルから 3 ドルの間で支出しており、支出が少ない

出力は GROUP(1,2,3) になります。# Custs(3,3,3); Min_Spend($9,$4,$1); MAX_SPEND($12、$8、$3)