Package org.apache.flink.fnexecution.v1
Class FlinkFnApi.UserDefinedAggregateFunctions
- java.lang.Object
-
- com.google.protobuf.AbstractMessageLite
-
- com.google.protobuf.AbstractMessage
-
- com.google.protobuf.GeneratedMessageV3
-
- org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunctions
-
- All Implemented Interfaces:
com.google.protobuf.Message
,com.google.protobuf.MessageLite
,com.google.protobuf.MessageLiteOrBuilder
,com.google.protobuf.MessageOrBuilder
,Serializable
,FlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Enclosing class:
- FlinkFnApi
public static final class FlinkFnApi.UserDefinedAggregateFunctions extends com.google.protobuf.GeneratedMessageV3 implements FlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
A list of the user-defined aggregate functions to be executed in a group aggregate operation.
Protobuf typeorg.apache.flink.fn_execution.v1.UserDefinedAggregateFunctions
- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
FlinkFnApi.UserDefinedAggregateFunctions.Builder
A list of the user-defined aggregate functions to be executed in a group aggregate operation.-
Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessageV3
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
-
-
Field Summary
Fields Modifier and Type Field Description static int
COUNT_STAR_INSERTED_FIELD_NUMBER
static int
GENERATE_UPDATE_BEFORE_FIELD_NUMBER
static int
GROUP_WINDOW_FIELD_NUMBER
static int
GROUPING_FIELD_NUMBER
static int
INDEX_OF_COUNT_STAR_FIELD_NUMBER
static int
JOB_PARAMETERS_FIELD_NUMBER
static int
KEY_TYPE_FIELD_NUMBER
static int
MAP_STATE_READ_CACHE_SIZE_FIELD_NUMBER
static int
MAP_STATE_WRITE_CACHE_SIZE_FIELD_NUMBER
static int
METRIC_ENABLED_FIELD_NUMBER
static int
PROFILE_ENABLED_FIELD_NUMBER
static int
STATE_CACHE_SIZE_FIELD_NUMBER
static int
STATE_CLEANING_ENABLED_FIELD_NUMBER
static int
UDFS_FIELD_NUMBER
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object obj)
boolean
getCountStarInserted()
True if the count(*) agg is inserted by the planner.static FlinkFnApi.UserDefinedAggregateFunctions
getDefaultInstance()
FlinkFnApi.UserDefinedAggregateFunctions
getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor
getDescriptor()
boolean
getGenerateUpdateBefore()
Generate retract messages if true.int
getGrouping(int index)
The array of the key indexes.int
getGroupingCount()
The array of the key indexes.List<Integer>
getGroupingList()
The array of the key indexes.FlinkFnApi.GroupWindow
getGroupWindow()
Group Window.FlinkFnApi.GroupWindowOrBuilder
getGroupWindowOrBuilder()
Group Window.int
getIndexOfCountStar()
The index of a count aggregate used to calculate the number of accumulated rows.FlinkFnApi.JobParameter
getJobParameters(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
int
getJobParametersCount()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
List<FlinkFnApi.JobParameter>
getJobParametersList()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
FlinkFnApi.JobParameterOrBuilder
getJobParametersOrBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
List<? extends FlinkFnApi.JobParameterOrBuilder>
getJobParametersOrBuilderList()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
FlinkFnApi.Schema.FieldType
getKeyType()
The schema of the grouping keys.FlinkFnApi.Schema.FieldTypeOrBuilder
getKeyTypeOrBuilder()
The schema of the grouping keys.int
getMapStateReadCacheSize()
The map state read cache size.int
getMapStateWriteCacheSize()
The map_state_write_cache_size.boolean
getMetricEnabled()
bool metric_enabled = 2;
com.google.protobuf.Parser<FlinkFnApi.UserDefinedAggregateFunctions>
getParserForType()
boolean
getProfileEnabled()
bool profile_enabled = 13;
int
getSerializedSize()
int
getStateCacheSize()
The state cache size.boolean
getStateCleaningEnabled()
Cleanup the expired state if true.FlinkFnApi.UserDefinedAggregateFunction
getUdfs(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
int
getUdfsCount()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
List<FlinkFnApi.UserDefinedAggregateFunction>
getUdfsList()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
FlinkFnApi.UserDefinedAggregateFunctionOrBuilder
getUdfsOrBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
List<? extends FlinkFnApi.UserDefinedAggregateFunctionOrBuilder>
getUdfsOrBuilderList()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
com.google.protobuf.UnknownFieldSet
getUnknownFields()
boolean
hasGroupWindow()
Group Window.int
hashCode()
boolean
hasKeyType()
The schema of the grouping keys.protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable()
boolean
isInitialized()
static FlinkFnApi.UserDefinedAggregateFunctions.Builder
newBuilder()
static FlinkFnApi.UserDefinedAggregateFunctions.Builder
newBuilder(FlinkFnApi.UserDefinedAggregateFunctions prototype)
FlinkFnApi.UserDefinedAggregateFunctions.Builder
newBuilderForType()
protected FlinkFnApi.UserDefinedAggregateFunctions.Builder
newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
protected Object
newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
static FlinkFnApi.UserDefinedAggregateFunctions
parseDelimitedFrom(InputStream input)
static FlinkFnApi.UserDefinedAggregateFunctions
parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static FlinkFnApi.UserDefinedAggregateFunctions
parseFrom(byte[] data)
static FlinkFnApi.UserDefinedAggregateFunctions
parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static FlinkFnApi.UserDefinedAggregateFunctions
parseFrom(com.google.protobuf.ByteString data)
static FlinkFnApi.UserDefinedAggregateFunctions
parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static FlinkFnApi.UserDefinedAggregateFunctions
parseFrom(com.google.protobuf.CodedInputStream input)
static FlinkFnApi.UserDefinedAggregateFunctions
parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static FlinkFnApi.UserDefinedAggregateFunctions
parseFrom(InputStream input)
static FlinkFnApi.UserDefinedAggregateFunctions
parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static FlinkFnApi.UserDefinedAggregateFunctions
parseFrom(ByteBuffer data)
static FlinkFnApi.UserDefinedAggregateFunctions
parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static com.google.protobuf.Parser<FlinkFnApi.UserDefinedAggregateFunctions>
parser()
FlinkFnApi.UserDefinedAggregateFunctions.Builder
toBuilder()
void
writeTo(com.google.protobuf.CodedOutputStream output)
-
Methods inherited from class com.google.protobuf.GeneratedMessageV3
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
-
Methods inherited from class com.google.protobuf.AbstractMessage
findInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toString
-
Methods inherited from class com.google.protobuf.AbstractMessageLite
addAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
-
-
-
Field Detail
-
UDFS_FIELD_NUMBER
public static final int UDFS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
METRIC_ENABLED_FIELD_NUMBER
public static final int METRIC_ENABLED_FIELD_NUMBER
- See Also:
- Constant Field Values
-
GROUPING_FIELD_NUMBER
public static final int GROUPING_FIELD_NUMBER
- See Also:
- Constant Field Values
-
GENERATE_UPDATE_BEFORE_FIELD_NUMBER
public static final int GENERATE_UPDATE_BEFORE_FIELD_NUMBER
- See Also:
- Constant Field Values
-
KEY_TYPE_FIELD_NUMBER
public static final int KEY_TYPE_FIELD_NUMBER
- See Also:
- Constant Field Values
-
INDEX_OF_COUNT_STAR_FIELD_NUMBER
public static final int INDEX_OF_COUNT_STAR_FIELD_NUMBER
- See Also:
- Constant Field Values
-
STATE_CLEANING_ENABLED_FIELD_NUMBER
public static final int STATE_CLEANING_ENABLED_FIELD_NUMBER
- See Also:
- Constant Field Values
-
STATE_CACHE_SIZE_FIELD_NUMBER
public static final int STATE_CACHE_SIZE_FIELD_NUMBER
- See Also:
- Constant Field Values
-
MAP_STATE_READ_CACHE_SIZE_FIELD_NUMBER
public static final int MAP_STATE_READ_CACHE_SIZE_FIELD_NUMBER
- See Also:
- Constant Field Values
-
MAP_STATE_WRITE_CACHE_SIZE_FIELD_NUMBER
public static final int MAP_STATE_WRITE_CACHE_SIZE_FIELD_NUMBER
- See Also:
- Constant Field Values
-
COUNT_STAR_INSERTED_FIELD_NUMBER
public static final int COUNT_STAR_INSERTED_FIELD_NUMBER
- See Also:
- Constant Field Values
-
GROUP_WINDOW_FIELD_NUMBER
public static final int GROUP_WINDOW_FIELD_NUMBER
- See Also:
- Constant Field Values
-
PROFILE_ENABLED_FIELD_NUMBER
public static final int PROFILE_ENABLED_FIELD_NUMBER
- See Also:
- Constant Field Values
-
JOB_PARAMETERS_FIELD_NUMBER
public static final int JOB_PARAMETERS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
-
Method Detail
-
newInstance
protected Object newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
- Overrides:
newInstance
in classcom.google.protobuf.GeneratedMessageV3
-
getUnknownFields
public final com.google.protobuf.UnknownFieldSet getUnknownFields()
- Specified by:
getUnknownFields
in interfacecom.google.protobuf.MessageOrBuilder
- Overrides:
getUnknownFields
in classcom.google.protobuf.GeneratedMessageV3
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTable
in classcom.google.protobuf.GeneratedMessageV3
-
getUdfsList
public List<FlinkFnApi.UserDefinedAggregateFunction> getUdfsList()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
- Specified by:
getUdfsList
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getUdfsOrBuilderList
public List<? extends FlinkFnApi.UserDefinedAggregateFunctionOrBuilder> getUdfsOrBuilderList()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
- Specified by:
getUdfsOrBuilderList
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getUdfsCount
public int getUdfsCount()
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
- Specified by:
getUdfsCount
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getUdfs
public FlinkFnApi.UserDefinedAggregateFunction getUdfs(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
- Specified by:
getUdfs
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getUdfsOrBuilder
public FlinkFnApi.UserDefinedAggregateFunctionOrBuilder getUdfsOrBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.UserDefinedAggregateFunction udfs = 1;
- Specified by:
getUdfsOrBuilder
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getMetricEnabled
public boolean getMetricEnabled()
bool metric_enabled = 2;
- Specified by:
getMetricEnabled
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- The metricEnabled.
-
getGroupingList
public List<Integer> getGroupingList()
The array of the key indexes.
repeated int32 grouping = 3;
- Specified by:
getGroupingList
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- A list containing the grouping.
-
getGroupingCount
public int getGroupingCount()
The array of the key indexes.
repeated int32 grouping = 3;
- Specified by:
getGroupingCount
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- The count of grouping.
-
getGrouping
public int getGrouping(int index)
The array of the key indexes.
repeated int32 grouping = 3;
- Specified by:
getGrouping
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Parameters:
index
- The index of the element to return.- Returns:
- The grouping at the given index.
-
getGenerateUpdateBefore
public boolean getGenerateUpdateBefore()
Generate retract messages if true.
bool generate_update_before = 4;
- Specified by:
getGenerateUpdateBefore
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- The generateUpdateBefore.
-
hasKeyType
public boolean hasKeyType()
The schema of the grouping keys.
.org.apache.flink.fn_execution.v1.Schema.FieldType key_type = 5;
- Specified by:
hasKeyType
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- Whether the keyType field is set.
-
getKeyType
public FlinkFnApi.Schema.FieldType getKeyType()
The schema of the grouping keys.
.org.apache.flink.fn_execution.v1.Schema.FieldType key_type = 5;
- Specified by:
getKeyType
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- The keyType.
-
getKeyTypeOrBuilder
public FlinkFnApi.Schema.FieldTypeOrBuilder getKeyTypeOrBuilder()
The schema of the grouping keys.
.org.apache.flink.fn_execution.v1.Schema.FieldType key_type = 5;
- Specified by:
getKeyTypeOrBuilder
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getIndexOfCountStar
public int getIndexOfCountStar()
The index of a count aggregate used to calculate the number of accumulated rows.
int32 index_of_count_star = 6;
- Specified by:
getIndexOfCountStar
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- The indexOfCountStar.
-
getStateCleaningEnabled
public boolean getStateCleaningEnabled()
Cleanup the expired state if true.
bool state_cleaning_enabled = 7;
- Specified by:
getStateCleaningEnabled
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- The stateCleaningEnabled.
-
getStateCacheSize
public int getStateCacheSize()
The state cache size.
int32 state_cache_size = 8;
- Specified by:
getStateCacheSize
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- The stateCacheSize.
-
getMapStateReadCacheSize
public int getMapStateReadCacheSize()
The map state read cache size.
int32 map_state_read_cache_size = 9;
- Specified by:
getMapStateReadCacheSize
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- The mapStateReadCacheSize.
-
getMapStateWriteCacheSize
public int getMapStateWriteCacheSize()
The map_state_write_cache_size.
int32 map_state_write_cache_size = 10;
- Specified by:
getMapStateWriteCacheSize
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- The mapStateWriteCacheSize.
-
getCountStarInserted
public boolean getCountStarInserted()
True if the count(*) agg is inserted by the planner.
bool count_star_inserted = 11;
- Specified by:
getCountStarInserted
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- The countStarInserted.
-
hasGroupWindow
public boolean hasGroupWindow()
Group Window.
.org.apache.flink.fn_execution.v1.GroupWindow group_window = 12;
- Specified by:
hasGroupWindow
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- Whether the groupWindow field is set.
-
getGroupWindow
public FlinkFnApi.GroupWindow getGroupWindow()
Group Window.
.org.apache.flink.fn_execution.v1.GroupWindow group_window = 12;
- Specified by:
getGroupWindow
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- The groupWindow.
-
getGroupWindowOrBuilder
public FlinkFnApi.GroupWindowOrBuilder getGroupWindowOrBuilder()
Group Window.
.org.apache.flink.fn_execution.v1.GroupWindow group_window = 12;
- Specified by:
getGroupWindowOrBuilder
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getProfileEnabled
public boolean getProfileEnabled()
bool profile_enabled = 13;
- Specified by:
getProfileEnabled
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
- Returns:
- The profileEnabled.
-
getJobParametersList
public List<FlinkFnApi.JobParameter> getJobParametersList()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
- Specified by:
getJobParametersList
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getJobParametersOrBuilderList
public List<? extends FlinkFnApi.JobParameterOrBuilder> getJobParametersOrBuilderList()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
- Specified by:
getJobParametersOrBuilderList
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getJobParametersCount
public int getJobParametersCount()
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
- Specified by:
getJobParametersCount
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getJobParameters
public FlinkFnApi.JobParameter getJobParameters(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
- Specified by:
getJobParameters
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
getJobParametersOrBuilder
public FlinkFnApi.JobParameterOrBuilder getJobParametersOrBuilder(int index)
repeated .org.apache.flink.fn_execution.v1.JobParameter job_parameters = 14;
- Specified by:
getJobParametersOrBuilder
in interfaceFlinkFnApi.UserDefinedAggregateFunctionsOrBuilder
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitialized
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Overrides:
isInitialized
in classcom.google.protobuf.GeneratedMessageV3
-
writeTo
public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException
- Specified by:
writeTo
in interfacecom.google.protobuf.MessageLite
- Overrides:
writeTo
in classcom.google.protobuf.GeneratedMessageV3
- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()
- Specified by:
getSerializedSize
in interfacecom.google.protobuf.MessageLite
- Overrides:
getSerializedSize
in classcom.google.protobuf.GeneratedMessageV3
-
equals
public boolean equals(Object obj)
- Specified by:
equals
in interfacecom.google.protobuf.Message
- Overrides:
equals
in classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()
- Specified by:
hashCode
in interfacecom.google.protobuf.Message
- Overrides:
hashCode
in classcom.google.protobuf.AbstractMessage
-
parseFrom
public static FlinkFnApi.UserDefinedAggregateFunctions parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static FlinkFnApi.UserDefinedAggregateFunctions parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static FlinkFnApi.UserDefinedAggregateFunctions parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static FlinkFnApi.UserDefinedAggregateFunctions parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static FlinkFnApi.UserDefinedAggregateFunctions parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static FlinkFnApi.UserDefinedAggregateFunctions parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static FlinkFnApi.UserDefinedAggregateFunctions parseFrom(InputStream input) throws IOException
- Throws:
IOException
-
parseFrom
public static FlinkFnApi.UserDefinedAggregateFunctions parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
parseDelimitedFrom
public static FlinkFnApi.UserDefinedAggregateFunctions parseDelimitedFrom(InputStream input) throws IOException
- Throws:
IOException
-
parseDelimitedFrom
public static FlinkFnApi.UserDefinedAggregateFunctions parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
parseFrom
public static FlinkFnApi.UserDefinedAggregateFunctions parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
- Throws:
IOException
-
parseFrom
public static FlinkFnApi.UserDefinedAggregateFunctions parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
newBuilderForType
public FlinkFnApi.UserDefinedAggregateFunctions.Builder newBuilderForType()
- Specified by:
newBuilderForType
in interfacecom.google.protobuf.Message
- Specified by:
newBuilderForType
in interfacecom.google.protobuf.MessageLite
-
newBuilder
public static FlinkFnApi.UserDefinedAggregateFunctions.Builder newBuilder()
-
newBuilder
public static FlinkFnApi.UserDefinedAggregateFunctions.Builder newBuilder(FlinkFnApi.UserDefinedAggregateFunctions prototype)
-
toBuilder
public FlinkFnApi.UserDefinedAggregateFunctions.Builder toBuilder()
- Specified by:
toBuilder
in interfacecom.google.protobuf.Message
- Specified by:
toBuilder
in interfacecom.google.protobuf.MessageLite
-
newBuilderForType
protected FlinkFnApi.UserDefinedAggregateFunctions.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
- Specified by:
newBuilderForType
in classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstance
public static FlinkFnApi.UserDefinedAggregateFunctions getDefaultInstance()
-
parser
public static com.google.protobuf.Parser<FlinkFnApi.UserDefinedAggregateFunctions> parser()
-
getParserForType
public com.google.protobuf.Parser<FlinkFnApi.UserDefinedAggregateFunctions> getParserForType()
- Specified by:
getParserForType
in interfacecom.google.protobuf.Message
- Specified by:
getParserForType
in interfacecom.google.protobuf.MessageLite
- Overrides:
getParserForType
in classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstanceForType
public FlinkFnApi.UserDefinedAggregateFunctions getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageOrBuilder
-
-