public static final class FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext extends com.google.protobuf.GeneratedMessageV3 implements FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder
org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.RuntimeContext
Modifier and Type | Class and Description |
---|---|
static class |
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder
Protobuf type
org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.RuntimeContext |
com.google.protobuf.GeneratedMessageV3.BuilderParent, com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>,BuilderT extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageT,BuilderT>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable, com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter
Modifier and Type | Field and Description |
---|---|
static int |
ATTEMPT_NUMBER_FIELD_NUMBER |
static int |
IN_BATCH_EXECUTION_MODE_FIELD_NUMBER |
static int |
INDEX_OF_THIS_SUBTASK_FIELD_NUMBER |
static int |
JOB_PARAMETERS_FIELD_NUMBER |
static int |
MAX_NUMBER_OF_PARALLEL_SUBTASKS_FIELD_NUMBER |
static int |
NUMBER_OF_PARALLEL_SUBTASKS_FIELD_NUMBER |
static int |
TASK_NAME_FIELD_NUMBER |
static int |
TASK_NAME_WITH_SUBTASKS_FIELD_NUMBER |
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, hasField, hasOneof, internalGetMapField, isStringEmpty, makeExtensionsImmutable, makeMutableCopy, makeMutableCopy, mergeFromAndMakeImmutableInternal, mutableCopy, mutableCopy, mutableCopy, mutableCopy, mutableCopy, newBooleanList, newBuilderForType, newDoubleList, newFloatList, newIntList, newLongList, parseDelimitedWithIOException, parseDelimitedWithIOException, parseUnknownField, parseUnknownFieldProto3, parseWithIOException, parseWithIOException, parseWithIOException, parseWithIOException, serializeBooleanMapTo, serializeIntegerMapTo, serializeLongMapTo, serializeStringMapTo, writeReplace, writeString, writeStringNoTag
findInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toString
addAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
public static final int TASK_NAME_FIELD_NUMBER
public static final int TASK_NAME_WITH_SUBTASKS_FIELD_NUMBER
public static final int NUMBER_OF_PARALLEL_SUBTASKS_FIELD_NUMBER
public static final int MAX_NUMBER_OF_PARALLEL_SUBTASKS_FIELD_NUMBER
public static final int INDEX_OF_THIS_SUBTASK_FIELD_NUMBER
public static final int ATTEMPT_NUMBER_FIELD_NUMBER
public static final int JOB_PARAMETERS_FIELD_NUMBER
public static final int IN_BATCH_EXECUTION_MODE_FIELD_NUMBER
protected Object newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
newInstance
in class com.google.protobuf.GeneratedMessageV3
public final com.google.protobuf.UnknownFieldSet getUnknownFields()
getUnknownFields
in interface com.google.protobuf.MessageOrBuilder
getUnknownFields
in class com.google.protobuf.GeneratedMessageV3
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
internalGetFieldAccessorTable
in class com.google.protobuf.GeneratedMessageV3
public String getTaskName()
string task_name = 1;
getTaskName
in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder
public com.google.protobuf.ByteString getTaskNameBytes()
string task_name = 1;
getTaskNameBytes
in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder
public String getTaskNameWithSubtasks()
string task_name_with_subtasks = 2;
getTaskNameWithSubtasks
in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder
public com.google.protobuf.ByteString getTaskNameWithSubtasksBytes()
string task_name_with_subtasks = 2;
getTaskNameWithSubtasksBytes
in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder
public int getNumberOfParallelSubtasks()
int32 number_of_parallel_subtasks = 3;
getNumberOfParallelSubtasks
in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder
public int getMaxNumberOfParallelSubtasks()
int32 max_number_of_parallel_subtasks = 4;
getMaxNumberOfParallelSubtasks
in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder
public int getIndexOfThisSubtask()
int32 index_of_this_subtask = 5;
getIndexOfThisSubtask
in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder
public int getAttemptNumber()
int32 attempt_number = 6;
getAttemptNumber
in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder
public List<FlinkFnApi.JobParameter> getJobParametersList()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;
getJobParametersList
in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder
public List<? extends FlinkFnApi.JobParameterOrBuilder> getJobParametersOrBuilderList()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;
getJobParametersOrBuilderList
in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder
public int getJobParametersCount()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;
getJobParametersCount
in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder
public FlinkFnApi.JobParameter getJobParameters(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;
getJobParameters
in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder
public FlinkFnApi.JobParameterOrBuilder getJobParametersOrBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;
getJobParametersOrBuilder
in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder
public boolean getInBatchExecutionMode()
bool in_batch_execution_mode = 8;
getInBatchExecutionMode
in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder
public final boolean isInitialized()
isInitialized
in interface com.google.protobuf.MessageLiteOrBuilder
isInitialized
in class com.google.protobuf.GeneratedMessageV3
public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException
writeTo
in interface com.google.protobuf.MessageLite
writeTo
in class com.google.protobuf.GeneratedMessageV3
IOException
public int getSerializedSize()
getSerializedSize
in interface com.google.protobuf.MessageLite
getSerializedSize
in class com.google.protobuf.GeneratedMessageV3
public boolean equals(Object obj)
equals
in interface com.google.protobuf.Message
equals
in class com.google.protobuf.AbstractMessage
public int hashCode()
hashCode
in interface com.google.protobuf.Message
hashCode
in class com.google.protobuf.AbstractMessage
public static FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext parseFrom(InputStream input) throws IOException
IOException
public static FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public static FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext parseDelimitedFrom(InputStream input) throws IOException
IOException
public static FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public static FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
IOException
public static FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder newBuilderForType()
newBuilderForType
in interface com.google.protobuf.Message
newBuilderForType
in interface com.google.protobuf.MessageLite
public static FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder newBuilder()
public static FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder newBuilder(FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext prototype)
public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder toBuilder()
toBuilder
in interface com.google.protobuf.Message
toBuilder
in interface com.google.protobuf.MessageLite
protected FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
newBuilderForType
in class com.google.protobuf.GeneratedMessageV3
public static FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext getDefaultInstance()
public static com.google.protobuf.Parser<FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext> parser()
public com.google.protobuf.Parser<FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext> getParserForType()
getParserForType
in interface com.google.protobuf.Message
getParserForType
in interface com.google.protobuf.MessageLite
getParserForType
in class com.google.protobuf.GeneratedMessageV3
public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext getDefaultInstanceForType()
getDefaultInstanceForType
in interface com.google.protobuf.MessageLiteOrBuilder
getDefaultInstanceForType
in interface com.google.protobuf.MessageOrBuilder
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.