public static final class FlinkFnApi.CoderInfoDescriptor extends com.google.protobuf.GeneratedMessageV3 implements FlinkFnApi.CoderInfoDescriptorOrBuilder
A representation of the coderProtobuf type
org.apache.flink.fn_execution.v1.CoderInfoDescriptor
Modifier and Type | Class and Description |
---|---|
static class |
FlinkFnApi.CoderInfoDescriptor.ArrowType
Protobuf type
org.apache.flink.fn_execution.v1.CoderInfoDescriptor.ArrowType |
static interface |
FlinkFnApi.CoderInfoDescriptor.ArrowTypeOrBuilder |
static class |
FlinkFnApi.CoderInfoDescriptor.Builder
A representation of the coder
|
static class |
FlinkFnApi.CoderInfoDescriptor.DataTypeCase |
static class |
FlinkFnApi.CoderInfoDescriptor.FlattenRowType
for Table & SQL
|
static interface |
FlinkFnApi.CoderInfoDescriptor.FlattenRowTypeOrBuilder |
static class |
FlinkFnApi.CoderInfoDescriptor.Mode
Protobuf enum
org.apache.flink.fn_execution.v1.CoderInfoDescriptor.Mode |
static class |
FlinkFnApi.CoderInfoDescriptor.OverWindowArrowType
only used in batch over window
the data consists of [window data][arrow data]
|
static interface |
FlinkFnApi.CoderInfoDescriptor.OverWindowArrowTypeOrBuilder |
static class |
FlinkFnApi.CoderInfoDescriptor.RawType
for DataStream
|
static interface |
FlinkFnApi.CoderInfoDescriptor.RawTypeOrBuilder |
static class |
FlinkFnApi.CoderInfoDescriptor.RowType
Protobuf type
org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RowType |
static interface |
FlinkFnApi.CoderInfoDescriptor.RowTypeOrBuilder |
com.google.protobuf.GeneratedMessageV3.BuilderParent, com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage,BuilderType extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType,BuilderType>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable, com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter
Modifier and Type | Field and Description |
---|---|
static int |
ARROW_TYPE_FIELD_NUMBER |
static int |
FLATTEN_ROW_TYPE_FIELD_NUMBER |
static int |
MODE_FIELD_NUMBER |
static int |
OVER_WINDOW_ARROW_TYPE_FIELD_NUMBER |
static int |
RAW_TYPE_FIELD_NUMBER |
static int |
ROW_TYPE_FIELD_NUMBER |
static int |
SEPARATED_WITH_END_MESSAGE_FIELD_NUMBER |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object obj) |
FlinkFnApi.CoderInfoDescriptor.ArrowType |
getArrowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.ArrowType arrow_type = 3; |
FlinkFnApi.CoderInfoDescriptor.ArrowTypeOrBuilder |
getArrowTypeOrBuilder()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.ArrowType arrow_type = 3; |
FlinkFnApi.CoderInfoDescriptor.DataTypeCase |
getDataTypeCase() |
static FlinkFnApi.CoderInfoDescriptor |
getDefaultInstance() |
FlinkFnApi.CoderInfoDescriptor |
getDefaultInstanceForType() |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
FlinkFnApi.CoderInfoDescriptor.FlattenRowType |
getFlattenRowType()
for Table & SQL
|
FlinkFnApi.CoderInfoDescriptor.FlattenRowTypeOrBuilder |
getFlattenRowTypeOrBuilder()
for Table & SQL
|
FlinkFnApi.CoderInfoDescriptor.Mode |
getMode()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.Mode mode = 6; |
int |
getModeValue()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.Mode mode = 6; |
FlinkFnApi.CoderInfoDescriptor.OverWindowArrowType |
getOverWindowArrowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.OverWindowArrowType over_window_arrow_type = 4; |
FlinkFnApi.CoderInfoDescriptor.OverWindowArrowTypeOrBuilder |
getOverWindowArrowTypeOrBuilder()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.OverWindowArrowType over_window_arrow_type = 4; |
com.google.protobuf.Parser<FlinkFnApi.CoderInfoDescriptor> |
getParserForType() |
FlinkFnApi.CoderInfoDescriptor.RawType |
getRawType()
for DataStream
|
FlinkFnApi.CoderInfoDescriptor.RawTypeOrBuilder |
getRawTypeOrBuilder()
for DataStream
|
FlinkFnApi.CoderInfoDescriptor.RowType |
getRowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RowType row_type = 2; |
FlinkFnApi.CoderInfoDescriptor.RowTypeOrBuilder |
getRowTypeOrBuilder()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RowType row_type = 2; |
boolean |
getSeparatedWithEndMessage()
append an end message (0x00) after serializing the records belonging to the same batch.
|
int |
getSerializedSize() |
com.google.protobuf.UnknownFieldSet |
getUnknownFields() |
boolean |
hasArrowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.ArrowType arrow_type = 3; |
boolean |
hasFlattenRowType()
for Table & SQL
|
int |
hashCode() |
boolean |
hasOverWindowArrowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.OverWindowArrowType over_window_arrow_type = 4; |
boolean |
hasRawType()
for DataStream
|
boolean |
hasRowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RowType row_type = 2; |
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable |
internalGetFieldAccessorTable() |
boolean |
isInitialized() |
static FlinkFnApi.CoderInfoDescriptor.Builder |
newBuilder() |
static FlinkFnApi.CoderInfoDescriptor.Builder |
newBuilder(FlinkFnApi.CoderInfoDescriptor prototype) |
FlinkFnApi.CoderInfoDescriptor.Builder |
newBuilderForType() |
protected FlinkFnApi.CoderInfoDescriptor.Builder |
newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) |
protected Object |
newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused) |
static FlinkFnApi.CoderInfoDescriptor |
parseDelimitedFrom(InputStream input) |
static FlinkFnApi.CoderInfoDescriptor |
parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.CoderInfoDescriptor |
parseFrom(byte[] data) |
static FlinkFnApi.CoderInfoDescriptor |
parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.CoderInfoDescriptor |
parseFrom(ByteBuffer data) |
static FlinkFnApi.CoderInfoDescriptor |
parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.CoderInfoDescriptor |
parseFrom(com.google.protobuf.ByteString data) |
static FlinkFnApi.CoderInfoDescriptor |
parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.CoderInfoDescriptor |
parseFrom(com.google.protobuf.CodedInputStream input) |
static FlinkFnApi.CoderInfoDescriptor |
parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.CoderInfoDescriptor |
parseFrom(InputStream input) |
static FlinkFnApi.CoderInfoDescriptor |
parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static com.google.protobuf.Parser<FlinkFnApi.CoderInfoDescriptor> |
parser() |
FlinkFnApi.CoderInfoDescriptor.Builder |
toBuilder() |
void |
writeTo(com.google.protobuf.CodedOutputStream output) |
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, hasField, hasOneof, internalGetMapField, isStringEmpty, makeExtensionsImmutable, 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 FLATTEN_ROW_TYPE_FIELD_NUMBER
public static final int ROW_TYPE_FIELD_NUMBER
public static final int ARROW_TYPE_FIELD_NUMBER
public static final int OVER_WINDOW_ARROW_TYPE_FIELD_NUMBER
public static final int RAW_TYPE_FIELD_NUMBER
public static final int MODE_FIELD_NUMBER
public static final int SEPARATED_WITH_END_MESSAGE_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 FlinkFnApi.CoderInfoDescriptor.DataTypeCase getDataTypeCase()
getDataTypeCase
in interface FlinkFnApi.CoderInfoDescriptorOrBuilder
public boolean hasFlattenRowType()
for Table & SQL
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.FlattenRowType flatten_row_type = 1;
hasFlattenRowType
in interface FlinkFnApi.CoderInfoDescriptorOrBuilder
public FlinkFnApi.CoderInfoDescriptor.FlattenRowType getFlattenRowType()
for Table & SQL
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.FlattenRowType flatten_row_type = 1;
getFlattenRowType
in interface FlinkFnApi.CoderInfoDescriptorOrBuilder
public FlinkFnApi.CoderInfoDescriptor.FlattenRowTypeOrBuilder getFlattenRowTypeOrBuilder()
for Table & SQL
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.FlattenRowType flatten_row_type = 1;
getFlattenRowTypeOrBuilder
in interface FlinkFnApi.CoderInfoDescriptorOrBuilder
public boolean hasRowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RowType row_type = 2;
hasRowType
in interface FlinkFnApi.CoderInfoDescriptorOrBuilder
public FlinkFnApi.CoderInfoDescriptor.RowType getRowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RowType row_type = 2;
getRowType
in interface FlinkFnApi.CoderInfoDescriptorOrBuilder
public FlinkFnApi.CoderInfoDescriptor.RowTypeOrBuilder getRowTypeOrBuilder()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RowType row_type = 2;
getRowTypeOrBuilder
in interface FlinkFnApi.CoderInfoDescriptorOrBuilder
public boolean hasArrowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.ArrowType arrow_type = 3;
hasArrowType
in interface FlinkFnApi.CoderInfoDescriptorOrBuilder
public FlinkFnApi.CoderInfoDescriptor.ArrowType getArrowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.ArrowType arrow_type = 3;
getArrowType
in interface FlinkFnApi.CoderInfoDescriptorOrBuilder
public FlinkFnApi.CoderInfoDescriptor.ArrowTypeOrBuilder getArrowTypeOrBuilder()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.ArrowType arrow_type = 3;
getArrowTypeOrBuilder
in interface FlinkFnApi.CoderInfoDescriptorOrBuilder
public boolean hasOverWindowArrowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.OverWindowArrowType over_window_arrow_type = 4;
hasOverWindowArrowType
in interface FlinkFnApi.CoderInfoDescriptorOrBuilder
public FlinkFnApi.CoderInfoDescriptor.OverWindowArrowType getOverWindowArrowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.OverWindowArrowType over_window_arrow_type = 4;
getOverWindowArrowType
in interface FlinkFnApi.CoderInfoDescriptorOrBuilder
public FlinkFnApi.CoderInfoDescriptor.OverWindowArrowTypeOrBuilder getOverWindowArrowTypeOrBuilder()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.OverWindowArrowType over_window_arrow_type = 4;
getOverWindowArrowTypeOrBuilder
in interface FlinkFnApi.CoderInfoDescriptorOrBuilder
public boolean hasRawType()
for DataStream
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RawType raw_type = 5;
hasRawType
in interface FlinkFnApi.CoderInfoDescriptorOrBuilder
public FlinkFnApi.CoderInfoDescriptor.RawType getRawType()
for DataStream
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RawType raw_type = 5;
getRawType
in interface FlinkFnApi.CoderInfoDescriptorOrBuilder
public FlinkFnApi.CoderInfoDescriptor.RawTypeOrBuilder getRawTypeOrBuilder()
for DataStream
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RawType raw_type = 5;
getRawTypeOrBuilder
in interface FlinkFnApi.CoderInfoDescriptorOrBuilder
public int getModeValue()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.Mode mode = 6;
getModeValue
in interface FlinkFnApi.CoderInfoDescriptorOrBuilder
public FlinkFnApi.CoderInfoDescriptor.Mode getMode()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.Mode mode = 6;
getMode
in interface FlinkFnApi.CoderInfoDescriptorOrBuilder
public boolean getSeparatedWithEndMessage()
append an end message (0x00) after serializing the records belonging to the same batch.
bool separated_with_end_message = 7;
getSeparatedWithEndMessage
in interface FlinkFnApi.CoderInfoDescriptorOrBuilder
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.CoderInfoDescriptor parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static FlinkFnApi.CoderInfoDescriptor parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static FlinkFnApi.CoderInfoDescriptor parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static FlinkFnApi.CoderInfoDescriptor parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static FlinkFnApi.CoderInfoDescriptor parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static FlinkFnApi.CoderInfoDescriptor parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static FlinkFnApi.CoderInfoDescriptor parseFrom(InputStream input) throws IOException
IOException
public static FlinkFnApi.CoderInfoDescriptor parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public static FlinkFnApi.CoderInfoDescriptor parseDelimitedFrom(InputStream input) throws IOException
IOException
public static FlinkFnApi.CoderInfoDescriptor parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public static FlinkFnApi.CoderInfoDescriptor parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
IOException
public static FlinkFnApi.CoderInfoDescriptor parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public FlinkFnApi.CoderInfoDescriptor.Builder newBuilderForType()
newBuilderForType
in interface com.google.protobuf.Message
newBuilderForType
in interface com.google.protobuf.MessageLite
public static FlinkFnApi.CoderInfoDescriptor.Builder newBuilder()
public static FlinkFnApi.CoderInfoDescriptor.Builder newBuilder(FlinkFnApi.CoderInfoDescriptor prototype)
public FlinkFnApi.CoderInfoDescriptor.Builder toBuilder()
toBuilder
in interface com.google.protobuf.Message
toBuilder
in interface com.google.protobuf.MessageLite
protected FlinkFnApi.CoderInfoDescriptor.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
newBuilderForType
in class com.google.protobuf.GeneratedMessageV3
public static FlinkFnApi.CoderInfoDescriptor getDefaultInstance()
public static com.google.protobuf.Parser<FlinkFnApi.CoderInfoDescriptor> parser()
public com.google.protobuf.Parser<FlinkFnApi.CoderInfoDescriptor> getParserForType()
getParserForType
in interface com.google.protobuf.Message
getParserForType
in interface com.google.protobuf.MessageLite
getParserForType
in class com.google.protobuf.GeneratedMessageV3
public FlinkFnApi.CoderInfoDescriptor 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.