Package org.apache.flink.fnexecution.v1

Class FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder

java.lang.Object

com.google.protobuf.AbstractMessageLite.Builder

com.google.protobuf.AbstractMessage.Builder<BuilderT>

com.google.protobuf.GeneratedMessage.Builder<FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder>

org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder

All Implemented Interfaces:

com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Cloneable, FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder

Enclosing class:

FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext

public static final class FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder
extends com.google.protobuf.GeneratedMessage.Builder<FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder>
implements FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder

Protobuf type org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.RuntimeContext

Method Summary

Modifier and Type	Method	Description
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	addAllJobParameters(Iterable<? extends FlinkFnApi.JobParameter> values)	repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	addJobParameters(int index, FlinkFnApi.JobParameter value)	repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	addJobParameters(int index, FlinkFnApi.JobParameter.Builder builderForValue)	repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	addJobParameters(FlinkFnApi.JobParameter value)	repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	addJobParameters(FlinkFnApi.JobParameter.Builder builderForValue)	repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;
FlinkFnApi.JobParameter.Builder	addJobParametersBuilder()	repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;
FlinkFnApi.JobParameter.Builder	addJobParametersBuilder(int index)	repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext	build()
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext	buildPartial()
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	clear()
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	clearAttemptNumber()	int32 attempt_number = 6;
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	clearInBatchExecutionMode()	bool in_batch_execution_mode = 8;
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	clearIndexOfThisSubtask()	int32 index_of_this_subtask = 5;
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	clearJobParameters()	repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	clearMaxNumberOfParallelSubtasks()	int32 max_number_of_parallel_subtasks = 4;
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	clearNumberOfParallelSubtasks()	int32 number_of_parallel_subtasks = 3;
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	clearTaskName()	string task_name = 1;
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	clearTaskNameWithSubtasks()	string task_name_with_subtasks = 2;
int	getAttemptNumber()	int32 attempt_number = 6;
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext	getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor	getDescriptor()
com.google.protobuf.Descriptors.Descriptor	getDescriptorForType()
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;
FlinkFnApi.JobParameter.Builder	getJobParametersBuilder(int index)	repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;
List<FlinkFnApi.JobParameter.Builder>	getJobParametersBuilderList()	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;
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable	internalGetFieldAccessorTable()
boolean	isInitialized()
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	mergeFrom(com.google.protobuf.Message other)
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	mergeFrom(FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext other)
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	removeJobParameters(int index)	repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	setAttemptNumber(int value)	int32 attempt_number = 6;
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	setInBatchExecutionMode(boolean value)	bool in_batch_execution_mode = 8;
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	setIndexOfThisSubtask(int value)	int32 index_of_this_subtask = 5;
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	setJobParameters(int index, FlinkFnApi.JobParameter value)	repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	setJobParameters(int index, FlinkFnApi.JobParameter.Builder builderForValue)	repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	setMaxNumberOfParallelSubtasks(int value)	int32 max_number_of_parallel_subtasks = 4;
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	setNumberOfParallelSubtasks(int value)	int32 number_of_parallel_subtasks = 3;
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	setTaskName(String value)	string task_name = 1;
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	setTaskNameBytes(com.google.protobuf.ByteString value)	string task_name = 1;
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	setTaskNameWithSubtasks(String value)	string task_name_with_subtasks = 2;
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder	setTaskNameWithSubtasksBytes(com.google.protobuf.ByteString value)	string task_name_with_subtasks = 2;

Methods inherited from class com.google.protobuf.GeneratedMessage.Builder

addRepeatedField, clearField, clearOneof, clone, getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getParentForChildren, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, getUnknownFieldSetBuilder, hasField, hasOneof, internalGetMapField, internalGetMapFieldReflection, internalGetMutableMapField, internalGetMutableMapFieldReflection, isClean, markClean, mergeUnknownFields, mergeUnknownLengthDelimitedField, mergeUnknownVarintField, newBuilderForField, onBuilt, onChanged, parseUnknownField, setField, setRepeatedField, setUnknownFields, setUnknownFieldSetBuilder, setUnknownFieldsProto3

Methods inherited from class com.google.protobuf.AbstractMessage.Builder

findInitializationErrors, getInitializationErrorString, internalMergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, newUninitializedMessageException, toString

Methods inherited from class com.google.protobuf.AbstractMessageLite.Builder

addAll, addAll, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, newUninitializedMessageException

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.protobuf.Message.Builder

mergeDelimitedFrom, mergeDelimitedFrom

Methods inherited from interface com.google.protobuf.MessageLite.Builder

mergeFrom

Methods inherited from interface com.google.protobuf.MessageOrBuilder

findInitializationErrors, getAllFields, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

Method Detail

getDescriptor

public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

internalGetFieldAccessorTable

protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()

Specified by:

internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage.Builder<FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder>

clear

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder clear()

Specified by:

clear in interface com.google.protobuf.Message.Builder

Specified by:

clear in interface com.google.protobuf.MessageLite.Builder

Overrides:

clear in class com.google.protobuf.GeneratedMessage.Builder<FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder>

getDescriptorForType

public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()

Specified by:

getDescriptorForType in interface com.google.protobuf.Message.Builder

Specified by:

getDescriptorForType in interface com.google.protobuf.MessageOrBuilder

Overrides:

getDescriptorForType in class com.google.protobuf.GeneratedMessage.Builder<FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder>

getDefaultInstanceForType

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

build

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext build()

Specified by:

build in interface com.google.protobuf.Message.Builder

Specified by:

build in interface com.google.protobuf.MessageLite.Builder

buildPartial

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext buildPartial()

Specified by:

buildPartial in interface com.google.protobuf.Message.Builder

Specified by:

buildPartial in interface com.google.protobuf.MessageLite.Builder

mergeFrom

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder mergeFrom(com.google.protobuf.Message other)

Specified by:

mergeFrom in interface com.google.protobuf.Message.Builder

Overrides:

mergeFrom in class com.google.protobuf.AbstractMessage.Builder<FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder>

mergeFrom

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder mergeFrom(FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext other)

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface com.google.protobuf.MessageLiteOrBuilder

Overrides:

isInitialized in class com.google.protobuf.GeneratedMessage.Builder<FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder>

mergeFrom

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder mergeFrom(com.google.protobuf.CodedInputStream input,
                                                                                 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                                          throws IOException

Specified by:

mergeFrom in interface com.google.protobuf.Message.Builder

Specified by:

mergeFrom in interface com.google.protobuf.MessageLite.Builder

Overrides:

mergeFrom in class com.google.protobuf.AbstractMessage.Builder<FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder>

Throws:

IOException

getTaskName

public String getTaskName()

string task_name = 1;

Specified by:

getTaskName in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder

Returns:

The taskName.

getTaskNameBytes

public com.google.protobuf.ByteString getTaskNameBytes()

string task_name = 1;

Specified by:

getTaskNameBytes in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder

Returns:

The bytes for taskName.

setTaskName

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder setTaskName(String value)

string task_name = 1;

Parameters:

value - The taskName to set.

Returns:

This builder for chaining.

clearTaskName

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder clearTaskName()

string task_name = 1;

Returns:

This builder for chaining.

setTaskNameBytes

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder setTaskNameBytes(com.google.protobuf.ByteString value)

string task_name = 1;

Parameters:

value - The bytes for taskName to set.

Returns:

This builder for chaining.

getTaskNameWithSubtasks

public String getTaskNameWithSubtasks()

string task_name_with_subtasks = 2;

Specified by:

getTaskNameWithSubtasks in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder

Returns:

The taskNameWithSubtasks.

getTaskNameWithSubtasksBytes

public com.google.protobuf.ByteString getTaskNameWithSubtasksBytes()

string task_name_with_subtasks = 2;

Specified by:

getTaskNameWithSubtasksBytes in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder

Returns:

The bytes for taskNameWithSubtasks.

setTaskNameWithSubtasks

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder setTaskNameWithSubtasks(String value)

string task_name_with_subtasks = 2;

Parameters:

value - The taskNameWithSubtasks to set.

Returns:

This builder for chaining.

clearTaskNameWithSubtasks

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder clearTaskNameWithSubtasks()

string task_name_with_subtasks = 2;

Returns:

This builder for chaining.

setTaskNameWithSubtasksBytes

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder setTaskNameWithSubtasksBytes(com.google.protobuf.ByteString value)

string task_name_with_subtasks = 2;

Parameters:

value - The bytes for taskNameWithSubtasks to set.

Returns:

This builder for chaining.

getNumberOfParallelSubtasks

public int getNumberOfParallelSubtasks()

int32 number_of_parallel_subtasks = 3;

Specified by:

getNumberOfParallelSubtasks in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder

Returns:

The numberOfParallelSubtasks.

setNumberOfParallelSubtasks

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder setNumberOfParallelSubtasks(int value)

int32 number_of_parallel_subtasks = 3;

Parameters:

value - The numberOfParallelSubtasks to set.

Returns:

This builder for chaining.

clearNumberOfParallelSubtasks

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder clearNumberOfParallelSubtasks()

int32 number_of_parallel_subtasks = 3;

Returns:

This builder for chaining.

getMaxNumberOfParallelSubtasks

public int getMaxNumberOfParallelSubtasks()

int32 max_number_of_parallel_subtasks = 4;

Specified by:

getMaxNumberOfParallelSubtasks in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder

Returns:

The maxNumberOfParallelSubtasks.

setMaxNumberOfParallelSubtasks

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder setMaxNumberOfParallelSubtasks(int value)

int32 max_number_of_parallel_subtasks = 4;

Parameters:

value - The maxNumberOfParallelSubtasks to set.

Returns:

This builder for chaining.

clearMaxNumberOfParallelSubtasks

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder clearMaxNumberOfParallelSubtasks()

int32 max_number_of_parallel_subtasks = 4;

Returns:

This builder for chaining.

getIndexOfThisSubtask

public int getIndexOfThisSubtask()

int32 index_of_this_subtask = 5;

Specified by:

getIndexOfThisSubtask in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder

Returns:

The indexOfThisSubtask.

setIndexOfThisSubtask

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder setIndexOfThisSubtask(int value)

int32 index_of_this_subtask = 5;

Parameters:

value - The indexOfThisSubtask to set.

Returns:

This builder for chaining.

clearIndexOfThisSubtask

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder clearIndexOfThisSubtask()

int32 index_of_this_subtask = 5;

Returns:

This builder for chaining.

getAttemptNumber

public int getAttemptNumber()

int32 attempt_number = 6;

Specified by:

getAttemptNumber in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder

Returns:

The attemptNumber.

setAttemptNumber

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder setAttemptNumber(int value)

int32 attempt_number = 6;

Parameters:

value - The attemptNumber to set.

Returns:

This builder for chaining.

clearAttemptNumber

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder clearAttemptNumber()

int32 attempt_number = 6;

Returns:

This builder for chaining.

getJobParametersList

public List<FlinkFnApi.JobParameter> getJobParametersList()

repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;

Specified by:

getJobParametersList in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder

getJobParametersCount

public int getJobParametersCount()

repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;

Specified by:

getJobParametersCount in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder

getJobParameters

public FlinkFnApi.JobParameter getJobParameters(int index)

repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;

Specified by:

getJobParameters in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder

setJobParameters

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder setJobParameters(int index,
                                                                                        FlinkFnApi.JobParameter value)

repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;

setJobParameters

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder setJobParameters(int index,
                                                                                        FlinkFnApi.JobParameter.Builder builderForValue)

repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;

addJobParameters

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder addJobParameters(FlinkFnApi.JobParameter value)

repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;

addJobParameters

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder addJobParameters(int index,
                                                                                        FlinkFnApi.JobParameter value)

repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;

addJobParameters

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder addJobParameters(FlinkFnApi.JobParameter.Builder builderForValue)

repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;

addJobParameters

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder addJobParameters(int index,
                                                                                        FlinkFnApi.JobParameter.Builder builderForValue)

repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;

addAllJobParameters

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder addAllJobParameters(Iterable<? extends FlinkFnApi.JobParameter> values)

repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;

clearJobParameters

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder clearJobParameters()

repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;

removeJobParameters

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder removeJobParameters(int index)

repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;

getJobParametersBuilder

public FlinkFnApi.JobParameter.Builder getJobParametersBuilder(int index)

repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;

getJobParametersOrBuilder

public FlinkFnApi.JobParameterOrBuilder getJobParametersOrBuilder(int index)

repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;

Specified by:

getJobParametersOrBuilder in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder

getJobParametersOrBuilderList

public List<? extends FlinkFnApi.JobParameterOrBuilder> getJobParametersOrBuilderList()

repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;

Specified by:

getJobParametersOrBuilderList in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder

addJobParametersBuilder

public FlinkFnApi.JobParameter.Builder addJobParametersBuilder()

repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;

addJobParametersBuilder

public FlinkFnApi.JobParameter.Builder addJobParametersBuilder(int index)

repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;

getJobParametersBuilderList

public List<FlinkFnApi.JobParameter.Builder> getJobParametersBuilderList()

repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 7;

getInBatchExecutionMode

public boolean getInBatchExecutionMode()

bool in_batch_execution_mode = 8;

Specified by:

getInBatchExecutionMode in interface FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder

Returns:

The inBatchExecutionMode.

setInBatchExecutionMode

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder setInBatchExecutionMode(boolean value)

bool in_batch_execution_mode = 8;

Parameters:

value - The inBatchExecutionMode to set.

Returns:

This builder for chaining.

clearInBatchExecutionMode

public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext.Builder clearInBatchExecutionMode()

bool in_batch_execution_mode = 8;

Returns:

This builder for chaining.