streaming

0熱度

1回答

我需要使用aws kinesis流& lambda來實現某種流解決方案。我添加了第一個用於添加數據流的lambda。第一個Lambda本身每10秒調用一次，並添加100個數據請求（每個1kb）流。我運行了兩個調用lambda的腳本實例。第二個lambda使用上面的流作爲觸發器。在小容量數據/間隔第二個lambda上同時獲取數據。但是，在上述的數據中，數據的準確性會降低（在+1小時流播後，速度會降

0熱度

1回答

Twitter的流API - Objective-C的

我與工作Twitter的REST /流式API。當我想訪問REST API時，我創建了一個NSMutableURLRequest（包含訪問令牌和查詢等參數）。然後，我使用請求與NSURLSession一起加載數據。我使用它爲我創建的可變請求對象庫（如果我不使用請求對象，那麼Twitter的API不會允許我訪問相關的用戶數據）。現在我想通過流API加載Twitter的時間表。我遇到的一個問題是，我

0熱度

1回答

HEVC平鋪中VR視頻的列數和行數

我聽說過「在HEVC平鋪中，所有列必須具有相同的行數」。也許它不是「必須」，而是「應該」。我只想知道哪些可靠的科學論文可以證實這些信息。如果有人知道，請給我發源。非常感謝！

0熱度

1回答

卡夫卡流字數統計應用程序

我玩的卡夫卡流API（Kakfa版本：0.10.2.0）試圖做一個簡單的wordcount示例工作：Wordcount App gist。我同時運行生產者和消費者的控制檯： ./kafka-console-producer.sh -topic input-topic --broker-list localhost:9092 ./kafka-console-consumer.sh --topic o

0熱度

1回答

如果消費多個主題，卡夫卡消費者是否處理相同的主題密鑰？

比方說，我有2個卡夫卡主題登錄和註銷通過用戶名並具有分區的相等數目的分割。如果我運行一個消費者組，消費兩個主題的兩個消費者，我可以確定每個用戶的登錄和註銷事件將由同一個消費者處理嗎？

2熱度

1回答

AVAssetResourceLoaderDelegate方法覆蓋loadingRequest

在播放解密的HLS視頻時，我使用GCDServer來主持m3u8文件，當我在m3u8文件中使用一組解密的塊時，它演奏的很好，但是當我使用解密的塊並嘗試解密密鑰大塊它不是在那裏玩。由於未使用http方案調用AVAssetResourceLoaderDelegate方法，並且如果使用自定義方案，則GCDServer完成加載。任何建議？我們可以重載加載請求回http嗎？如果是，那麼如何。如何從保存的

0熱度

2回答

flink 1.2下沉kafka流的錯誤

我所做的是讀取來自kafka的消息以json格式。例如。 {"a":1,"b":2} 然後我應用的濾波器此消息，以確保對應於a的值是1，b的值是2。最後，我想以輸出結果流至下游卡夫卡。但是，我不知道編譯器爲什麼說類型不匹配。我的代碼如下： val kafkaConsumer = new FlinkKafkaConsumer010( params.getRequired("input-topi

6熱度

1回答

卡夫卡流應用程序設計負責人

我想與卡夫卡一起深入處理流處理，我需要一些幫助，讓我的頭部圍繞一些目前不太清楚的設計原則。 1.）假設我有一些實時股價數據。你是否會用股票代碼來鎖定（並因此分割）一個主題「價格」？或者你會爲每個符號製作一個主題？例如，如果我決定生產（添加）一些更多的股票代碼，包括以後的完整歷史記錄，會發生什麼情況？現在我的歷史（在日誌中訂購）的主題「價格」是一團糟，對吧？另一方面，對於每個價格系列，我想要稍後計算

0熱度

1回答

在下沉kafka流時看不到消息，無法在flink 1.2中看到打印消息

我的目標是使用kafka讀取json格式的字符串，對字符串進行過濾，然後將消息下沉（仍在json字符串中格式）。出於測試目的，我的輸入字符串信息是這樣的： {"a":1,"b":2} 而且我實現的代碼是： def main(args: Array[String]): Unit = { // parse input arguments val params = ParameterTool

0熱度

1回答

如何在Flink 1.2中從Kafka中提取部分json格式的字符串

我的目標是使用kafka以json格式讀取字符串，對字符串進行過濾，選擇部分消息並下沉消息（仍以json字符串格式）。出於測試目的，我的輸入字符串信息是這樣的： {"a":1,"b":2，"c":"3"} 而且我實現的代碼是： def main(args: Array[String]): Unit = { val inputProperties = new Properties() i