public static interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder
extends com.google.protobuf.MessageOrBuilder
Modifier and Type | Method and Description |
---|---|
int |
getAttemptNumber()
int32 attempt_number = 6; |
boolean |
getInBatchExecutionMode()
bool in_batch_execution_mode = 8; |
int |
getIndexOfThisSubtask()
int32 index_of_this_subtask = 5; |
FlinkFnApi.JobParameter |
getJobParameters(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7; |
int |
getJobParametersCount()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7; |
List<FlinkFnApi.JobParameter> |
getJobParametersList()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7; |
FlinkFnApi.JobParameterOrBuilder |
getJobParametersOrBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7; |
List<? extends FlinkFnApi.JobParameterOrBuilder> |
getJobParametersOrBuilderList()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7; |
int |
getMaxNumberOfParallelSubtasks()
int32 max_number_of_parallel_subtasks = 4; |
int |
getNumberOfParallelSubtasks()
int32 number_of_parallel_subtasks = 3; |
String |
getTaskName()
string task_name = 1; |
com.google.protobuf.ByteString |
getTaskNameBytes()
string task_name = 1; |
String |
getTaskNameWithSubtasks()
string task_name_with_subtasks = 2; |
com.google.protobuf.ByteString |
getTaskNameWithSubtasksBytes()
string task_name_with_subtasks = 2; |
findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
String getTaskName()
string task_name = 1;
com.google.protobuf.ByteString getTaskNameBytes()
string task_name = 1;
String getTaskNameWithSubtasks()
string task_name_with_subtasks = 2;
com.google.protobuf.ByteString getTaskNameWithSubtasksBytes()
string task_name_with_subtasks = 2;
int getNumberOfParallelSubtasks()
int32 number_of_parallel_subtasks = 3;
int getMaxNumberOfParallelSubtasks()
int32 max_number_of_parallel_subtasks = 4;
int getIndexOfThisSubtask()
int32 index_of_this_subtask = 5;
int getAttemptNumber()
int32 attempt_number = 6;
List<FlinkFnApi.JobParameter> getJobParametersList()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;
FlinkFnApi.JobParameter getJobParameters(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;
int getJobParametersCount()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;
List<? extends FlinkFnApi.JobParameterOrBuilder> getJobParametersOrBuilderList()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;
FlinkFnApi.JobParameterOrBuilder getJobParametersOrBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;
boolean getInBatchExecutionMode()
bool in_batch_execution_mode = 8;
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.