Re: [PR] [INLONG-9560][Sort] Support rowdata way for all sort message format [inlong]

2024-01-15 Thread via GitHub


EMsnap merged PR #9573:
URL: https://github.com/apache/inlong/pull/9573


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscr...@inlong.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org



(inlong) branch master updated: [INLONG-9560][Sort]Support rowdata way for all sort message format (#9573)

2024-01-15 Thread zirui
This is an automated email from the ASF dual-hosted git repository.

zirui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
 new 4864117038 [INLONG-9560][Sort]Support rowdata way for all sort message 
format (#9573)
4864117038 is described below

commit 48641170384d37db31c82f1f97c389cef4d7c691
Author: baomingyu 
AuthorDate: Mon Jan 15 16:30:21 2024 +0800

[INLONG-9560][Sort]Support rowdata way for all sort message format (#9573)
---
 .../{ => format-row}/format-base/pom.xml   |  6 +--
 .../formats/base/DefaultDeserializationSchema.java |  0
 .../formats/base/DefaultSerializationSchema.java   |  0
 .../base/DefaultTableFormatDeserializer.java   |  0
 .../formats/base/DefaultTableFormatSerializer.java |  0
 .../inlong/sort/formats/base/FormatDescriptor.java |  0
 .../formats/base/FormatDescriptorValidator.java|  0
 .../ProjectedDeserializationSchemaFactory.java |  0
 .../base/ProjectedSerializationSchemaFactory.java  |  0
 .../sort/formats/base/TableFormatConstants.java|  0
 .../sort/formats/base/TableFormatDeserializer.java |  0
 .../base/TableFormatDeserializerFactory.java   |  0
 .../sort/formats/base/TableFormatSerializer.java   |  0
 .../formats/base/TableFormatSerializerFactory.java |  0
 .../inlong/sort/formats/base/TableFormatUtils.java |  0
 .../sort/formats/base/TextFormatBuilder.java   |  0
 .../sort/formats/base/TextFormatDescriptor.java|  0
 .../base/TextFormatDescriptorValidator.java|  0
 .../base/collectors/TimestampedCollector.java  |  0
 .../inlong/sort/formats/base/util/LogCounter.java  |  0
 .../sort/formats/base/TableFormatUtilsTest.java|  0
 .../{ => format-row}/format-csv/pom.xml|  6 +--
 .../org/apache/inlong/sort/formats/csv/Csv.java|  0
 .../sort/formats/csv/CsvDeserializationSchema.java |  0
 .../inlong/sort/formats/csv/CsvFormatBuilder.java  |  0
 .../inlong/sort/formats/csv/CsvFormatFactory.java  |  0
 .../sort/formats/csv/CsvSerializationSchema.java   |  0
 .../inlong/sort/formats/csv/CsvValidator.java  |  0
 .../org.apache.flink.table.factories.TableFactory  |  0
 .../formats/csv/CsvDeserializationSchemaTest.java  |  0
 .../sort/formats/csv/CsvFormatFactoryTest.java |  0
 .../formats/csv/CsvSerializationSchemaTest.java|  0
 .../apache/inlong/sort/formats/csv/CsvTest.java|  0
 .../inlong/sort/formats/csv/CsvUtilsTest.java  |  0
 .../{ => format-row}/format-inlongmsg-base/pom.xml |  6 +--
 .../AbstractInLongMsgFormatDeserializer.java   |  0
 .../AbstractInLongMsgMixedFormatConverter.java |  0
 .../AbstractInLongMsgMixedFormatDeserializer.java  |  0
 .../sort/formats/inlongmsg/FailureHandler.java |  0
 .../formats/inlongmsg/IgnoreFailureHandler.java|  0
 .../sort/formats/inlongmsg/InLongMsgBody.java  |  0
 .../formats/inlongmsg/InLongMsgDecodingFormat.java |  0
 .../inlongmsg/InLongMsgDeserializationSchema.java  |  0
 .../formats/inlongmsg/InLongMsgFormatFactory.java  |  0
 .../sort/formats/inlongmsg/InLongMsgHead.java  |  0
 .../inlongmsg/InLongMsgMixedFormatConverter.java   |  0
 .../InLongMsgMixedFormatConverterBuilder.java  |  0
 .../InLongMsgMixedFormatConverterValidator.java|  0
 .../InLongMsgMixedFormatDeserializerValidator.java |  0
 .../inlongmsg/InLongMsgMixedFormatFactory.java |  0
 .../formats/inlongmsg/InLongMsgMixedValidator.java |  0
 .../sort/formats/inlongmsg/InLongMsgOptions.java   |  0
 ...nLongMsgTextMixedFormatDeserializerBuilder.java |  0
 .../sort/formats/inlongmsg/InLongMsgUtils.java |  0
 .../sort/formats/inlongmsg/InLongMsgValidator.java |  0
 .../sort/formats/inlongmsg/NoOpFailureHandler.java |  0
 .../org.apache.flink.table.factories.Factory   |  0
 .../inlongmsg/InLongMsgFormatFactoryTest.java  |  0
 .../inlongmsg/InLongMsgRowDataSerDeTest.java   |  0
 .../org.apache.flink.table.factories.Factory   |  0
 .../{ => format-row}/format-inlongmsg-csv/pom.xml  |  6 +--
 .../sort/formats/inlongmsgcsv/InLongMsgCsv.java|  0
 .../InLongMsgCsvFormatDeserializer.java|  0
 .../inlongmsgcsv/InLongMsgCsvFormatFactory.java|  0
 .../InLongMsgCsvMixedFormatConverter.java  |  0
 .../InLongMsgCsvMixedFormatDeserializer.java   |  0
 .../formats/inlongmsgcsv/InLongMsgCsvUtils.java|  0
 .../inlongmsgcsv/InLongMsgCsvValidator.java|  0
 .../org.apache.flink.table.factories.TableFactory  |  0
 .../InLongMsgCsvFormatDeserializerTest.java|  0
 .../InLongMsgCsvFormatFactoryTest.java |  0
 .../formats/inlongmsgcsv/InLongMsgCsvTest.java |  0
 .../{ => format-row}/format-inlongmsg-kv/pom.xml   |  6 +--
 .../sort/formats/inlongmsgkv/InLongMsgKv.java  |  0
 .../inlongmsgkv/InLongMsgKvFormatDeserializer.java |  0
 .../inlongmsgkv/InLongMsgKvFormatFactory.java  |  0
 .../InLongMsgKvMixedFormatConverter.java   |  0
 .../InLongMsgKvMixedFormatD

[PR] [INLONG-9571][Sort] Support row way of sort InLong message binlog format [inlong]

2024-01-15 Thread via GitHub


baomingyu opened a new pull request, #9579:
URL: https://github.com/apache/inlong/pull/9579

   ### Prepare a Pull Request
Support row way of sort InLong message binlog format
   
   - Fixes #9571
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscr...@inlong.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org