google-cloud-bigtable

    2熱度

    1回答

    我使用JAVA API通過部分行鍵掃描Bigtable,向後和向前。此代碼的工作很好,但只能向前: Scan s = new Scan(); s.setReversed(true); s.setStartRow(rowKey); s.setStopRow(rowKeyEnd); ResultScanner scanner = tbl.getScanne

    0熱度

    1回答

    我需要從每個我的知識流媒體數據流job.As訪問Bigtable的在轉型的一個訪問Bigtable的最佳做法有兩種方式: 1),我們可以創建連接錯誤從doFn的startBundle方法到bigtable,並從processElement方法中的bigtable訪問數據。在這種方法中,每次新元素進入時,dataflow sdk都會創建與Bigtable的新連接。 2)在轉換obj創建時創建bigt

    1熱度

    2回答

    我正在嘗試使用HBase API連接到Google Cloud Bigtable實例。我正在使用Java 1.8。我跟着下面的教程: https://cloud.google.com/bigtable/docs/samples-java-hello https://cloud.google.com/bigtable/docs/using-maven 但由於某些原因,我無法連接到該Bigtable的

    0熱度

    2回答

    我正在研究從某些傳感器讀取數據的IOT應用程序,我需要將此數據填充到Google Cloud Bigtable實例中。我使用Java 1.8進行開發,我將使用HBase API進行Bigtable相關操作。 有人能讓我知道什麼是創建一個Bigtable實例的步驟,所以我可以從我的Java應用程序連接到它? 謝謝

    0熱度

    1回答

    我正在測試一個小的Bigtable集羣(最少3個節點)。我在Google控制檯上看到,隨着寫入QPS級別接近10K,CPU利用率接近推薦的最大值〜80%。 從我所瞭解的情況來看,QPS指標是針對整個實例的,而不是針對每個節點的?在這種情況下,爲什麼在技術上達到CPU閾值時,實例的QPS負載僅爲30K指導最大值的1/3?我只是想了解是否有數據上傳程序(通過Dataflow完成)。我也懷疑爲什麼我從來

    0熱度

    1回答

    我知道我們可以使用HBase API在BigTable上執行checkAndDelete。我想知道是否有一種方法可以提交checkAndDelete列表,這樣我就不需要一個接一個地執行了。我主要擔心非批處理的性能... 謝謝!

    1熱度

    1回答

    我在Dataflow中有一項工作,通過使用內置的Dataflow API將數據從Bigtable導入Bigquery。我有兩個問題: 問題1:如果源數據是在一個大表Bigtable中,我怎麼能它分爲BigQuery中的一組子或小表動態基礎上,也就是說,在給定只有在運行時才知道Bigtable行鍵? 在數據流中的Java代碼看起來是這樣的: p.apply(Read.from(CloudBigtab

    1熱度

    1回答

    我正在嘗試使用google-cloud-bigtable庫。我的意圖是查詢bigtable,其中響應應該只返回列名稱/限定符,但沒有值。 我試過不同的方法,像cells_per_row_limit_filter和block_all_filter,但他們似乎沒有做我想要的工作。 我不希望'行'被過濾;我只是不想在結果中使用單元格值。

    0熱度

    1回答

    我有一些工作代碼。它採用了BigtableConfiguration對象返回去Bigtable的連接,就像這樣: var connection = BigtableConfiguration.connect("myProject", "myCluster") 返回的連接爲com.google.cloud.bigtable.hbase.Connection類型。 我知道現在有一個用於本地的Big

    0熱度

    1回答

    我的團隊正在考慮導出/導入bigtable數據,但只是列族(不是全部)的一個子集用於解決技術問題。 這些文檔似乎暗示出口/進口只可能用於整個bigtable。 https://cloud.google.com/bigtable/docs/exporting-sequence-files https://cloud.google.com/bigtable/docs/importing-sequenc