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, 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, writeStringNoTagfindInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toStringaddAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeToclone, finalize, getClass, notify, notifyAll, wait, wait, waitpublic 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.GeneratedMessageV3public final com.google.protobuf.UnknownFieldSet getUnknownFields()
getUnknownFields in interface com.google.protobuf.MessageOrBuildergetUnknownFields in class com.google.protobuf.GeneratedMessageV3public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessageV3public FlinkFnApi.CoderInfoDescriptor.DataTypeCase getDataTypeCase()
getDataTypeCase in interface FlinkFnApi.CoderInfoDescriptorOrBuilderpublic boolean hasFlattenRowType()
for Table & SQL
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.FlattenRowType flatten_row_type = 1;hasFlattenRowType in interface FlinkFnApi.CoderInfoDescriptorOrBuilderpublic FlinkFnApi.CoderInfoDescriptor.FlattenRowType getFlattenRowType()
for Table & SQL
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.FlattenRowType flatten_row_type = 1;getFlattenRowType in interface FlinkFnApi.CoderInfoDescriptorOrBuilderpublic FlinkFnApi.CoderInfoDescriptor.FlattenRowTypeOrBuilder getFlattenRowTypeOrBuilder()
for Table & SQL
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.FlattenRowType flatten_row_type = 1;getFlattenRowTypeOrBuilder in interface FlinkFnApi.CoderInfoDescriptorOrBuilderpublic boolean hasRowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RowType row_type = 2;hasRowType in interface FlinkFnApi.CoderInfoDescriptorOrBuilderpublic FlinkFnApi.CoderInfoDescriptor.RowType getRowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RowType row_type = 2;getRowType in interface FlinkFnApi.CoderInfoDescriptorOrBuilderpublic FlinkFnApi.CoderInfoDescriptor.RowTypeOrBuilder getRowTypeOrBuilder()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RowType row_type = 2;getRowTypeOrBuilder in interface FlinkFnApi.CoderInfoDescriptorOrBuilderpublic boolean hasArrowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.ArrowType arrow_type = 3;hasArrowType in interface FlinkFnApi.CoderInfoDescriptorOrBuilderpublic FlinkFnApi.CoderInfoDescriptor.ArrowType getArrowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.ArrowType arrow_type = 3;getArrowType in interface FlinkFnApi.CoderInfoDescriptorOrBuilderpublic FlinkFnApi.CoderInfoDescriptor.ArrowTypeOrBuilder getArrowTypeOrBuilder()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.ArrowType arrow_type = 3;getArrowTypeOrBuilder in interface FlinkFnApi.CoderInfoDescriptorOrBuilderpublic boolean hasOverWindowArrowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.OverWindowArrowType over_window_arrow_type = 4;hasOverWindowArrowType in interface FlinkFnApi.CoderInfoDescriptorOrBuilderpublic FlinkFnApi.CoderInfoDescriptor.OverWindowArrowType getOverWindowArrowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.OverWindowArrowType over_window_arrow_type = 4;getOverWindowArrowType in interface FlinkFnApi.CoderInfoDescriptorOrBuilderpublic FlinkFnApi.CoderInfoDescriptor.OverWindowArrowTypeOrBuilder getOverWindowArrowTypeOrBuilder()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.OverWindowArrowType over_window_arrow_type = 4;getOverWindowArrowTypeOrBuilder in interface FlinkFnApi.CoderInfoDescriptorOrBuilderpublic boolean hasRawType()
for DataStream
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RawType raw_type = 5;hasRawType in interface FlinkFnApi.CoderInfoDescriptorOrBuilderpublic FlinkFnApi.CoderInfoDescriptor.RawType getRawType()
for DataStream
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RawType raw_type = 5;getRawType in interface FlinkFnApi.CoderInfoDescriptorOrBuilderpublic FlinkFnApi.CoderInfoDescriptor.RawTypeOrBuilder getRawTypeOrBuilder()
for DataStream
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RawType raw_type = 5;getRawTypeOrBuilder in interface FlinkFnApi.CoderInfoDescriptorOrBuilderpublic int getModeValue()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.Mode mode = 6;getModeValue in interface FlinkFnApi.CoderInfoDescriptorOrBuilderpublic FlinkFnApi.CoderInfoDescriptor.Mode getMode()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.Mode mode = 6;getMode in interface FlinkFnApi.CoderInfoDescriptorOrBuilderpublic 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.CoderInfoDescriptorOrBuilderpublic final boolean isInitialized()
isInitialized in interface com.google.protobuf.MessageLiteOrBuilderisInitialized in class com.google.protobuf.GeneratedMessageV3public void writeTo(com.google.protobuf.CodedOutputStream output)
throws IOException
writeTo in interface com.google.protobuf.MessageLitewriteTo in class com.google.protobuf.GeneratedMessageV3IOExceptionpublic int getSerializedSize()
getSerializedSize in interface com.google.protobuf.MessageLitegetSerializedSize in class com.google.protobuf.GeneratedMessageV3public boolean equals(Object obj)
equals in interface com.google.protobuf.Messageequals in class com.google.protobuf.AbstractMessagepublic int hashCode()
hashCode in interface com.google.protobuf.MessagehashCode in class com.google.protobuf.AbstractMessagepublic static FlinkFnApi.CoderInfoDescriptor parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static FlinkFnApi.CoderInfoDescriptor parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static FlinkFnApi.CoderInfoDescriptor parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static FlinkFnApi.CoderInfoDescriptor parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static FlinkFnApi.CoderInfoDescriptor parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static FlinkFnApi.CoderInfoDescriptor parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static FlinkFnApi.CoderInfoDescriptor parseFrom(InputStream input) throws IOException
IOExceptionpublic static FlinkFnApi.CoderInfoDescriptor parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOExceptionpublic static FlinkFnApi.CoderInfoDescriptor parseDelimitedFrom(InputStream input) throws IOException
IOExceptionpublic static FlinkFnApi.CoderInfoDescriptor parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOExceptionpublic static FlinkFnApi.CoderInfoDescriptor parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
IOExceptionpublic static FlinkFnApi.CoderInfoDescriptor parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOExceptionpublic FlinkFnApi.CoderInfoDescriptor.Builder newBuilderForType()
newBuilderForType in interface com.google.protobuf.MessagenewBuilderForType in interface com.google.protobuf.MessageLitepublic 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.MessagetoBuilder in interface com.google.protobuf.MessageLiteprotected FlinkFnApi.CoderInfoDescriptor.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
newBuilderForType in class com.google.protobuf.GeneratedMessageV3public 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.MessagegetParserForType in interface com.google.protobuf.MessageLitegetParserForType in class com.google.protobuf.GeneratedMessageV3public FlinkFnApi.CoderInfoDescriptor getDefaultInstanceForType()
getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuildergetDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilderCopyright © 2014–2021 The Apache Software Foundation. All rights reserved.