Индексы

db = RxConnector(
    "cproto://127.0.0.1:6534/testdb",
    enable_compression=True,
    fetch_amount=500
)
index_definitions = [
    {
        "name": "id",
        "json_paths": ["id"],
        "field_type": "int",
        'is_pk': True,
    },
    {
        "name": "name",
        "json_paths": ["name"],
        "field_type": "string",
    },
    {
        "name": "articles",
        "json_paths": ["articles"],
        "field_type": "int",
        "is_array": True,
    },
    {
        "name": "year",
        "json_paths": ["year"],
        "field_type": "int",
        "index_type": "tree",
    },
]

db.namespace_open("items")

for index in index_definitions:
    db.index_add("items", index)

import java.util.List;
import ru.rt.restream.reindexer.NamespaceOptions;
import ru.rt.restream.reindexer.annotations.Reindex;
import static ru.rt.restream.reindexer.IndexType.TREE;


// Объявление структуры с индексными полями
public static class Item {
    // Поле 'id' — первичный ключ
    // Если для индекcа не указан тип, type = HASH
    @Reindex(name = "id", isPrimaryKey = true)
    private Integer id;

    // Текстовое индексное поле.
    @Reindex(name = "name")
    private String name;

    // Массив 'articles' — множество записей (документов, статей) в составе индекса
    @Reindex(name = "articles")
    private List<Integer> articles;

    // Добавление сортируемого индекса по полю 'year'
    @Reindex(name = "year", type = TREE)
    private Integer year;

    public Item() {
    }

    public Item(Integer id, String name, List<Integer> articles, Integer year) {
        this.id = id;
        this.name = name;
        this.articles = articles;
        this.year = year;
    }

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public List<Integer> getArticles() {
        return articles;
    }

    public void setArticles(List<Integer> articles) {
        this.articles = articles;
    }

    public Integer getYear() {
        return year;
    }

    public void setYear(Integer year) {
        this.year = year;
    }

    @Override
    public String toString() {
        return "Item{" +
                "id=" + id +
                ", name='" + name + '\'' +
                ", articles=" + articles +
                ", year=" + year +
                '}';
    }
}

// Подключение к базе данных
Reindexer db = ReindexerConfiguration.builder()
    .url("builtin:///tmp/reindex/testdb")
    .getReindexer();

// Создание нового неймспейса
Namespace<Item> itemNamespace = db.openNamespace(
    "items",
    NamespaceOptions.defaultOptions(),
    Item.class
);

curl --location --request POST 'http://127.0.0.1:9088/api/v1/db/testdb/namespaces/items/indexes' \
--header 'Content-Type: application/json' \
--data-raw '{
  "name": "id3",
  "json_paths": [
    "id3"
  ],
  "field_type": "string",
  "index_type": "hash",
  "expire_after": 0,
  "is_pk": false,
  "is_array": false,
  "is_dense": false,
  "is_sparse": false,
  "rtree_type": "linear",
  "is_simple_tag": false,
  "collate_mode": "none",
  "sort_order_letters": "",
  "config": {
    "enable_translit": true,
    "enable_numbers_search": false,
    "enable_warmup_on_ns_copy": false,
    "enable_kb_layout": true,
    "log_level": 0,
    "merge_limit": 20000,
    "extra_word_symbols": "-/+",
    "stop_words": [
      "string"
    ],
    "stemmers": [
      "en",
      "ru"
    ],
    "synonyms": [
      {
        "tokens": [
          "string"
        ],
        "alternatives": [
          "string"
        ]
      }
    ],
    "terms_boost": [
      {
        "terms": [
          "string"
        ],
        "boost": 1
      }
    ],    
    "bm25_boost": 1,
    "bm25_weight": 0.1,
    "distance_boost": 1,
    "distance_weight": 0.5,
    "term_len_boost": 1,
    "term_len_weight": 0.3,
    "position_boost": 1,
    "position_weight": 0.1,
    "full_match_boost": 1.1,
    "partial_match_decrease": 15,
    "min_relevancy": 0.05,
    "max_typos": 2,
    "max_typo_len": 15,
    "max_rebuild_steps": 50,
    "max_step_size": 4000,
    "sum_ranks_by_fields_ratio": 0,
    "fields": [
      {
        "field_name": "string",
        "bm25_boost": 1,
        "bm25_weight": 0.1,
        "term_len_boost": 1,
        "term_len_weight": 0.3,
        "position_boost": 1,
        "position_weight": 0.1
      }
    ]
  }
}'

db.index_update(
    "items",
    {
        "name": "year",
        "json_paths": ["Date_year"],
        "index_type": "tree",
        "field_type": "int",
    }
)

curl --location --request PUT 'http://127.0.0.1:9088/api/v1/db/testdb/namespaces/items3/indexes' \
--header 'Content-Type: text/plain' \
--data-raw '{
  "name": "id",
  "json_paths": [
    "New_id"
  ],
  "field_type": "int64",
  "index_type": "tree",
  "expire_after": 0,
  "is_pk": false,
  "is_array": false,
  "is_dense": false,
  "is_sparse": false,
  "rtree_type": "linear",
  "is_simple_tag": false,
  "collate_mode": "none",
  "sort_order_letters": "",
  "config": {
    "enable_translit": true,
    "enable_numbers_search": false,
    "enable_warmup_on_ns_copy": false,
    "enable_kb_layout": true,
    "log_level": 0,
    "merge_limit": 20000,
    "extra_word_symbols": "-/+",
    "stop_words": [
      "string"
    ],
    "stemmers": [
      "en",
      "ru"
    ],
    "synonyms": [
      {
        "tokens": [
          "string"
        ],
        "alternatives": [
          "string"
        ]
      }
    ],
    "terms_boost": [
      {
        "terms": [
          "string"
        ],
        "boost": 1
      }
    ],
    "bm25_boost": 1,
    "bm25_weight": 0.1,
    "distance_boost": 1,
    "distance_weight": 0.5,
    "term_len_boost": 1,
    "term_len_weight": 0.3,
    "position_boost": 1,
    "position_weight": 0.1,
    "full_match_boost": 1.1,
    "partial_match_decrease": 15,
    "min_relevancy": 0.05,
    "max_typos": 2,
    "max_typo_len": 15,
    "max_rebuild_steps": 50,
    "max_step_size": 4000,
    "sum_ranks_by_fields_ratio": 0,
    "fields": [
      {
        "field_name": "string",
        "bm25_boost": 1,
        "bm25_weight": 0.1,
        "term_len_boost": 1,
        "term_len_weight": 0.3,
        "position_boost": 1,
        "position_weight": 0.1
      }
    ]
  }
}'

db.index_drop("items", "articles")

db.dropIndex("items", "articles");

curl --location --request DELETE 'http://127.0.0.1:9088/api/v1/db/dbtest/namespaces/items/indexes/year'

{
  "title": "complex_item",
  "type": "object",
  "properties": {
    "id": {
      "type": "integer"
    },
    "actor": {
      "type": "array",
      "items": {
        "type": "object",
        "properties": {
          "actor_name": {
            "type": "string"
          },
          "age": {
            "type": "integer"
          }
        }
      }
    },
    "another_actor": {
      "type": "object",
      "properties": {
        "actor_name": {
          "type": "string"
        },
        "age": {
          "type": "integer"
        }
      }
    }
  }
}

nested_index_definitions = [
    {
        "name": "id",
        "json_paths": ["id"],
        "field_type": "int64",
        "is_pk": True
    },
    # Индексные поля из actor ("name" and "age") добавляются в виде отдельных индексов-массивов ("is_array": True)
    {
        "name": "actor.name",
        "json_paths": ["actor.name"],
        "field_type": "string",
        "is_array": True
    },
    {
        "name": "actor.age",
        "json_paths": ["actor.age"],
        "field_type": "int",
        "is_array": True
    },
    # Индексные поля из another_actor добавляются с префиском "another_actor."
    {
        "name": "another_actor.name",
        "json_paths": ["another_actor.name"],
        "field_type": "string"
    },
    {
        "name": "another_actor.age",
        "json_paths": ["another_actor.age"],
        "field_type": "int"
    }
]

// Индексные поля из BaseItem будут добавлены в текущую структуру
public static class BaseItem {
    @Reindex(name = "id", isPrimaryKey = true)
    private Long id;

    public Long getId() {
        return id;
    }

    public void setId(Long id) {
        this.id = id;
    }
}

// Индексные поля из Actor ("name" and "age") будут добавлены в текущую структуру в виде отдельных индексов-массивов
public class Actor {
    @Reindex(name = "actor_name")
    private String name;

    @Reindex(name = "age")
    private Integer age;

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Integer getAge() {
        return age;
    }

    public void setAge(Integer age) {
        this.age = age;
    }
}

public static class ComplexItem extends BaseItem {
    @Reindex(name = "actor")
    private List<Actor> actor;

    // Hash-индекс для поля "name"
    @Reindex(name = "name")
    private String name;

    // Tree-индекс для поля "year"
    @Reindex(name = "year", type = TREE)
    private Integer year;

    // Колоночный индекс для поля "value"
    @Reindex(name = "value", isSparse = true, isNoColumn = true)
    private Integer value;

    // Содержимое поля MetaInfo НЕ будет
    private Integer metainfo;

    // Индексные поля из Parent НЕ будут добавлены в текущую структуру. Содержимое полей Parent попадёт в reindexer в виде неиндексируемых
    @Reindex(name = "-")
    private Item parent;

    // Индексные поля и любые данные из ParentHidden НЕ попадут в reindexer
    private Item parentHidden;

    // Индексные поля и любые данные из ParentHidden НЕ попадут в reindexer (поведение аналогично тегу `json:"-"`)
    private Item privateParent;

    // Индексные поля AnotherActor будут добавлены в текущую структуру с префиском "actor." (в этом конкретном примере это приведёт к добавлению двух индексов: "actor.actor_name" и "actor.age")
    @Reindex(name = "actor")
    private Actor anotherActor;

    public List<Actor> getActor() {
        return actor;
    }

    public void setActor(List<Actor> actor) {
        this.actor = actor;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Integer getYear() {
        return year;
    }

    public void setYear(Integer year) {
        this.year = year;
    }

    public Integer getValue() {
        return value;
    }

    public void setValue(Integer value) {
        this.value = value;
    }

    public Integer getMetainfo() {
        return metainfo;
    }

    public void setMetainfo(Integer metainfo) {
        this.metainfo = metainfo;
    }

    public Item getParent() {
        return parent;
    }

    public void setParent(Item parent) {
        this.parent = parent;
    }

    public Item getParentHidden() {
        return parentHidden;
    }

    public void setParentHidden(Item parentHidden) {
        this.parentHidden = parentHidden;
    }

    public Item getPrivateParent() {
        return privateParent;
    }

    public void setPrivateParent(Item privateParent) {
        this.privateParent = privateParent;
    }

    public Actor getAnotherActor() {
        return anotherActor;
    }

    public void setAnotherActor(Actor anotherActor) {
        this.anotherActor = anotherActor;
    }

    @Override
    public String toString() {
        return "ComplexItem{" +
                "id=" + getId() +
                ", actor=" + actor +
                ", name='" + name + '\'' +
                ", year=" + year +
                ", value=" + value +
                ", metainfo=" + metainfo +
                ", parent=" + parent +
                ", parentHidden=" + parentHidden +
                ", privateParent=" + privateParent +
                ", anotherActor=" + anotherActor +
                '}';
    }
}