Apache Flink · JSON-LD Context

Apache Flink Rest Context

JSON-LD context defining the semantic vocabulary for Apache Flink Rest from Apache Flink.

52 Classes 130 Properties 4 Namespaces
View Context View on GitHub

Namespaces

flink: https://flink.apache.org/schema/
schema: https://schema.org/
dcterms: http://purl.org/dc/terms/
xsd: http://www.w3.org/2001/XMLSchema#

Classes

AggregatedMetricsResponseBody AggregatedTaskDetailsInfo AggregationMode ApplicationStatus AsynchronousOperationInfo AsynchronousOperationResult CheckpointAlignment CheckpointAlignmentSummary CheckpointConfigInfo CheckpointDuration CheckpointDurationSummary CheckpointInfo CheckpointStatistics CheckpointStatisticsSummary CheckpointStatsStatus CheckpointTriggerRequestBody CheckpointType CheckpointingStatistics ClusterDataSetEntry ClusterDataSetListResponseBody ClusterOverviewWithVersion CompletedCheckpointStatistics CompletedSubtaskCheckpointStatistics ConfigurationInfoEntry ConfigurationInfo Counts DashboardConfiguration EnvironmentInfo ExceptionInfo ExecutionConfigInfo ExecutionState ExternalizedCheckpointInfo FailedCheckpointStatistics FailureLabel Features GarbageCollectorInfo name HardwareDescription Id IntermediateDataSetID IOMetricsInfo JarEntryInfo description JarFileInfo JarListInfo JarPlanRequestBody JarRunRequestBody JarRunResponseBody JarUploadResponseBody JobAccumulator JobAccumulatorsInfo JobClientHeartbeatRequestBody

Properties

Property Type Container
metrics string
status-duration string
failure-cause string
operation string
status string
buffered integer
duration integer
persisted integer
processed integer
aligned_checkpoint_timeout integer
changelog_periodic_materialization_interval integer
changelog_storage string
checkpoint_storage string
checkpoints_after_tasks_finish boolean
externalization string
interval integer
max_concurrent integer
min_pause integer
mode string
state_backend string
state_changelog_enabled boolean
timeout integer
tolerable_failed_checkpoints integer
unaligned_checkpoints boolean
async integer
sync integer
checkpointId integer
failureCause string
alignment_buffered integer
checkpoint_type string
checkpointed_size integer
className string
end_to_end_duration integer
id integer
is_savepoint boolean
latest_ack_timestamp integer
num_acknowledged_subtasks integer
num_subtasks integer
persisted_data integer
processed_data integer
savepointFormat string
state_size integer
tasks string
trigger_timestamp integer
checkpointType string
triggerId string
counts string
history string set
latest string
summary string
isComplete boolean
dataSets string set
flink-commit string
flink-version string
jobs-cancelled integer
jobs-failed integer
jobs-finished integer
jobs-running integer
slots-available integer
slots-free-and-blocked integer
slots-total integer
taskmanagers integer
taskmanagers-blocked integer
key string
value string
completed integer
failed integer
in_progress integer
restored integer
total integer
features string
flink-revision string
refresh-interval integer
timezone-name string
timezone-offset integer
classpath string set
jvm string
endpoint string
exceptionName string
failureLabels string
stacktrace string
taskManagerId string
taskName string
timestamp integer
job-parallelism integer
object-reuse-mode boolean
restart-strategy string
user-config string
delete_on_cancellation boolean
enabled boolean
web-cancel boolean
web-history boolean
web-rescale boolean
web-submit boolean
count integer
time integer
cpuCores integer
freeMemory integer
managedMemory integer
physicalMemory integer
accumulated-backpressured-time integer
accumulated-busy-time integer
accumulated-idle-time integer
read-bytes integer
read-bytes-complete boolean
read-records integer
read-records-complete boolean
write-bytes integer
write-bytes-complete boolean
write-records integer
write-records-complete boolean
entry string set
uploaded integer
address string
files string set
entryClass string
flinkConfiguration string
jobId string
parallelism integer
programArgsList string set
allowNonRestoredState boolean
claimMode string
restoreMode string
savepointPath string
jobid string
filename string
job-accumulators string set
serialized-user-task-accumulators string
user-task-accumulators string set
expiredTimestamp integer