Programação

9
Spark: UDF executado várias vezes

Eu tenho um quadro de dados com o seguinte código: def test(lat: Double, lon: Double) = { println(s"testing ${lat / lon}") Map("one" -> "one", "two" -> "two") } val testUDF = udf(test _) df.withColumn("test", testUDF(col("lat"), col("lon"))) .withColumn("test1", col("test.one"))...

9
dtypes sujam as coisas ao mudar no eixo um (colunas)

Considere o quadro de dados df df = pd.DataFrame(dict(A=[1, 2], B=['X', 'Y'])) df A B 0 1 X 1 2 Y Se eu mudar axis=0(o padrão) df.shift() A B 0 NaN NaN 1 1.0 X Empurra todas as linhas para baixo uma linha, conforme o esperado. Mas quando eu mudo axis=1 df.shift(axis=1) A B 0 NaN NaN 1...

9
GRPC: criar cliente de alto rendimento em Java / Scala

Eu tenho um serviço que transfere mensagens a uma taxa bastante alta. Atualmente, é atendido pelo akka-tcp e gera 3,5 milhões de mensagens por minuto. Decidi experimentar o grpc. Infelizmente, resultou em uma taxa de transferência muito menor: ~ 500 mil mensagens por minuto e até menos. Você...

9
Imprimindo séries matemáticas de forma concisa em Raku

Séries matemáticas, considere, por exemplo, a sequência consecutiva representada aqui como uma matriz: my @seq = my $a=0, {++$a} ... *; for @seq[^10].kv {state $f=0; ($^k < 4 or $^k > 7) ?? say "a$^k = " ~ $^v !! (say "..." if $f ne 1; $f=1) }; Impressões: a0 = 0 a1 = 1 a2 = 2 ... a8 =...

9
Hardware gráfico da Intel H264 A chamada MFT ProcessInput falha após alimentar algumas amostras de entrada, o mesmo funciona bem com o hardware Nvidia MFT

Estou capturando a área de trabalho usando a API DesktopDuplication e convertendo as amostras de RGBA para NV12 na GPU e alimentando o mesmo no hardware MediaFoundation H264 MFT. Isso funciona bem com gráficos Nvidia e também com codificadores de software, mas falha quando apenas o hardware gráfico...