Udostępnij za pośrednictwem


FlinkJobProperties interface

Właściwości zadania migania.

Extends

Właściwości

action

Właściwość ciągu wskazująca akcję do wykonania w zadaniu Flink. Może mieć jedną z następujących wartości wyliczenia => NEW, UPDATE, STATELESS_UPDATE, STOP, START, CANCEL, SAVEPOINT, LIST_SAVEPOINT lub DELETE.

actionResult

Wynik akcji zadania. UWAGA: Ta właściwość nie zostanie serializowana. Można go wypełnić tylko przez serwer.

args

Właściwość ciągu reprezentująca dodatkowe argumenty JVM dla zadania Flink. Powinna to być przestrzeń rozdzielona wartością.

entryClass

Właściwość ciągu określająca klasę wpisu zadania Flink.

flinkConfiguration

Dodatkowe właściwości używane do konfigurowania zadań Flink. Umożliwia użytkownikom ustawianie właściwości, takich jak równoległość i jobSavePointDirectory. Akceptuje ona dodatkowe pary klucz-wartość jako właściwości, gdzie klucze są ciągami, a wartości są również ciągami.

jarName

Właściwość ciągu reprezentująca nazwę pliku JAR zadania.

jobId

Unikatowy identyfikator identyfikacji zadania UWAGA: ta właściwość nie zostanie serializowana. Można go wypełnić tylko przez serwer.

jobJarDirectory

Właściwość ciągu określająca katalog, w którym znajduje się plik JAR zadania.

jobName

Nazwa zadania

jobOutput

Dane wyjściowe zadania. UWAGA: Ta właściwość nie zostanie serializowana. Można go wypełnić tylko przez serwer.

jobType

Dyskryminator polimorficzny, który określa różne typy, które mogą być tym obiektem

lastSavePoint

Ostatni punkt zapisu. UWAGA: Ta właściwość nie zostanie serializowana. Można go wypełnić tylko przez serwer.

runId

Identyfikator uruchomienia zadania

savePointName

Właściwość ciągu reprezentująca nazwę punktu zapisywania dla zadania Flink

status

Stan zadania. UWAGA: Ta właściwość nie zostanie serializowana. Można go wypełnić tylko przez serwer.

Szczegóły właściwości

action

Właściwość ciągu wskazująca akcję do wykonania w zadaniu Flink. Może mieć jedną z następujących wartości wyliczenia => NEW, UPDATE, STATELESS_UPDATE, STOP, START, CANCEL, SAVEPOINT, LIST_SAVEPOINT lub DELETE.

action?: string

Wartość właściwości

string

actionResult

Wynik akcji zadania. UWAGA: Ta właściwość nie zostanie serializowana. Można go wypełnić tylko przez serwer.

actionResult?: string

Wartość właściwości

string

args

Właściwość ciągu reprezentująca dodatkowe argumenty JVM dla zadania Flink. Powinna to być przestrzeń rozdzielona wartością.

args?: string

Wartość właściwości

string

entryClass

Właściwość ciągu określająca klasę wpisu zadania Flink.

entryClass?: string

Wartość właściwości

string

flinkConfiguration

Dodatkowe właściwości używane do konfigurowania zadań Flink. Umożliwia użytkownikom ustawianie właściwości, takich jak równoległość i jobSavePointDirectory. Akceptuje ona dodatkowe pary klucz-wartość jako właściwości, gdzie klucze są ciągami, a wartości są również ciągami.

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

Wartość właściwości

{[propertyName: string]: string}

jarName

Właściwość ciągu reprezentująca nazwę pliku JAR zadania.

jarName?: string

Wartość właściwości

string

jobId

Unikatowy identyfikator identyfikacji zadania UWAGA: ta właściwość nie zostanie serializowana. Można go wypełnić tylko przez serwer.

jobId?: string

Wartość właściwości

string

jobJarDirectory

Właściwość ciągu określająca katalog, w którym znajduje się plik JAR zadania.

jobJarDirectory?: string

Wartość właściwości

string

jobName

Nazwa zadania

jobName?: string

Wartość właściwości

string

jobOutput

Dane wyjściowe zadania. UWAGA: Ta właściwość nie zostanie serializowana. Można go wypełnić tylko przez serwer.

jobOutput?: string

Wartość właściwości

string

jobType

Dyskryminator polimorficzny, który określa różne typy, które mogą być tym obiektem

jobType: "FlinkJob"

Wartość właściwości

"FlinkJob"

lastSavePoint

Ostatni punkt zapisu. UWAGA: Ta właściwość nie zostanie serializowana. Można go wypełnić tylko przez serwer.

lastSavePoint?: string

Wartość właściwości

string

runId

Identyfikator uruchomienia zadania

runId?: string

Wartość właściwości

string

savePointName

Właściwość ciągu reprezentująca nazwę punktu zapisywania dla zadania Flink

savePointName?: string

Wartość właściwości

string

status

Stan zadania. UWAGA: Ta właściwość nie zostanie serializowana. Można go wypełnić tylko przez serwer.

status?: string

Wartość właściwości

string