stream-compaction

    1熱度

    3回答

    我已經在卡夫卡0.8.1.1中的server.properties文件中進行了更改,即添加了log.cleaner.enable=true,並在創建主題時啓用了cleanup.policy=compact。 現在,當我測試它時,我將以下消息(密鑰,消息)推送到主題。 偏移:1-(123,abc); 偏移量:2 - (234,def); 抵消:3 - (345,ghi); 偏移:4 - (123,改

    8熱度

    2回答

    我知道cassandra會合並sstables,row-keys,刪除墓碑等等。 但我真的很想知道它是如何執行壓實? 由於sstables是不可變的,它會將所有相關數據複製到新文件中嗎?並在寫入這個新文件時丟棄墓碑標記的數據。 我知道什麼壓實並而是想知道它是怎麼做到這一點(T)

    0熱度

    1回答

    我們有Cassandra-0.8.2集羣中的24個節點和複製因子2。其中一個節點是相當緩慢的,最sstables的這個節點上已損壞。(我們不能夠運行壓實,甚至不擦洗) 所以是有可能清理數據,緩存和commitlog目錄此節點並用bootstrap = true重新啓動?它有助於將所有的數據流返回到這個節點嗎? 如果有可能,是否有任何可能造成問題的地方?應該注意避免任何危險?

    1熱度

    1回答

    我正在尋找我的cuda程序的優化策略。在我內核的for循環內的每次迭代中,每個線程都會產生一個分數。我保持分數的共享優先級隊列以保持每塊的top-k。請參閱下面的僞代碼: __global__ gpuCompute(... arguments) { __shared__ myPriorityQueue[k]; //To maintain top k scores (k < #threa

    -1熱度

    1回答

    我正在製作一個將字符串發送到webservice(在C#中)的python「腳本」。我需要壓縮或壓縮這個字符串,因爲帶寬和MB數據是有限的(是的,因爲它的數量非常有限)。 我正在考慮將它轉換成文件,然後壓縮文件。但我正在尋找一種方法來直接壓縮字符串。 如何壓縮或壓縮字符串?

    6熱度

    1回答

    我正在嘗試用SIMD內在函數編寫流壓縮(取一個數組並刪除空元素)。循環的每次迭代一次處理8個元素(SIMD寬度)。 對於SSE內在函數,我可以使用_mm_shuffle_epi8()進行相當有效的操作,該函數執行16個條目表查找(收集並行計算術語)。 shuffle索引是預計算的,並用一個掩碼查找。 for (i = 0; i < n; i += 8) { v8n_Data = _mm