---
metadata:
- name: generator
content: Diplodoc Platform v5.50.6
alternate:
- https://ytsaurus.tech/docs/en/flow/java/state-accessor.md
- https://ytsaurus.tech/docs/ru/flow/java/state-accessor.md
---
> **Documentation Index:** Fetch the complete configuration index at https://ytsaurus.tech/docs/ru/llms.txt
# StateAccessor в YTsaurus Flow (Java)
StateAccessor — интерфейс для чтения, модификации и удаления значений [стейта](https://ytsaurus.tech/docs/ru/flow/concepts/glossary.md#state).
Общие сведения о stateful-обработке описаны в разделе [Stateful processing](https://ytsaurus.tech/docs/ru/flow/concepts/stateful.md).
## Принцип работы {#how-it-works}
[Стейт](https://ytsaurus.tech/docs/ru/flow/concepts/glossary.md#state) во Flow хранится в [сортированных динамических таблицах](https://ytsaurus.tech/docs/ru/user-guide/dynamic-tables/sorted-dynamic-tables.md).
В случае [внешнего стейта](https://ytsaurus.tech/docs/ru/flow/java/external-state.md) эта таблица создаётся пользователем, в случае [внутреннего стейта](https://ytsaurus.tech/docs/ru/flow/java/internal-state.md) эти таблицы создаются и управляются Flow автоматически.
Далее для простоты описания будем рассматривать пример внешнего стейта.
Каждую строку в таблице стейта можно условно разделить на ключевые колонки и колонки значений:
Для `TTransformCompanionComputation` ключевые колонки в таблице стейта совпадают с `group_by_schema` [компьютейшена](https://ytsaurus.tech/docs/ru/flow/concepts/glossary.md#stream-and-computation). Для внутреннего стейта `TTransformOrderedSourceCompanionComputation` ключом служит ключ партиции источника: `group_by_schema` в таком SourceComputation не поддерживается.
Колонки значений будут доступны для чтения и модификации через `StateAccessor`. Формат, в котором эти значения будут доступны для чтения и модификации в Java-коде, зависит от реализации `StateAccessor`.
## Чтение и запись данных {#reading-and-writing-data}
Непосредственную работу с таблицей (чтение, запись, удаление данных) осуществляет [воркер](https://ytsaurus.tech/docs/ru/flow/concepts/glossary.md#worker). При получении очередного батча [сообщений](https://ytsaurus.tech/docs/ru/flow/concepts/glossary.md#message) воркер загружает значения стейтов для всех [ключей](https://ytsaurus.tech/docs/ru/flow/concepts/glossary.md#key) в батче и отправляет их в [компаньон](https://ytsaurus.tech/docs/ru/flow/concepts/companion.md) вместе с сообщениями и [таймерами](https://ytsaurus.tech/docs/ru/flow/concepts/glossary.md#timer). Подробнее про [схему взаимодействия](https://ytsaurus.tech/docs/ru/flow/concepts/companion.md#schema).
Запись новых значений в таблицу стейта осуществляется транзакционно в рамках [эпохи](https://ytsaurus.tech/docs/ru/flow/concepts/glossary.md#epoch).
## Интерфейс StateAccessor {#state-accessor-interface}
{% list tabs group=lang %}
- Java
```java
public interface StateAccessor {
/** Получить значение стейта. */
@Nullable
T get();
/** Получить значение стейта или дефолтное значение. */
default T getOrDefault(T defaultValue);
/** Установить значение стейта. */
void set(T value);
/** Очистить/удалить стейт для ключа. */
void clear();
/** Получить класс стейта. */
Class getStateClass();
/** Получить read-only представление аксессора. */
default StateAccessor readOnly();
}
```
- Kotlin
```kotlin
interface StateAccessor {
/** Получить значение стейта. */
fun get(): T?
/** Получить значение стейта или дефолтное значение. */
fun getOrDefault(defaultValue: T): T
/** Установить значение стейта. */
fun set(value: T)
/** Очистить/удалить стейт для ключа. */
fun clear()
/** Получить класс стейта. */
fun getStateClass(): Class
/** Получить read-only представление аксессора. */
fun readOnly(): StateAccessor
}
```
{% endlist %}
Значение внутреннего стейта, полученное через `get()` и `getOrDefault()`, живое: изменения, сделанные в нём, записываются без вызова `set()`, а `readOnly()` возвращает неотслеживаемое представление — см. [Изменение значения на месте](https://ytsaurus.tech/docs/ru/flow/java/internal-state.md#in-place). Дефолт, который вернул `getOrDefault()`, в YTsaurus не записывается: он становится значением стейта, только если вычисление его изменит.