public static final class FlinkFnApi.UserDefinedDataStreamFunction extends com.google.protobuf.GeneratedMessageV3 implements FlinkFnApi.UserDefinedDataStreamFunctionOrBuilder
User defined DataStream function definition.Protobuf type
org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction
Modifier and Type | Class and Description |
---|---|
static class |
FlinkFnApi.UserDefinedDataStreamFunction.Builder
User defined DataStream function definition.
|
static class |
FlinkFnApi.UserDefinedDataStreamFunction.FunctionType
Protobuf enum
org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.FunctionType |
static class |
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext
Protobuf type
org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.RuntimeContext |
static interface |
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder |
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 |
FUNCTION_TYPE_FIELD_NUMBER |
static int |
HAS_SIDE_OUTPUT_FIELD_NUMBER |
static int |
KEY_TYPE_INFO_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 |
PAYLOAD_FIELD_NUMBER |
static int |
PROFILE_ENABLED_FIELD_NUMBER |
static int |
RUNTIME_CONTEXT_FIELD_NUMBER |
static int |
STATE_CACHE_SIZE_FIELD_NUMBER |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object obj) |
static FlinkFnApi.UserDefinedDataStreamFunction |
getDefaultInstance() |
FlinkFnApi.UserDefinedDataStreamFunction |
getDefaultInstanceForType() |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
FlinkFnApi.UserDefinedDataStreamFunction.FunctionType |
getFunctionType()
.org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.FunctionType function_type = 1; |
int |
getFunctionTypeValue()
.org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.FunctionType function_type = 1; |
boolean |
getHasSideOutput()
bool has_side_output = 7; |
FlinkFnApi.TypeInfo |
getKeyTypeInfo()
.org.apache.flink.fn_execution.v1.TypeInfo key_type_info = 5; |
FlinkFnApi.TypeInfoOrBuilder |
getKeyTypeInfoOrBuilder()
.org.apache.flink.fn_execution.v1.TypeInfo key_type_info = 5; |
int |
getMapStateReadCacheSize()
The map state read cache size.
|
int |
getMapStateWriteCacheSize()
The map_state_write_cache_size.
|
boolean |
getMetricEnabled()
bool metric_enabled = 4; |
com.google.protobuf.Parser<FlinkFnApi.UserDefinedDataStreamFunction> |
getParserForType() |
com.google.protobuf.ByteString |
getPayload()
bytes payload = 3; |
boolean |
getProfileEnabled()
bool profile_enabled = 6; |
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext |
getRuntimeContext()
.org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.RuntimeContext runtime_context = 2; |
FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder |
getRuntimeContextOrBuilder()
.org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.RuntimeContext runtime_context = 2; |
int |
getSerializedSize() |
int |
getStateCacheSize()
The state cache size.
|
com.google.protobuf.UnknownFieldSet |
getUnknownFields() |
int |
hashCode() |
boolean |
hasKeyTypeInfo()
.org.apache.flink.fn_execution.v1.TypeInfo key_type_info = 5; |
boolean |
hasRuntimeContext()
.org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.RuntimeContext runtime_context = 2; |
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable |
internalGetFieldAccessorTable() |
boolean |
isInitialized() |
static FlinkFnApi.UserDefinedDataStreamFunction.Builder |
newBuilder() |
static FlinkFnApi.UserDefinedDataStreamFunction.Builder |
newBuilder(FlinkFnApi.UserDefinedDataStreamFunction prototype) |
FlinkFnApi.UserDefinedDataStreamFunction.Builder |
newBuilderForType() |
protected FlinkFnApi.UserDefinedDataStreamFunction.Builder |
newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) |
protected Object |
newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused) |
static FlinkFnApi.UserDefinedDataStreamFunction |
parseDelimitedFrom(InputStream input) |
static FlinkFnApi.UserDefinedDataStreamFunction |
parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.UserDefinedDataStreamFunction |
parseFrom(byte[] data) |
static FlinkFnApi.UserDefinedDataStreamFunction |
parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.UserDefinedDataStreamFunction |
parseFrom(ByteBuffer data) |
static FlinkFnApi.UserDefinedDataStreamFunction |
parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.UserDefinedDataStreamFunction |
parseFrom(com.google.protobuf.ByteString data) |
static FlinkFnApi.UserDefinedDataStreamFunction |
parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.UserDefinedDataStreamFunction |
parseFrom(com.google.protobuf.CodedInputStream input) |
static FlinkFnApi.UserDefinedDataStreamFunction |
parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.UserDefinedDataStreamFunction |
parseFrom(InputStream input) |
static FlinkFnApi.UserDefinedDataStreamFunction |
parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static com.google.protobuf.Parser<FlinkFnApi.UserDefinedDataStreamFunction> |
parser() |
FlinkFnApi.UserDefinedDataStreamFunction.Builder |
toBuilder() |
void |
writeTo(com.google.protobuf.CodedOutputStream output) |
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 FUNCTION_TYPE_FIELD_NUMBER
public static final int RUNTIME_CONTEXT_FIELD_NUMBER
public static final int PAYLOAD_FIELD_NUMBER
public static final int METRIC_ENABLED_FIELD_NUMBER
public static final int KEY_TYPE_INFO_FIELD_NUMBER
public static final int PROFILE_ENABLED_FIELD_NUMBER
public static final int HAS_SIDE_OUTPUT_FIELD_NUMBER
public static final int STATE_CACHE_SIZE_FIELD_NUMBER
public static final int MAP_STATE_READ_CACHE_SIZE_FIELD_NUMBER
public static final int MAP_STATE_WRITE_CACHE_SIZE_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 int getFunctionTypeValue()
.org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.FunctionType function_type = 1;
getFunctionTypeValue
in interface FlinkFnApi.UserDefinedDataStreamFunctionOrBuilder
public FlinkFnApi.UserDefinedDataStreamFunction.FunctionType getFunctionType()
.org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.FunctionType function_type = 1;
getFunctionType
in interface FlinkFnApi.UserDefinedDataStreamFunctionOrBuilder
public boolean hasRuntimeContext()
.org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.RuntimeContext runtime_context = 2;
hasRuntimeContext
in interface FlinkFnApi.UserDefinedDataStreamFunctionOrBuilder
public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContext getRuntimeContext()
.org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.RuntimeContext runtime_context = 2;
getRuntimeContext
in interface FlinkFnApi.UserDefinedDataStreamFunctionOrBuilder
public FlinkFnApi.UserDefinedDataStreamFunction.RuntimeContextOrBuilder getRuntimeContextOrBuilder()
.org.apache.flink.fn_execution.v1.UserDefinedDataStreamFunction.RuntimeContext runtime_context = 2;
getRuntimeContextOrBuilder
in interface FlinkFnApi.UserDefinedDataStreamFunctionOrBuilder
public com.google.protobuf.ByteString getPayload()
bytes payload = 3;
getPayload
in interface FlinkFnApi.UserDefinedDataStreamFunctionOrBuilder
public boolean getMetricEnabled()
bool metric_enabled = 4;
getMetricEnabled
in interface FlinkFnApi.UserDefinedDataStreamFunctionOrBuilder
public boolean hasKeyTypeInfo()
.org.apache.flink.fn_execution.v1.TypeInfo key_type_info = 5;
hasKeyTypeInfo
in interface FlinkFnApi.UserDefinedDataStreamFunctionOrBuilder
public FlinkFnApi.TypeInfo getKeyTypeInfo()
.org.apache.flink.fn_execution.v1.TypeInfo key_type_info = 5;
getKeyTypeInfo
in interface FlinkFnApi.UserDefinedDataStreamFunctionOrBuilder
public FlinkFnApi.TypeInfoOrBuilder getKeyTypeInfoOrBuilder()
.org.apache.flink.fn_execution.v1.TypeInfo key_type_info = 5;
getKeyTypeInfoOrBuilder
in interface FlinkFnApi.UserDefinedDataStreamFunctionOrBuilder
public boolean getProfileEnabled()
bool profile_enabled = 6;
getProfileEnabled
in interface FlinkFnApi.UserDefinedDataStreamFunctionOrBuilder
public boolean getHasSideOutput()
bool has_side_output = 7;
getHasSideOutput
in interface FlinkFnApi.UserDefinedDataStreamFunctionOrBuilder
public int getStateCacheSize()
The state cache size.
int32 state_cache_size = 8;
getStateCacheSize
in interface FlinkFnApi.UserDefinedDataStreamFunctionOrBuilder
public int getMapStateReadCacheSize()
The map state read cache size.
int32 map_state_read_cache_size = 9;
getMapStateReadCacheSize
in interface FlinkFnApi.UserDefinedDataStreamFunctionOrBuilder
public int getMapStateWriteCacheSize()
The map_state_write_cache_size.
int32 map_state_write_cache_size = 10;
getMapStateWriteCacheSize
in interface FlinkFnApi.UserDefinedDataStreamFunctionOrBuilder
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 parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static FlinkFnApi.UserDefinedDataStreamFunction parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static FlinkFnApi.UserDefinedDataStreamFunction parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static FlinkFnApi.UserDefinedDataStreamFunction parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static FlinkFnApi.UserDefinedDataStreamFunction parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static FlinkFnApi.UserDefinedDataStreamFunction parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static FlinkFnApi.UserDefinedDataStreamFunction parseFrom(InputStream input) throws IOException
IOException
public static FlinkFnApi.UserDefinedDataStreamFunction parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public static FlinkFnApi.UserDefinedDataStreamFunction parseDelimitedFrom(InputStream input) throws IOException
IOException
public static FlinkFnApi.UserDefinedDataStreamFunction parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public static FlinkFnApi.UserDefinedDataStreamFunction parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
IOException
public static FlinkFnApi.UserDefinedDataStreamFunction parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public FlinkFnApi.UserDefinedDataStreamFunction.Builder newBuilderForType()
newBuilderForType
in interface com.google.protobuf.Message
newBuilderForType
in interface com.google.protobuf.MessageLite
public static FlinkFnApi.UserDefinedDataStreamFunction.Builder newBuilder()
public static FlinkFnApi.UserDefinedDataStreamFunction.Builder newBuilder(FlinkFnApi.UserDefinedDataStreamFunction prototype)
public FlinkFnApi.UserDefinedDataStreamFunction.Builder toBuilder()
toBuilder
in interface com.google.protobuf.Message
toBuilder
in interface com.google.protobuf.MessageLite
protected FlinkFnApi.UserDefinedDataStreamFunction.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
newBuilderForType
in class com.google.protobuf.GeneratedMessageV3
public static FlinkFnApi.UserDefinedDataStreamFunction getDefaultInstance()
public static com.google.protobuf.Parser<FlinkFnApi.UserDefinedDataStreamFunction> parser()
public com.google.protobuf.Parser<FlinkFnApi.UserDefinedDataStreamFunction> 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 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.