Estou usando o Kafka Streams para agrupar e reduzir um tópico do Kafka.
Quero gerar uma saída para uma chave, se a chave e o valor forem iguais para todos os valores de uma determinada chave; caso contrário, não gere nada para essa chave.
Para fazer isso, no entanto, preciso acessar o key, e os .reducemétodos só dão acesso aos valores agregados/atuais.
É possível obter a chave ao chamar .reduce? Ou existe outra maneira de fazer isso?
Estou usando a imagem oficial do Oracle 23 Docker. Tenho uma grande quantidade de dados de teste que precisam ser executados no banco de dados para que estejam disponíveis para desenvolvedores que usam a imagem.
Eu sei que posso colocar os scripts .sql /docker-entrypoint-initdb.d/startupna imagem e eles serão executados automaticamente pelo SQL Plus na imagem.
O problema é que não quero ver:
db_1 | 1 row created.
db_1 |
db_1 |
db_1 | 1 row created.
db_1 |
db_1 |
db_1 | 1 row created.
db_1 |
db_1 |
db_1 | 1 row created.
db_1 |
db_1 |
db_1 | 1 row created.
db_1 |
db_1 |
db_1 | 1 row created.
db_1 |
db_1 |
(etc...)
db_1 | Commit complete.
Na saída do meu console. Prefiro ver algo como:
db_1 | 10,000 rows created.
db_1 |
db_1 |
db_1 | Commit complete.
Ou mesmo agrupar em grupos de 100 ou algo assim reduziria bastante a quantidade de produção.
Isso é possível?
Eu tentei usar INSERT ALL..., mas ainda imprime cada inserção individualmente.
O script final deve ser compatível com versões anteriores do 19c, se possível.