Re: [PR] [INLONG-9560][Sort] Support rowdata way for all sort message format [inlong]
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)
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]
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