valencik
/ observe.html
Last active
March 1, 2023 01:40
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| <li class="indented0" name="fs2.Stream.InvariantOps#observe" group="Ungrouped" fullcomment="yes" data-isabs="false" visbl="pub"> | |
| <a id="observe(p:fs2.Pipe[F,O,Nothing])(implicitF:cats.effect.Concurrent[F]):fs2.Stream[F,O]" class="anchorToMember"></a><a id="observe(Pipe[F,O,Nothing])(Concurrent[F]):Stream[F,O]" class="anchorToMember"></a> | |
| <span class="permalink"> | |
| <a href="../fs2/Stream$$InvariantOps.html#observe(p:fs2.Pipe[F,O,Nothing])(implicitF:cats.effect.Concurrent[F]):fs2.Stream[F,O]" title="Permalink"><i class="material-icons"></i></a> | |
| </span> | |
| <span class="modifier_kind"><span class="modifier"></span> <span class="kind">def</span></span> | |
| <span class="symbol"> | |
| <span class="name">observe</span> | |
| <span class="params"> | |
| ( |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| //> using scala "2.13.10" | |
| //> using lib "org.apache.lucene:lucene-core:9.5.0" | |
| //> using lib "org.apache.lucene:lucene-analysis-common:9.5.0" | |
| //> using lib "org.apache.lucene:lucene-memory:9.5.0" | |
| //> using lib "org.apache.lucene:lucene-queryparser:9.5.0" | |
| import org.apache.lucene.analysis.standard.StandardAnalyzer | |
| import org.apache.lucene.index.memory.MemoryIndex | |
| import org.apache.lucene.queryparser.flexible.standard.StandardQueryParser |
valencik
/ JsonlPayloadPipe.scala
Created
July 9, 2024 20:19
Elasticsearch Bulk Indexing with a stream of JSON strings
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import cats.effect.IO | |
| import fs2.{Pipe, Pull, Stream} | |
| object JsonlPayloadPipe { | |
| /** Builds a pipe that transforms a stream of JSON strings into payloads for the Elasticsearch Bulk | |
| * API. Each input string represents a JSON document to be sent to the Bulk API. The JSONs are | |
| * gathered, interspersed with `delimiter`, and packaged into payload strings up to a maximum | |
| * size of `batchMax` bytes. | |
| * |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| <!DOCTYPE html> | |
| <html lang="en"> | |
| <head> | |
| <meta charset="UTF-8"> | |
| <meta name="viewport" content="width=device-width, initial-scale=1.0"> | |
| <title>28x28 Input Grid</title> | |
| <style> | |
| body { | |
| font-family: Arial, sans-serif; |
OlderNewer