public static final class FlinkFnApi.CoderInfoDescriptor.Builder extends com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.CoderInfoDescriptor.Builder> implements FlinkFnApi.CoderInfoDescriptorOrBuilder
A representation of the coderProtobuf type
org.apache.flink.fn_execution.v1.CoderInfoDescriptor
Modifier and Type | Method and Description |
---|---|
FlinkFnApi.CoderInfoDescriptor.Builder |
addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
FlinkFnApi.CoderInfoDescriptor |
build() |
FlinkFnApi.CoderInfoDescriptor |
buildPartial() |
FlinkFnApi.CoderInfoDescriptor.Builder |
clear() |
FlinkFnApi.CoderInfoDescriptor.Builder |
clearArrowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.ArrowType arrow_type = 3; |
FlinkFnApi.CoderInfoDescriptor.Builder |
clearDataType() |
FlinkFnApi.CoderInfoDescriptor.Builder |
clearField(com.google.protobuf.Descriptors.FieldDescriptor field) |
FlinkFnApi.CoderInfoDescriptor.Builder |
clearFlattenRowType()
for Table & SQL
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.FlattenRowType flatten_row_type = 1; |
FlinkFnApi.CoderInfoDescriptor.Builder |
clearMode()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.Mode mode = 6; |
FlinkFnApi.CoderInfoDescriptor.Builder |
clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) |
FlinkFnApi.CoderInfoDescriptor.Builder |
clearOverWindowArrowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.OverWindowArrowType over_window_arrow_type = 4; |
FlinkFnApi.CoderInfoDescriptor.Builder |
clearRawType()
for DataStream
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RawType raw_type = 5; |
FlinkFnApi.CoderInfoDescriptor.Builder |
clearRowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RowType row_type = 2; |
FlinkFnApi.CoderInfoDescriptor.Builder |
clearSeparatedWithEndMessage()
append an end message (0x00) after serializing the records belonging to the same batch.
|
FlinkFnApi.CoderInfoDescriptor.Builder |
clone() |
FlinkFnApi.CoderInfoDescriptor.ArrowType |
getArrowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.ArrowType arrow_type = 3; |
FlinkFnApi.CoderInfoDescriptor.ArrowType.Builder |
getArrowTypeBuilder()
.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() |
FlinkFnApi.CoderInfoDescriptor |
getDefaultInstanceForType() |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
com.google.protobuf.Descriptors.Descriptor |
getDescriptorForType() |
FlinkFnApi.CoderInfoDescriptor.FlattenRowType |
getFlattenRowType()
for Table & SQL
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.FlattenRowType flatten_row_type = 1; |
FlinkFnApi.CoderInfoDescriptor.FlattenRowType.Builder |
getFlattenRowTypeBuilder()
for Table & SQL
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.FlattenRowType flatten_row_type = 1; |
FlinkFnApi.CoderInfoDescriptor.FlattenRowTypeOrBuilder |
getFlattenRowTypeOrBuilder()
for Table & SQL
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.FlattenRowType flatten_row_type = 1; |
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.OverWindowArrowType.Builder |
getOverWindowArrowTypeBuilder()
.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; |
FlinkFnApi.CoderInfoDescriptor.RawType |
getRawType()
for DataStream
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RawType raw_type = 5; |
FlinkFnApi.CoderInfoDescriptor.RawType.Builder |
getRawTypeBuilder()
for DataStream
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RawType raw_type = 5; |
FlinkFnApi.CoderInfoDescriptor.RawTypeOrBuilder |
getRawTypeOrBuilder()
for DataStream
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RawType raw_type = 5; |
FlinkFnApi.CoderInfoDescriptor.RowType |
getRowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RowType row_type = 2; |
FlinkFnApi.CoderInfoDescriptor.RowType.Builder |
getRowTypeBuilder()
.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.
|
boolean |
hasArrowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.ArrowType arrow_type = 3; |
boolean |
hasFlattenRowType()
for Table & SQL
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.FlattenRowType flatten_row_type = 1; |
boolean |
hasOverWindowArrowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.OverWindowArrowType over_window_arrow_type = 4; |
boolean |
hasRawType()
for DataStream
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RawType raw_type = 5; |
boolean |
hasRowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RowType row_type = 2; |
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable |
internalGetFieldAccessorTable() |
boolean |
isInitialized() |
FlinkFnApi.CoderInfoDescriptor.Builder |
mergeArrowType(FlinkFnApi.CoderInfoDescriptor.ArrowType value)
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.ArrowType arrow_type = 3; |
FlinkFnApi.CoderInfoDescriptor.Builder |
mergeFlattenRowType(FlinkFnApi.CoderInfoDescriptor.FlattenRowType value)
for Table & SQL
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.FlattenRowType flatten_row_type = 1; |
FlinkFnApi.CoderInfoDescriptor.Builder |
mergeFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
FlinkFnApi.CoderInfoDescriptor.Builder |
mergeFrom(FlinkFnApi.CoderInfoDescriptor other) |
FlinkFnApi.CoderInfoDescriptor.Builder |
mergeFrom(com.google.protobuf.Message other) |
FlinkFnApi.CoderInfoDescriptor.Builder |
mergeOverWindowArrowType(FlinkFnApi.CoderInfoDescriptor.OverWindowArrowType value)
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.OverWindowArrowType over_window_arrow_type = 4; |
FlinkFnApi.CoderInfoDescriptor.Builder |
mergeRawType(FlinkFnApi.CoderInfoDescriptor.RawType value)
for DataStream
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RawType raw_type = 5; |
FlinkFnApi.CoderInfoDescriptor.Builder |
mergeRowType(FlinkFnApi.CoderInfoDescriptor.RowType value)
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RowType row_type = 2; |
FlinkFnApi.CoderInfoDescriptor.Builder |
mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
FlinkFnApi.CoderInfoDescriptor.Builder |
setArrowType(FlinkFnApi.CoderInfoDescriptor.ArrowType.Builder builderForValue)
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.ArrowType arrow_type = 3; |
FlinkFnApi.CoderInfoDescriptor.Builder |
setArrowType(FlinkFnApi.CoderInfoDescriptor.ArrowType value)
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.ArrowType arrow_type = 3; |
FlinkFnApi.CoderInfoDescriptor.Builder |
setField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
FlinkFnApi.CoderInfoDescriptor.Builder |
setFlattenRowType(FlinkFnApi.CoderInfoDescriptor.FlattenRowType.Builder builderForValue)
for Table & SQL
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.FlattenRowType flatten_row_type = 1; |
FlinkFnApi.CoderInfoDescriptor.Builder |
setFlattenRowType(FlinkFnApi.CoderInfoDescriptor.FlattenRowType value)
for Table & SQL
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.FlattenRowType flatten_row_type = 1; |
FlinkFnApi.CoderInfoDescriptor.Builder |
setMode(FlinkFnApi.CoderInfoDescriptor.Mode value)
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.Mode mode = 6; |
FlinkFnApi.CoderInfoDescriptor.Builder |
setModeValue(int value)
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.Mode mode = 6; |
FlinkFnApi.CoderInfoDescriptor.Builder |
setOverWindowArrowType(FlinkFnApi.CoderInfoDescriptor.OverWindowArrowType.Builder builderForValue)
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.OverWindowArrowType over_window_arrow_type = 4; |
FlinkFnApi.CoderInfoDescriptor.Builder |
setOverWindowArrowType(FlinkFnApi.CoderInfoDescriptor.OverWindowArrowType value)
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.OverWindowArrowType over_window_arrow_type = 4; |
FlinkFnApi.CoderInfoDescriptor.Builder |
setRawType(FlinkFnApi.CoderInfoDescriptor.RawType.Builder builderForValue)
for DataStream
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RawType raw_type = 5; |
FlinkFnApi.CoderInfoDescriptor.Builder |
setRawType(FlinkFnApi.CoderInfoDescriptor.RawType value)
for DataStream
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RawType raw_type = 5; |
FlinkFnApi.CoderInfoDescriptor.Builder |
setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
int index,
Object value) |
FlinkFnApi.CoderInfoDescriptor.Builder |
setRowType(FlinkFnApi.CoderInfoDescriptor.RowType.Builder builderForValue)
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RowType row_type = 2; |
FlinkFnApi.CoderInfoDescriptor.Builder |
setRowType(FlinkFnApi.CoderInfoDescriptor.RowType value)
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RowType row_type = 2; |
FlinkFnApi.CoderInfoDescriptor.Builder |
setSeparatedWithEndMessage(boolean value)
append an end message (0x00) after serializing the records belonging to the same batch.
|
FlinkFnApi.CoderInfoDescriptor.Builder |
setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getParentForChildren, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, getUnknownFieldSetBuilder, hasField, hasOneof, internalGetMapField, internalGetMutableMapField, isClean, markClean, mergeUnknownLengthDelimitedField, mergeUnknownVarintField, newBuilderForField, onBuilt, onChanged, parseUnknownField, setUnknownFieldSetBuilder, setUnknownFieldsProto3
findInitializationErrors, getInitializationErrorString, internalMergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, newUninitializedMessageException, toString
addAll, addAll, mergeDelimitedFrom, mergeDelimitedFrom, newUninitializedMessageException
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
internalGetFieldAccessorTable
in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.CoderInfoDescriptor.Builder>
public FlinkFnApi.CoderInfoDescriptor.Builder clear()
clear
in interface com.google.protobuf.Message.Builder
clear
in interface com.google.protobuf.MessageLite.Builder
clear
in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.CoderInfoDescriptor.Builder>
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
getDescriptorForType
in interface com.google.protobuf.Message.Builder
getDescriptorForType
in interface com.google.protobuf.MessageOrBuilder
getDescriptorForType
in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.CoderInfoDescriptor.Builder>
public FlinkFnApi.CoderInfoDescriptor getDefaultInstanceForType()
getDefaultInstanceForType
in interface com.google.protobuf.MessageLiteOrBuilder
getDefaultInstanceForType
in interface com.google.protobuf.MessageOrBuilder
public FlinkFnApi.CoderInfoDescriptor build()
build
in interface com.google.protobuf.Message.Builder
build
in interface com.google.protobuf.MessageLite.Builder
public FlinkFnApi.CoderInfoDescriptor buildPartial()
buildPartial
in interface com.google.protobuf.Message.Builder
buildPartial
in interface com.google.protobuf.MessageLite.Builder
public FlinkFnApi.CoderInfoDescriptor.Builder clone()
clone
in interface com.google.protobuf.Message.Builder
clone
in interface com.google.protobuf.MessageLite.Builder
clone
in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.CoderInfoDescriptor.Builder>
public FlinkFnApi.CoderInfoDescriptor.Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
setField
in interface com.google.protobuf.Message.Builder
setField
in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.CoderInfoDescriptor.Builder>
public FlinkFnApi.CoderInfoDescriptor.Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field)
clearField
in interface com.google.protobuf.Message.Builder
clearField
in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.CoderInfoDescriptor.Builder>
public FlinkFnApi.CoderInfoDescriptor.Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)
clearOneof
in interface com.google.protobuf.Message.Builder
clearOneof
in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.CoderInfoDescriptor.Builder>
public FlinkFnApi.CoderInfoDescriptor.Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value)
setRepeatedField
in interface com.google.protobuf.Message.Builder
setRepeatedField
in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.CoderInfoDescriptor.Builder>
public FlinkFnApi.CoderInfoDescriptor.Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
addRepeatedField
in interface com.google.protobuf.Message.Builder
addRepeatedField
in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.CoderInfoDescriptor.Builder>
public FlinkFnApi.CoderInfoDescriptor.Builder mergeFrom(com.google.protobuf.Message other)
mergeFrom
in interface com.google.protobuf.Message.Builder
mergeFrom
in class com.google.protobuf.AbstractMessage.Builder<FlinkFnApi.CoderInfoDescriptor.Builder>
public FlinkFnApi.CoderInfoDescriptor.Builder mergeFrom(FlinkFnApi.CoderInfoDescriptor other)
public final boolean isInitialized()
isInitialized
in interface com.google.protobuf.MessageLiteOrBuilder
isInitialized
in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.CoderInfoDescriptor.Builder>
public FlinkFnApi.CoderInfoDescriptor.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
mergeFrom
in interface com.google.protobuf.Message.Builder
mergeFrom
in interface com.google.protobuf.MessageLite.Builder
mergeFrom
in class com.google.protobuf.AbstractMessage.Builder<FlinkFnApi.CoderInfoDescriptor.Builder>
IOException
public FlinkFnApi.CoderInfoDescriptor.DataTypeCase getDataTypeCase()
getDataTypeCase
in interface FlinkFnApi.CoderInfoDescriptorOrBuilder
public FlinkFnApi.CoderInfoDescriptor.Builder clearDataType()
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.Builder setFlattenRowType(FlinkFnApi.CoderInfoDescriptor.FlattenRowType value)
for Table & SQL
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.FlattenRowType flatten_row_type = 1;
public FlinkFnApi.CoderInfoDescriptor.Builder setFlattenRowType(FlinkFnApi.CoderInfoDescriptor.FlattenRowType.Builder builderForValue)
for Table & SQL
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.FlattenRowType flatten_row_type = 1;
public FlinkFnApi.CoderInfoDescriptor.Builder mergeFlattenRowType(FlinkFnApi.CoderInfoDescriptor.FlattenRowType value)
for Table & SQL
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.FlattenRowType flatten_row_type = 1;
public FlinkFnApi.CoderInfoDescriptor.Builder clearFlattenRowType()
for Table & SQL
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.FlattenRowType flatten_row_type = 1;
public FlinkFnApi.CoderInfoDescriptor.FlattenRowType.Builder getFlattenRowTypeBuilder()
for Table & SQL
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.FlattenRowType flatten_row_type = 1;
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.Builder setRowType(FlinkFnApi.CoderInfoDescriptor.RowType value)
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RowType row_type = 2;
public FlinkFnApi.CoderInfoDescriptor.Builder setRowType(FlinkFnApi.CoderInfoDescriptor.RowType.Builder builderForValue)
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RowType row_type = 2;
public FlinkFnApi.CoderInfoDescriptor.Builder mergeRowType(FlinkFnApi.CoderInfoDescriptor.RowType value)
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RowType row_type = 2;
public FlinkFnApi.CoderInfoDescriptor.Builder clearRowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RowType row_type = 2;
public FlinkFnApi.CoderInfoDescriptor.RowType.Builder getRowTypeBuilder()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RowType row_type = 2;
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.Builder setArrowType(FlinkFnApi.CoderInfoDescriptor.ArrowType value)
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.ArrowType arrow_type = 3;
public FlinkFnApi.CoderInfoDescriptor.Builder setArrowType(FlinkFnApi.CoderInfoDescriptor.ArrowType.Builder builderForValue)
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.ArrowType arrow_type = 3;
public FlinkFnApi.CoderInfoDescriptor.Builder mergeArrowType(FlinkFnApi.CoderInfoDescriptor.ArrowType value)
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.ArrowType arrow_type = 3;
public FlinkFnApi.CoderInfoDescriptor.Builder clearArrowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.ArrowType arrow_type = 3;
public FlinkFnApi.CoderInfoDescriptor.ArrowType.Builder getArrowTypeBuilder()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.ArrowType arrow_type = 3;
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.Builder setOverWindowArrowType(FlinkFnApi.CoderInfoDescriptor.OverWindowArrowType value)
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.OverWindowArrowType over_window_arrow_type = 4;
public FlinkFnApi.CoderInfoDescriptor.Builder setOverWindowArrowType(FlinkFnApi.CoderInfoDescriptor.OverWindowArrowType.Builder builderForValue)
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.OverWindowArrowType over_window_arrow_type = 4;
public FlinkFnApi.CoderInfoDescriptor.Builder mergeOverWindowArrowType(FlinkFnApi.CoderInfoDescriptor.OverWindowArrowType value)
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.OverWindowArrowType over_window_arrow_type = 4;
public FlinkFnApi.CoderInfoDescriptor.Builder clearOverWindowArrowType()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.OverWindowArrowType over_window_arrow_type = 4;
public FlinkFnApi.CoderInfoDescriptor.OverWindowArrowType.Builder getOverWindowArrowTypeBuilder()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.OverWindowArrowType over_window_arrow_type = 4;
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.Builder setRawType(FlinkFnApi.CoderInfoDescriptor.RawType value)
for DataStream
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RawType raw_type = 5;
public FlinkFnApi.CoderInfoDescriptor.Builder setRawType(FlinkFnApi.CoderInfoDescriptor.RawType.Builder builderForValue)
for DataStream
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RawType raw_type = 5;
public FlinkFnApi.CoderInfoDescriptor.Builder mergeRawType(FlinkFnApi.CoderInfoDescriptor.RawType value)
for DataStream
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RawType raw_type = 5;
public FlinkFnApi.CoderInfoDescriptor.Builder clearRawType()
for DataStream
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RawType raw_type = 5;
public FlinkFnApi.CoderInfoDescriptor.RawType.Builder getRawTypeBuilder()
for DataStream
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.RawType raw_type = 5;
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.Builder setModeValue(int value)
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.Mode mode = 6;
value
- The enum numeric value on the wire for mode to set.public FlinkFnApi.CoderInfoDescriptor.Mode getMode()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.Mode mode = 6;
getMode
in interface FlinkFnApi.CoderInfoDescriptorOrBuilder
public FlinkFnApi.CoderInfoDescriptor.Builder setMode(FlinkFnApi.CoderInfoDescriptor.Mode value)
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.Mode mode = 6;
value
- The mode to set.public FlinkFnApi.CoderInfoDescriptor.Builder clearMode()
.org.apache.flink.fn_execution.v1.CoderInfoDescriptor.Mode mode = 6;
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 FlinkFnApi.CoderInfoDescriptor.Builder setSeparatedWithEndMessage(boolean value)
append an end message (0x00) after serializing the records belonging to the same batch.
bool separated_with_end_message = 7;
value
- The separatedWithEndMessage to set.public FlinkFnApi.CoderInfoDescriptor.Builder clearSeparatedWithEndMessage()
append an end message (0x00) after serializing the records belonging to the same batch.
bool separated_with_end_message = 7;
public final FlinkFnApi.CoderInfoDescriptor.Builder setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
setUnknownFields
in interface com.google.protobuf.Message.Builder
setUnknownFields
in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.CoderInfoDescriptor.Builder>
public final FlinkFnApi.CoderInfoDescriptor.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
mergeUnknownFields
in interface com.google.protobuf.Message.Builder
mergeUnknownFields
in class com.google.protobuf.GeneratedMessageV3.Builder<FlinkFnApi.CoderInfoDescriptor.Builder>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.