snappydata

    1熱度

    1回答

    我無法提交僅執行System.out.println()的簡單作業。以下是我從SnappyData Lead獲得的錯誤。 snappy-job.sh submit --lead 10.0.18.66:8090 --app-name SimpleJobApp --class snappydata.jobs.SimpleJob --app-jar simpleJob.jar OKOK{ "statu

    3熱度

    2回答

    從snappy shell中使用kafka創建火花流式表時出現問題。 「異常 '無效輸入 'C',預期dmlOperation,插入,withIdentifier,選擇或放(行1,列1):' 參考:http://snappydatainc.github.io/snappydata/streamingWithSQL/#spark-streaming-overview 這是我的SQL : CREATE

    1熱度

    1回答

    我們需要在各種組件(服務器,定位器等)的快速配置文件中設置一些指令。 snappy_ec2腳本在創建所有配置並在羣集中保持同步方面做得很好,但我需要找到一個可用的方法來向自動生成的腳本添加指令。 使用此腳本的首選方法是什麼? 例如:添加下面的「服務器」文件: -gemfirexd.disable-GETALL本地指數=真 也許我應該添加這些字符串的文件,環境等 snappy-env.sh TIA

    0熱度

    1回答

    SnappyData V0.5連接到snappydata店 我的目標是開始從我的SnappyData一個「火花殼」安裝的/ bin目錄,併發出斯卡拉反對我SnappyData現有表的命令商店。 我和我的SnappyData商店,定位器和領導在同一主機上(並且是的,他們都在運行)。 要做到這一點,我在運行此命令按照這裏的文檔: Connecting to a Cluster with spark-s

    1熱度

    1回答

    我下面這個文件在snappydata配置日誌: http://snappydatainc.github.io/snappydata/configuration/#logging 當我改變的conf/log4j.properties.template爲 「log4j.properties」然後停止/啓動所有備份,我在ZNAO日誌中記錄snappylead.log。當我開始沒有配置log4j.prop

    1熱度

    1回答

    通過文檔閱讀刪除 - >http://snappydatainc.github.io/snappydata/rowAndColumnTables/#row-and-column-tables 我看,我們應該能夠執行DELETE FROM ....對行和列的表的SQL語句。嘗試從列表中刪除時,看到不一致的結果。 這裏是我的表: CREATE TABLE MY_TABLE_COL ( w_id

    1熱度

    1回答

    我正在閱讀文檔(http://snappydatainc.github.io/snappydata/streamingWithSQL/),並想知道在使用kafka時主題名稱後的參數「:01」是什麼意思。這是服務器正在使用的分區號或線程數? 即:「主題 'streamTopic:' val sc = new SparkContext(new SparkConf().setAppName("examp

    1熱度

    1回答

    我想通過JDBC API和Spring的NamedParameterJdbcTemplate對SnappyData行表執行UPDATE。 錯誤是: 引起:java.sql.SQLException中:(SQLSTATE = XCL14嚴重性= 20000)的列位置 '1' 超出範圍。此ResultSet的列數爲'0'。 at com.pivotal.gemfirexd.internal.share

    1熱度

    2回答

    桶的默認值是113.爲什麼?爲什麼不是110?桶邏輯是否在某個「可被整除」值時表現更好。 在SnappyData中有很多例子,使用更少的桶。這是爲什麼?確定使用比默認值113少的桶的邏輯是什麼? 選擇少的含義是什麼?怎麼樣更多桶?我在Spark SQL查詢中看到很多日誌記錄,在每個存儲桶中查找數據。查詢具有更多桶的性能會更差嗎?

    1熱度

    1回答

    我想收集時間序列數據並將其存儲在snappydata存儲中。我將收集數百萬行數據,並且希望跨時間片/範圍進行查詢。 下面是一個例子查詢我想做的事: select avg(value) from example_timeseries_table where time >= :startDate and time < :endDate; 所以,我想,我想有時間列PARTITION BY列,而不