public static enum FlinkFnApi.UserDefinedDataStreamFunction.FunctionType extends Enum<FlinkFnApi.UserDefinedDataStreamFunction.FunctionType> implements com.google.protobuf.ProtocolMessageEnum
org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.FunctionType
Enum Constant and Description |
---|
CO_BROADCAST_PROCESS
CO_BROADCAST_PROCESS = 5; |
CO_PROCESS
CO_PROCESS = 1; |
KEYED_CO_BROADCAST_PROCESS
KEYED_CO_BROADCAST_PROCESS = 6; |
KEYED_CO_PROCESS
KEYED_CO_PROCESS = 3; |
KEYED_PROCESS
KEYED_PROCESS = 2; |
PROCESS
PROCESS = 0; |
REVISE_OUTPUT
REVISE_OUTPUT = 100; |
UNRECOGNIZED |
WINDOW
WINDOW = 4; |
Modifier and Type | Field and Description |
---|---|
static int |
CO_BROADCAST_PROCESS_VALUE
CO_BROADCAST_PROCESS = 5; |
static int |
CO_PROCESS_VALUE
CO_PROCESS = 1; |
static int |
KEYED_CO_BROADCAST_PROCESS_VALUE
KEYED_CO_BROADCAST_PROCESS = 6; |
static int |
KEYED_CO_PROCESS_VALUE
KEYED_CO_PROCESS = 3; |
static int |
KEYED_PROCESS_VALUE
KEYED_PROCESS = 2; |
static int |
PROCESS_VALUE
PROCESS = 0; |
static int |
REVISE_OUTPUT_VALUE
REVISE_OUTPUT = 100; |
static int |
WINDOW_VALUE
WINDOW = 4; |
Modifier and Type | Method and Description |
---|---|
static FlinkFnApi.UserDefinedDataStreamFunction.FunctionType |
forNumber(int value) |
static com.google.protobuf.Descriptors.EnumDescriptor |
getDescriptor() |
com.google.protobuf.Descriptors.EnumDescriptor |
getDescriptorForType() |
int |
getNumber() |
com.google.protobuf.Descriptors.EnumValueDescriptor |
getValueDescriptor() |
static com.google.protobuf.Internal.EnumLiteMap<FlinkFnApi.UserDefinedDataStreamFunction.FunctionType> |
internalGetValueMap() |
static FlinkFnApi.UserDefinedDataStreamFunction.FunctionType |
valueOf(com.google.protobuf.Descriptors.EnumValueDescriptor desc) |
static FlinkFnApi.UserDefinedDataStreamFunction.FunctionType |
valueOf(int value)
Deprecated.
Use
forNumber(int) instead. |
static FlinkFnApi.UserDefinedDataStreamFunction.FunctionType |
valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static FlinkFnApi.UserDefinedDataStreamFunction.FunctionType[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final FlinkFnApi.UserDefinedDataStreamFunction.FunctionType PROCESS
PROCESS = 0;
public static final FlinkFnApi.UserDefinedDataStreamFunction.FunctionType CO_PROCESS
CO_PROCESS = 1;
public static final FlinkFnApi.UserDefinedDataStreamFunction.FunctionType KEYED_PROCESS
KEYED_PROCESS = 2;
public static final FlinkFnApi.UserDefinedDataStreamFunction.FunctionType KEYED_CO_PROCESS
KEYED_CO_PROCESS = 3;
public static final FlinkFnApi.UserDefinedDataStreamFunction.FunctionType WINDOW
WINDOW = 4;
public static final FlinkFnApi.UserDefinedDataStreamFunction.FunctionType CO_BROADCAST_PROCESS
CO_BROADCAST_PROCESS = 5;
public static final FlinkFnApi.UserDefinedDataStreamFunction.FunctionType KEYED_CO_BROADCAST_PROCESS
KEYED_CO_BROADCAST_PROCESS = 6;
public static final FlinkFnApi.UserDefinedDataStreamFunction.FunctionType REVISE_OUTPUT
REVISE_OUTPUT = 100;
public static final FlinkFnApi.UserDefinedDataStreamFunction.FunctionType UNRECOGNIZED
public static final int PROCESS_VALUE
PROCESS = 0;
public static final int CO_PROCESS_VALUE
CO_PROCESS = 1;
public static final int KEYED_PROCESS_VALUE
KEYED_PROCESS = 2;
public static final int KEYED_CO_PROCESS_VALUE
KEYED_CO_PROCESS = 3;
public static final int WINDOW_VALUE
WINDOW = 4;
public static final int CO_BROADCAST_PROCESS_VALUE
CO_BROADCAST_PROCESS = 5;
public static final int KEYED_CO_BROADCAST_PROCESS_VALUE
KEYED_CO_BROADCAST_PROCESS = 6;
public static final int REVISE_OUTPUT_VALUE
REVISE_OUTPUT = 100;
public static FlinkFnApi.UserDefinedDataStreamFunction.FunctionType[] values()
for (FlinkFnApi.UserDefinedDataStreamFunction.FunctionType c : FlinkFnApi.UserDefinedDataStreamFunction.FunctionType.values()) System.out.println(c);
public static FlinkFnApi.UserDefinedDataStreamFunction.FunctionType valueOf(String name)
name
- the name of the enum constant to be returned.IllegalArgumentException
- if this enum type has no constant with the specified nameNullPointerException
- if the argument is nullpublic final int getNumber()
getNumber
in interface com.google.protobuf.Internal.EnumLite
getNumber
in interface com.google.protobuf.ProtocolMessageEnum
@Deprecated public static FlinkFnApi.UserDefinedDataStreamFunction.FunctionType valueOf(int value)
forNumber(int)
instead.value
- The numeric wire value of the corresponding enum entry.public static FlinkFnApi.UserDefinedDataStreamFunction.FunctionType forNumber(int value)
value
- The numeric wire value of the corresponding enum entry.public static com.google.protobuf.Internal.EnumLiteMap<FlinkFnApi.UserDefinedDataStreamFunction.FunctionType> internalGetValueMap()
public final com.google.protobuf.Descriptors.EnumValueDescriptor getValueDescriptor()
getValueDescriptor
in interface com.google.protobuf.ProtocolMessageEnum
public final com.google.protobuf.Descriptors.EnumDescriptor getDescriptorForType()
getDescriptorForType
in interface com.google.protobuf.ProtocolMessageEnum
public static final com.google.protobuf.Descriptors.EnumDescriptor getDescriptor()
public static FlinkFnApi.UserDefinedDataStreamFunction.FunctionType valueOf(com.google.protobuf.Descriptors.EnumValueDescriptor desc)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.