View Source ElasticsearchEx.Streamer (Elasticsearch_ex v1.8.3)
Provides an utility to generate an Elixir Stream
from an Elasticsearch search.
Summary
Types
@type index() :: ElasticsearchEx.index()
@type opts() :: ElasticsearchEx.opts()
@type query() :: ElasticsearchEx.query()
Functions
@spec stream(query()) :: Enumerable.t()
@spec stream(query(), index()) :: Enumerable.t()
@spec stream(query(), opts()) :: Enumerable.t()
@spec stream(query(), nil | index(), opts()) :: Enumerable.t()
Runs an Elasticsearch by returning a Stream
which is perfect for browsing large volume of data.
Examples
iex> ElasticsearchEx.Stream.stream(
...> %{query: %{match_all: %{}}, sort: [%{message: :desc}], size: 500},
...> :my_index,
...> keep_alive: "30s"
...> )
#Function<52.124013645/2 in Stream.resource/3>