Поделиться через


FlinkJobProperties interface

Свойства задания flink.

Extends

Свойства

action

Строковое свойство, указывающее действие, выполняемое в задании Flink. Он может иметь одно из следующих значений перечисления:> NEW, UPDATE, STATELESS_UPDATE, STOP, START, CANCEL, SAVEPOINT, LIST_SAVEPOINT или DELETE.

actionResult

Результат действия задания. ПРИМЕЧАНИЕ. Это свойство не будет сериализовано. Его может заполнить только сервер.

args

Строковое свойство, представляющее дополнительные аргументы виртуальной машины Java для задания Flink. Это должно быть значение, разделенное пробелами.

entryClass

Строковое свойство, указывающее класс записи для задания Flink.

flinkConfiguration

Дополнительные свойства, используемые для настройки заданий Flink. Она позволяет пользователям задавать такие свойства, как параллелизм и jobSavePointDirectory. Он принимает дополнительные пары "ключ-значение" в качестве свойств, где ключи являются строками, а значения — строками.

jarName

Строковое свойство, представляющее имя JAR-файла задания.

jobId

Уникальный идентификатор для идентификации задания ПРИМЕЧАНИЕ. Это свойство не сериализуется. Его может заполнить только сервер.

jobJarDirectory

Строковое свойство, указывающее каталог, в котором находится JAR-файл задания.

jobName

Имя задания

jobOutput

Выходные данные задания. ПРИМЕЧАНИЕ. Это свойство не будет сериализовано. Его может заполнить только сервер.

jobType

Полиморфный дискриминатор, который указывает различные типы, которые могут быть у этого объекта.

lastSavePoint

Последняя точка сохранения. ПРИМЕЧАНИЕ. Это свойство не будет сериализовано. Его может заполнить только сервер.

runId

Идентификатор запуска задания

savePointName

Строковое свойство, представляющее имя точки сохранения для задания Flink.

status

Состояние задания. ПРИМЕЧАНИЕ. Это свойство не будет сериализовано. Его может заполнить только сервер.

Сведения о свойстве

action

Строковое свойство, указывающее действие, выполняемое в задании Flink. Он может иметь одно из следующих значений перечисления:> NEW, UPDATE, STATELESS_UPDATE, STOP, START, CANCEL, SAVEPOINT, LIST_SAVEPOINT или DELETE.

action?: string

Значение свойства

string

actionResult

Результат действия задания. ПРИМЕЧАНИЕ. Это свойство не будет сериализовано. Его может заполнить только сервер.

actionResult?: string

Значение свойства

string

args

Строковое свойство, представляющее дополнительные аргументы виртуальной машины Java для задания Flink. Это должно быть значение, разделенное пробелами.

args?: string

Значение свойства

string

entryClass

Строковое свойство, указывающее класс записи для задания Flink.

entryClass?: string

Значение свойства

string

flinkConfiguration

Дополнительные свойства, используемые для настройки заданий Flink. Она позволяет пользователям задавать такие свойства, как параллелизм и jobSavePointDirectory. Он принимает дополнительные пары "ключ-значение" в качестве свойств, где ключи являются строками, а значения — строками.

flinkConfiguration?: {[propertyName: string]: string}

Значение свойства

{[propertyName: string]: string}

jarName

Строковое свойство, представляющее имя JAR-файла задания.

jarName?: string

Значение свойства

string

jobId

Уникальный идентификатор для идентификации задания ПРИМЕЧАНИЕ. Это свойство не сериализуется. Его может заполнить только сервер.

jobId?: string

Значение свойства

string

jobJarDirectory

Строковое свойство, указывающее каталог, в котором находится JAR-файл задания.

jobJarDirectory?: string

Значение свойства

string

jobName

Имя задания

jobName?: string

Значение свойства

string

jobOutput

Выходные данные задания. ПРИМЕЧАНИЕ. Это свойство не будет сериализовано. Его может заполнить только сервер.

jobOutput?: string

Значение свойства

string

jobType

Полиморфный дискриминатор, который указывает различные типы, которые могут быть у этого объекта.

jobType: "FlinkJob"

Значение свойства

"FlinkJob"

lastSavePoint

Последняя точка сохранения. ПРИМЕЧАНИЕ. Это свойство не будет сериализовано. Его может заполнить только сервер.

lastSavePoint?: string

Значение свойства

string

runId

Идентификатор запуска задания

runId?: string

Значение свойства

string

savePointName

Строковое свойство, представляющее имя точки сохранения для задания Flink.

savePointName?: string

Значение свойства

string

status

Состояние задания. ПРИМЕЧАНИЕ. Это свойство не будет сериализовано. Его может заполнить только сервер.

status?: string

Значение свойства

string