Package org.apache.flink.fnexecution.v1
Class FlinkFnApi.UserDefinedFunctions.Builder
- java.lang.Object
-
- com.google.protobuf.AbstractMessageLite.Builder
-
- com.google.protobuf.AbstractMessage.Builder<BuilderT>
-
- com.google.protobuf.GeneratedMessage.Builder<FlinkFnApi.UserDefinedFunctions.Builder>
-
- org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedFunctions.Builder
-
- All Implemented Interfaces:
com.google.protobuf.Message.Builder,com.google.protobuf.MessageLite.Builder,com.google.protobuf.MessageLiteOrBuilder,com.google.protobuf.MessageOrBuilder,Cloneable,FlinkFnApi.UserDefinedFunctionsOrBuilder
- Enclosing class:
- FlinkFnApi.UserDefinedFunctions
public static final class FlinkFnApi.UserDefinedFunctions.Builder extends com.google.protobuf.GeneratedMessage.Builder<FlinkFnApi.UserDefinedFunctions.Builder> implements FlinkFnApi.UserDefinedFunctionsOrBuilder
A list of user-defined functions to be executed in a batch.
Protobuf typeorg.apache.flink.fn_execution.v1.UserDefinedFunctions
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description FlinkFnApi.UserDefinedFunctions.BuilderaddAllJobParameters(Iterable<? extends FlinkFnApi.JobParameter> values)repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;FlinkFnApi.UserDefinedFunctions.BuilderaddAllUdfs(Iterable<? extends FlinkFnApi.UserDefinedFunction> values)repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;FlinkFnApi.UserDefinedFunctions.BuilderaddAllWindows(Iterable<? extends FlinkFnApi.OverWindow> values)repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;FlinkFnApi.UserDefinedFunctions.BuilderaddJobParameters(int index, FlinkFnApi.JobParameter value)repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;FlinkFnApi.UserDefinedFunctions.BuilderaddJobParameters(int index, FlinkFnApi.JobParameter.Builder builderForValue)repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;FlinkFnApi.UserDefinedFunctions.BuilderaddJobParameters(FlinkFnApi.JobParameter value)repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;FlinkFnApi.UserDefinedFunctions.BuilderaddJobParameters(FlinkFnApi.JobParameter.Builder builderForValue)repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;FlinkFnApi.JobParameter.BuilderaddJobParametersBuilder()repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;FlinkFnApi.JobParameter.BuilderaddJobParametersBuilder(int index)repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;FlinkFnApi.UserDefinedFunctions.BuilderaddUdfs(int index, FlinkFnApi.UserDefinedFunction value)repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;FlinkFnApi.UserDefinedFunctions.BuilderaddUdfs(int index, FlinkFnApi.UserDefinedFunction.Builder builderForValue)repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;FlinkFnApi.UserDefinedFunctions.BuilderaddUdfs(FlinkFnApi.UserDefinedFunction value)repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;FlinkFnApi.UserDefinedFunctions.BuilderaddUdfs(FlinkFnApi.UserDefinedFunction.Builder builderForValue)repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;FlinkFnApi.UserDefinedFunction.BuilderaddUdfsBuilder()repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;FlinkFnApi.UserDefinedFunction.BuilderaddUdfsBuilder(int index)repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;FlinkFnApi.UserDefinedFunctions.BuilderaddWindows(int index, FlinkFnApi.OverWindow value)repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;FlinkFnApi.UserDefinedFunctions.BuilderaddWindows(int index, FlinkFnApi.OverWindow.Builder builderForValue)repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;FlinkFnApi.UserDefinedFunctions.BuilderaddWindows(FlinkFnApi.OverWindow value)repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;FlinkFnApi.UserDefinedFunctions.BuilderaddWindows(FlinkFnApi.OverWindow.Builder builderForValue)repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;FlinkFnApi.OverWindow.BuilderaddWindowsBuilder()repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;FlinkFnApi.OverWindow.BuilderaddWindowsBuilder(int index)repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;FlinkFnApi.UserDefinedFunctionsbuild()FlinkFnApi.UserDefinedFunctionsbuildPartial()FlinkFnApi.UserDefinedFunctions.Builderclear()FlinkFnApi.UserDefinedFunctions.BuilderclearJobParameters()repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;FlinkFnApi.UserDefinedFunctions.BuilderclearMetricEnabled()bool metric_enabled = 2;FlinkFnApi.UserDefinedFunctions.BuilderclearProfileEnabled()bool profile_enabled = 4;FlinkFnApi.UserDefinedFunctions.BuilderclearUdfs()repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;FlinkFnApi.UserDefinedFunctions.BuilderclearWindows()repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;FlinkFnApi.UserDefinedFunctionsgetDefaultInstanceForType()static com.google.protobuf.Descriptors.DescriptorgetDescriptor()com.google.protobuf.Descriptors.DescriptorgetDescriptorForType()FlinkFnApi.JobParametergetJobParameters(int index)repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;FlinkFnApi.JobParameter.BuildergetJobParametersBuilder(int index)repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;List<FlinkFnApi.JobParameter.Builder>getJobParametersBuilderList()repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;intgetJobParametersCount()repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;List<FlinkFnApi.JobParameter>getJobParametersList()repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;FlinkFnApi.JobParameterOrBuildergetJobParametersOrBuilder(int index)repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;List<? extends FlinkFnApi.JobParameterOrBuilder>getJobParametersOrBuilderList()repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;booleangetMetricEnabled()bool metric_enabled = 2;booleangetProfileEnabled()bool profile_enabled = 4;FlinkFnApi.UserDefinedFunctiongetUdfs(int index)repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;FlinkFnApi.UserDefinedFunction.BuildergetUdfsBuilder(int index)repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;List<FlinkFnApi.UserDefinedFunction.Builder>getUdfsBuilderList()repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;intgetUdfsCount()repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;List<FlinkFnApi.UserDefinedFunction>getUdfsList()repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;FlinkFnApi.UserDefinedFunctionOrBuildergetUdfsOrBuilder(int index)repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;List<? extends FlinkFnApi.UserDefinedFunctionOrBuilder>getUdfsOrBuilderList()repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;FlinkFnApi.OverWindowgetWindows(int index)repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;FlinkFnApi.OverWindow.BuildergetWindowsBuilder(int index)repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;List<FlinkFnApi.OverWindow.Builder>getWindowsBuilderList()repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;intgetWindowsCount()repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;List<FlinkFnApi.OverWindow>getWindowsList()repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;FlinkFnApi.OverWindowOrBuildergetWindowsOrBuilder(int index)repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;List<? extends FlinkFnApi.OverWindowOrBuilder>getWindowsOrBuilderList()repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;protected com.google.protobuf.GeneratedMessage.FieldAccessorTableinternalGetFieldAccessorTable()booleanisInitialized()FlinkFnApi.UserDefinedFunctions.BuildermergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)FlinkFnApi.UserDefinedFunctions.BuildermergeFrom(com.google.protobuf.Message other)FlinkFnApi.UserDefinedFunctions.BuildermergeFrom(FlinkFnApi.UserDefinedFunctions other)FlinkFnApi.UserDefinedFunctions.BuilderremoveJobParameters(int index)repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;FlinkFnApi.UserDefinedFunctions.BuilderremoveUdfs(int index)repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;FlinkFnApi.UserDefinedFunctions.BuilderremoveWindows(int index)repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;FlinkFnApi.UserDefinedFunctions.BuildersetJobParameters(int index, FlinkFnApi.JobParameter value)repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;FlinkFnApi.UserDefinedFunctions.BuildersetJobParameters(int index, FlinkFnApi.JobParameter.Builder builderForValue)repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;FlinkFnApi.UserDefinedFunctions.BuildersetMetricEnabled(boolean value)bool metric_enabled = 2;FlinkFnApi.UserDefinedFunctions.BuildersetProfileEnabled(boolean value)bool profile_enabled = 4;FlinkFnApi.UserDefinedFunctions.BuildersetUdfs(int index, FlinkFnApi.UserDefinedFunction value)repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;FlinkFnApi.UserDefinedFunctions.BuildersetUdfs(int index, FlinkFnApi.UserDefinedFunction.Builder builderForValue)repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;FlinkFnApi.UserDefinedFunctions.BuildersetWindows(int index, FlinkFnApi.OverWindow value)repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;FlinkFnApi.UserDefinedFunctions.BuildersetWindows(int index, FlinkFnApi.OverWindow.Builder builderForValue)repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;-
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
-
-
-
-
Method Detail
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTablein classcom.google.protobuf.GeneratedMessage.Builder<FlinkFnApi.UserDefinedFunctions.Builder>
-
clear
public FlinkFnApi.UserDefinedFunctions.Builder clear()
- Specified by:
clearin interfacecom.google.protobuf.Message.Builder- Specified by:
clearin interfacecom.google.protobuf.MessageLite.Builder- Overrides:
clearin classcom.google.protobuf.GeneratedMessage.Builder<FlinkFnApi.UserDefinedFunctions.Builder>
-
getDescriptorForType
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
- Specified by:
getDescriptorForTypein interfacecom.google.protobuf.Message.Builder- Specified by:
getDescriptorForTypein interfacecom.google.protobuf.MessageOrBuilder- Overrides:
getDescriptorForTypein classcom.google.protobuf.GeneratedMessage.Builder<FlinkFnApi.UserDefinedFunctions.Builder>
-
getDefaultInstanceForType
public FlinkFnApi.UserDefinedFunctions getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-
build
public FlinkFnApi.UserDefinedFunctions build()
- Specified by:
buildin interfacecom.google.protobuf.Message.Builder- Specified by:
buildin interfacecom.google.protobuf.MessageLite.Builder
-
buildPartial
public FlinkFnApi.UserDefinedFunctions buildPartial()
- Specified by:
buildPartialin interfacecom.google.protobuf.Message.Builder- Specified by:
buildPartialin interfacecom.google.protobuf.MessageLite.Builder
-
mergeFrom
public FlinkFnApi.UserDefinedFunctions.Builder mergeFrom(com.google.protobuf.Message other)
- Specified by:
mergeFromin interfacecom.google.protobuf.Message.Builder- Overrides:
mergeFromin classcom.google.protobuf.AbstractMessage.Builder<FlinkFnApi.UserDefinedFunctions.Builder>
-
mergeFrom
public FlinkFnApi.UserDefinedFunctions.Builder mergeFrom(FlinkFnApi.UserDefinedFunctions other)
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin classcom.google.protobuf.GeneratedMessage.Builder<FlinkFnApi.UserDefinedFunctions.Builder>
-
mergeFrom
public FlinkFnApi.UserDefinedFunctions.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Specified by:
mergeFromin interfacecom.google.protobuf.Message.Builder- Specified by:
mergeFromin interfacecom.google.protobuf.MessageLite.Builder- Overrides:
mergeFromin classcom.google.protobuf.AbstractMessage.Builder<FlinkFnApi.UserDefinedFunctions.Builder>- Throws:
IOException
-
getUdfsList
public List<FlinkFnApi.UserDefinedFunction> getUdfsList()
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;- Specified by:
getUdfsListin interfaceFlinkFnApi.UserDefinedFunctionsOrBuilder
-
getUdfsCount
public int getUdfsCount()
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;- Specified by:
getUdfsCountin interfaceFlinkFnApi.UserDefinedFunctionsOrBuilder
-
getUdfs
public FlinkFnApi.UserDefinedFunction getUdfs(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;- Specified by:
getUdfsin interfaceFlinkFnApi.UserDefinedFunctionsOrBuilder
-
setUdfs
public FlinkFnApi.UserDefinedFunctions.Builder setUdfs(int index, FlinkFnApi.UserDefinedFunction value)
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;
-
setUdfs
public FlinkFnApi.UserDefinedFunctions.Builder setUdfs(int index, FlinkFnApi.UserDefinedFunction.Builder builderForValue)
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;
-
addUdfs
public FlinkFnApi.UserDefinedFunctions.Builder addUdfs(FlinkFnApi.UserDefinedFunction value)
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;
-
addUdfs
public FlinkFnApi.UserDefinedFunctions.Builder addUdfs(int index, FlinkFnApi.UserDefinedFunction value)
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;
-
addUdfs
public FlinkFnApi.UserDefinedFunctions.Builder addUdfs(FlinkFnApi.UserDefinedFunction.Builder builderForValue)
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;
-
addUdfs
public FlinkFnApi.UserDefinedFunctions.Builder addUdfs(int index, FlinkFnApi.UserDefinedFunction.Builder builderForValue)
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;
-
addAllUdfs
public FlinkFnApi.UserDefinedFunctions.Builder addAllUdfs(Iterable<? extends FlinkFnApi.UserDefinedFunction> values)
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;
-
clearUdfs
public FlinkFnApi.UserDefinedFunctions.Builder clearUdfs()
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;
-
removeUdfs
public FlinkFnApi.UserDefinedFunctions.Builder removeUdfs(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;
-
getUdfsBuilder
public FlinkFnApi.UserDefinedFunction.Builder getUdfsBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;
-
getUdfsOrBuilder
public FlinkFnApi.UserDefinedFunctionOrBuilder getUdfsOrBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;- Specified by:
getUdfsOrBuilderin interfaceFlinkFnApi.UserDefinedFunctionsOrBuilder
-
getUdfsOrBuilderList
public List<? extends FlinkFnApi.UserDefinedFunctionOrBuilder> getUdfsOrBuilderList()
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;- Specified by:
getUdfsOrBuilderListin interfaceFlinkFnApi.UserDefinedFunctionsOrBuilder
-
addUdfsBuilder
public FlinkFnApi.UserDefinedFunction.Builder addUdfsBuilder()
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;
-
addUdfsBuilder
public FlinkFnApi.UserDefinedFunction.Builder addUdfsBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;
-
getUdfsBuilderList
public List<FlinkFnApi.UserDefinedFunction.Builder> getUdfsBuilderList()
repeated .org.apache.flink.fn_execution.v1.UserDefinedFunction udfs = 1;
-
getMetricEnabled
public boolean getMetricEnabled()
bool metric_enabled = 2;- Specified by:
getMetricEnabledin interfaceFlinkFnApi.UserDefinedFunctionsOrBuilder- Returns:
- The metricEnabled.
-
setMetricEnabled
public FlinkFnApi.UserDefinedFunctions.Builder setMetricEnabled(boolean value)
bool metric_enabled = 2;- Parameters:
value- The metricEnabled to set.- Returns:
- This builder for chaining.
-
clearMetricEnabled
public FlinkFnApi.UserDefinedFunctions.Builder clearMetricEnabled()
bool metric_enabled = 2;- Returns:
- This builder for chaining.
-
getWindowsList
public List<FlinkFnApi.OverWindow> getWindowsList()
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;- Specified by:
getWindowsListin interfaceFlinkFnApi.UserDefinedFunctionsOrBuilder
-
getWindowsCount
public int getWindowsCount()
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;- Specified by:
getWindowsCountin interfaceFlinkFnApi.UserDefinedFunctionsOrBuilder
-
getWindows
public FlinkFnApi.OverWindow getWindows(int index)
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;- Specified by:
getWindowsin interfaceFlinkFnApi.UserDefinedFunctionsOrBuilder
-
setWindows
public FlinkFnApi.UserDefinedFunctions.Builder setWindows(int index, FlinkFnApi.OverWindow value)
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;
-
setWindows
public FlinkFnApi.UserDefinedFunctions.Builder setWindows(int index, FlinkFnApi.OverWindow.Builder builderForValue)
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;
-
addWindows
public FlinkFnApi.UserDefinedFunctions.Builder addWindows(FlinkFnApi.OverWindow value)
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;
-
addWindows
public FlinkFnApi.UserDefinedFunctions.Builder addWindows(int index, FlinkFnApi.OverWindow value)
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;
-
addWindows
public FlinkFnApi.UserDefinedFunctions.Builder addWindows(FlinkFnApi.OverWindow.Builder builderForValue)
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;
-
addWindows
public FlinkFnApi.UserDefinedFunctions.Builder addWindows(int index, FlinkFnApi.OverWindow.Builder builderForValue)
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;
-
addAllWindows
public FlinkFnApi.UserDefinedFunctions.Builder addAllWindows(Iterable<? extends FlinkFnApi.OverWindow> values)
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;
-
clearWindows
public FlinkFnApi.UserDefinedFunctions.Builder clearWindows()
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;
-
removeWindows
public FlinkFnApi.UserDefinedFunctions.Builder removeWindows(int index)
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;
-
getWindowsBuilder
public FlinkFnApi.OverWindow.Builder getWindowsBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;
-
getWindowsOrBuilder
public FlinkFnApi.OverWindowOrBuilder getWindowsOrBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;- Specified by:
getWindowsOrBuilderin interfaceFlinkFnApi.UserDefinedFunctionsOrBuilder
-
getWindowsOrBuilderList
public List<? extends FlinkFnApi.OverWindowOrBuilder> getWindowsOrBuilderList()
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;- Specified by:
getWindowsOrBuilderListin interfaceFlinkFnApi.UserDefinedFunctionsOrBuilder
-
addWindowsBuilder
public FlinkFnApi.OverWindow.Builder addWindowsBuilder()
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;
-
addWindowsBuilder
public FlinkFnApi.OverWindow.Builder addWindowsBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;
-
getWindowsBuilderList
public List<FlinkFnApi.OverWindow.Builder> getWindowsBuilderList()
repeated .org.apache.flink.fn_execution.v1.OverWindow windows = 3;
-
getProfileEnabled
public boolean getProfileEnabled()
bool profile_enabled = 4;- Specified by:
getProfileEnabledin interfaceFlinkFnApi.UserDefinedFunctionsOrBuilder- Returns:
- The profileEnabled.
-
setProfileEnabled
public FlinkFnApi.UserDefinedFunctions.Builder setProfileEnabled(boolean value)
bool profile_enabled = 4;- Parameters:
value- The profileEnabled to set.- Returns:
- This builder for chaining.
-
clearProfileEnabled
public FlinkFnApi.UserDefinedFunctions.Builder clearProfileEnabled()
bool profile_enabled = 4;- Returns:
- This builder for chaining.
-
getJobParametersList
public List<FlinkFnApi.JobParameter> getJobParametersList()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;- Specified by:
getJobParametersListin interfaceFlinkFnApi.UserDefinedFunctionsOrBuilder
-
getJobParametersCount
public int getJobParametersCount()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;- Specified by:
getJobParametersCountin interfaceFlinkFnApi.UserDefinedFunctionsOrBuilder
-
getJobParameters
public FlinkFnApi.JobParameter getJobParameters(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;- Specified by:
getJobParametersin interfaceFlinkFnApi.UserDefinedFunctionsOrBuilder
-
setJobParameters
public FlinkFnApi.UserDefinedFunctions.Builder setJobParameters(int index, FlinkFnApi.JobParameter value)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;
-
setJobParameters
public FlinkFnApi.UserDefinedFunctions.Builder setJobParameters(int index, FlinkFnApi.JobParameter.Builder builderForValue)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;
-
addJobParameters
public FlinkFnApi.UserDefinedFunctions.Builder addJobParameters(FlinkFnApi.JobParameter value)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;
-
addJobParameters
public FlinkFnApi.UserDefinedFunctions.Builder addJobParameters(int index, FlinkFnApi.JobParameter value)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;
-
addJobParameters
public FlinkFnApi.UserDefinedFunctions.Builder addJobParameters(FlinkFnApi.JobParameter.Builder builderForValue)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;
-
addJobParameters
public FlinkFnApi.UserDefinedFunctions.Builder addJobParameters(int index, FlinkFnApi.JobParameter.Builder builderForValue)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;
-
addAllJobParameters
public FlinkFnApi.UserDefinedFunctions.Builder addAllJobParameters(Iterable<? extends FlinkFnApi.JobParameter> values)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;
-
clearJobParameters
public FlinkFnApi.UserDefinedFunctions.Builder clearJobParameters()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;
-
removeJobParameters
public FlinkFnApi.UserDefinedFunctions.Builder removeJobParameters(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;
-
getJobParametersBuilder
public FlinkFnApi.JobParameter.Builder getJobParametersBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;
-
getJobParametersOrBuilder
public FlinkFnApi.JobParameterOrBuilder getJobParametersOrBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;- Specified by:
getJobParametersOrBuilderin interfaceFlinkFnApi.UserDefinedFunctionsOrBuilder
-
getJobParametersOrBuilderList
public List<? extends FlinkFnApi.JobParameterOrBuilder> getJobParametersOrBuilderList()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;- Specified by:
getJobParametersOrBuilderListin interfaceFlinkFnApi.UserDefinedFunctionsOrBuilder
-
addJobParametersBuilder
public FlinkFnApi.JobParameter.Builder addJobParametersBuilder()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;
-
addJobParametersBuilder
public FlinkFnApi.JobParameter.Builder addJobParametersBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;
-
getJobParametersBuilderList
public List<FlinkFnApi.JobParameter.Builder> getJobParametersBuilderList()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 5;
-
-