streaming

0熱度

1回答

對不起，這個問題還不清楚，我是Hadoop研究中的新手。我再次編輯了問題。我在Python中編寫了兩個Hadoop MapReduce程序：map.py和red.py. 然後在HDFS上編寫run.sh來繼續使用Hadoop流的MapReduce。我需要在HDFS上讀取半年的數據，文件名爲：20170101-20170630。文件在HDFS路徑： /user/name/20161231

0熱度

1回答

消耗的數據字節數

與在下載視頻的情況下相比，在線觀看視頻時是否消耗了數據？注意：提供所有後臺應用程序不消耗任何數據。在此先感謝..！

-1熱度

1回答

異常在線程「主」org.apache.spark.sql.AnalysisException：

我想我的手在kafka火花結構化流，但得到一些異常，如異常在線程「主」「org.apache.spark.sql.AnalysisException ：無法解析'device'給定的輸入列：[value，offset，partition，key，timestamp，timestampType，topic]; 附上我的代碼 import org.apache.spark.sql._ import

0熱度

1回答

散景+燒瓶：多個AjaxDataSource調用

散景對象是一個顯示3條獨立線條的圖形。數據流式傳輸。 AjaxDataSource調用每5秒鐘從數據庫讀取最後一個數據。這是剝離下來類： class Graph: def __init__(self): data_source = AjaxDataSource(data=dict(date_time=[], value_1=[],

0熱度

2回答

如何在Android中創建廣播流

我嘗試在我的應用程序中集成廣播流，但它不起作用，我不知道爲什麼。這是我的網絡電臺的鏈接：https://www.radioking.com/widgets/player/player.php?id=480&c=%23f39c12&ii=&p=1&pp=1&i=1&eq=1&po=1&t=1&a=1&f=big 你能幫助我嗎？這是我的代碼： public class MainActivity e

0熱度

1回答

視頻流

就像我在標題中寫道：在服務器端我有這樣的方法： [OperationContract] Stream GetStream(); 它返回流，但是當我得到它在客戶端，它返回字節[]： public System.Threading.Tasks.Task<byte[]> GetStreamAsync() { return base.Channel.GetStreamAsync();

1熱度

1回答

我可以在SBE複合類型中添加可變長度成員嗎？

我有一個嵌套的數據結構，我試圖與SBE集成。其中一個嵌套對象有一個字符串成員。我如何定義嵌套類型的可變長度字段？我可能會重新設計我的對象佈局，但如果支持，我很好奇。

0熱度

1回答

編碼/解碼和使用可變緩衝區加密/解密的影響

我有一個程序，加密和解密數據使用對稱密鑰。在加密過程I：加密數據的Base64編碼它在解密期間： Base64編碼解碼它解密它工作正常的數據。現在我正試圖在流緩衝區上執行此過程。假設加密是通過上面提到的大部分數據的程序完成的，並且只有在流式傳輸時纔會進行解密。在這種情況下做的緩衝區大小/塊大小與我的編碼數據無論何時我解碼嗎？如果我在3000字節的緩衝區中編碼數據，我還應該讀取多達3

0熱度

1回答

你怎麼能得到從iPhone到服務器的快速視頻直播流？

我已經試過Wowza流引擎，但即使在較低的視頻質量還有3秒的延遲。有沒有什麼標準的方法來設置這個延遲最小？

0熱度

1回答

舊版瀏覽器的webRTC/canvas支持

我有一個個性化的動態畫布，我的意思是與人分享，但我知道該標籤在舊版瀏覽器中不受支持（IE < 9），所以我一直在考慮解決方法。我計劃讓服務器瀏覽畫布而不是個人，並通過webRTC共享標籤（畫布）內容的實時流。我已經成功地通過製作Chrome擴展程序和使用谷歌的tabCapture API捕捉選項卡的內容，並使用服務器的NodeJS上Socket.IO來建立WebRTC會話完成這一部分。現在我的