Packages

ferricstore

0.10.1
0.11.4 0.11.3 0.11.2 0.11.1 0.11.0 0.10.3 0.10.2 0.10.1 0.10.0 0.9.1 0.9.0 0.8.0 0.7.5 0.7.4 0.7.3 0.7.2 0.7.1 0.7.0 0.6.0 0.5.7 0.5.6 0.5.5 0.5.4 0.5.3 0.5.2 0.5.1 0.5.0 0.4.3 0.4.2 0.4.1 0.4.0 0.3.7 0.3.6 0.3.5 0.3.4 0.3.3 0.3.2 0.3.1 0.2.0 0.1.0

FerricFlow durable workflows and queues with native-protocol storage, Raft durability, and Bitcask persistence.

HexDocs

Current section

Files

Jump to
Readme
40 Versions
10 Dependencies
Dependants
Files
Activity
ferricstore lib ferricstore flow query plan.ex
Raw

lib/ferricstore/flow/query/plan.ex 

defmodule Ferricstore.Flow.Query.Plan do

  @moduledoc false



  alias Ferricstore.Flow.Query.{CompositeRange, IndexDefinition, MandatoryScope}

  alias Ferricstore.Flow.Query.Budget



  @derive {Inspect,

           only: [

             :version,

             :path,

             :index_id,

             :index_version,

             :deduplicate,

             :order,

             :estimate,

             :stats,

             :fallback_reason,

             :query_fingerprint

           ]}

  @enforce_keys [

    :path,

    :ranges,

    :order,

    :residual_predicates,

    :recheck_predicates,

    :estimate,

    :stats,

    :budget,

    :fallback_reason,

    :query_fingerprint,

    :mandatory_scope

  ]

  defstruct version: 1,

            path: nil,

            index_id: nil,

            index_version: nil,

            index_build_id: nil,

            definition: nil,

            ranges: [],

            deduplicate: true,

            order: :none,

            residual_predicates: [],

            recheck_predicates: [],

            constraint_shapes: [],

            estimate: %{},

            stats: %{},

            budget: nil,

            fallback_reason: :none,

            query_fingerprint: nil,

            mandatory_scope: nil,

            alternatives: [],

            statistics_probes: []



  @type path ::

          :primary_key

          | :history

          | :lineage

          | :counter_lookup

          | :count_scan

          | :empty

          | :fixed_index

          | :ordered_range

          | :ordered_range_union

          | :ordered_filter

          | :reject

  @type t :: %__MODULE__{

          version: 1,

          path: path(),

          index_id: binary() | nil,

          index_version: pos_integer() | nil,

          index_build_id: binary() | nil,

          definition: IndexDefinition.t() | nil,

          ranges: [CompositeRange.t()],

          deduplicate: boolean(),

          order: :none | :native | :bounded_top_k,

          residual_predicates: [term()],

          recheck_predicates: [term()],

          constraint_shapes: [map()],

          estimate: map(),

          stats: map(),

          budget: Budget.t(),

          fallback_reason: atom(),

          query_fingerprint: binary(),

          mandatory_scope: MandatoryScope.t(),

          alternatives: [map()],

          statistics_probes: [

            %{

              definition: IndexDefinition.t(),

              equality_values: [term()],

              range: CompositeRange.t(),

              scope_prefix: [term()],

              physical_partition_key: binary(),

              statistics_key: binary(),

              scope_digest: <<_::256>>,

              prefix_digest: <<_::256>>

            }

          ]

        }

end