Resultados da pesquisa a pedido "stream"
Fluxos de Apache Kafka Materializar o KTables para um tópico parece lento
Estou usando o fluxo kafka e estou tentando materializar uma KTable em um tópico. Funciona, mas parece ser feito a cada 30 segundos ou mais. Como / quando o Kafka Stream decide materializar o estado atual de uma KTable em um tópico? Existe ...
Combine dois fluxos no Apache Flink, independentemente do tempo da janela
Eu tenho dois fluxos de dados que quero combinar. O problema é que um fluxo de dados tem uma frequência muito maior que o outro e há momentos em que um fluxo não está recebendo eventos. É possível usar o último evento de um fluxo e associá-lo ao ...
O fluxo FLV AAC pode ser reproduzido no Android
Estou tentando construir um rádio player e o cliente está fornecendo um fluxo que é um contêiner FLV com o áudio sendo AAC Quando leio os cabeçalhos, ele aparece como áudio / aacp. Eu tentei de todas as maneiras possíveis, como usar o 1) ...
Enviar e receber arquivos grandes através de fluxos no ASP.NET Web Api C #
Estou trabalhando em um projeto em que preciso enviar grandes arquivos de áudio por meio de fluxos de um cliente para um servidor. Estou usando o ASP.NET Web Api para se comunicar entre cliente e servidor. Meu cliente tem um método "SendFile" ...
Prática recomendada para transmitir dados em tempo real do Android para o Bluetooth
Eu tenho um aplicativo Android que grava dados em um bluetooth simblee. Abaixo do código que tenho: public void sendData(String data) { Utils.addLog(TAG,"sending data : " + data); if (mSerialCharacterstic == null) { Utils.addLog(TAG,"serial ...
Diferença entre fprintf, printf e sprintf?
Alguém pode explicar em inglês simples sobre as diferenças entreprintf, fprintfesprintf com exemplos? Em que fluxo está? Estou realmente confuso entre os três ao ler sobre "Manipulação de arquivos em C".
Fluxo de análise de regex do Python
Existe alguma maneira de usar a correspondência de regex em um fluxo em python? gostar reg = re.compile(r'\w+') reg.match(StringIO.StringIO('aa aaa aa'))E não quero fazer isso obtendo o valor de toda a string. Quero saber se há alguma maneira ...
Como ler inteiros elegantemente usando o fluxo C ++?
Eu tenho um arquivo cheio de linhas neste formato: 1 - 2: 3Eu quero carregar apenas números usando fluxos C ++. Qual é a maneira mais elegante de fazer isso? Eu só pensei em cin.get () e checikng cada caractere se é número ou não.
A leitura de objetos do fluxo legível causa a exceção TypeError
Estou tentando fazer o seguinte código funcionar: var stream = require('stream'); class MyReadable extends stream.Readable { constructor(options) { super(options); } _read(size) { this.push({a: 1}); } } var x = new MyReadable({objectMode: ...
Fluxos de arquivos C, anexando no início
Existe uma maneira simples de acrescentar algo no início de um arquivo de texto usando fluxos de arquivos? Porque a única maneira de pensar é carregar um arquivo em um buffer, escrever texto a acrescentar e depois escrever o buffer. Quero saber ...