This is an automated email from the ASF dual-hosted git repository. vinoyang pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/hudi.git.
from e93c6a5 [HUDI-1496] Fixing input stream detection of GCS FileSystem (#2500) add fc6c5f4 [HUDI-1684] Tweak hudi-flink-bundle module pom and reorganize the pacakges for hudi-flink module (#2669) No new revisions were added by this update. Summary of changes: .../{operator => configuration}/FlinkOptions.java | 6 +- .../hudi/schema/FilebasedSchemaProvider.java | 2 +- .../main/java/org/apache/hudi/sink/CommitSink.java | 1 - .../InstantGenerateOperator.java | 8 +- .../KeyedWriteProcessFunction.java | 6 +- .../KeyedWriteProcessOperator.java | 3 +- .../{operator => sink}/StreamWriteFunction.java | 5 +- .../{operator => sink}/StreamWriteOperator.java | 2 +- .../StreamWriteOperatorCoordinator.java | 5 +- .../StreamWriteOperatorFactory.java | 2 +- .../compact/CompactFunction.java | 2 +- .../compact/CompactionCommitEvent.java | 2 +- .../compact/CompactionCommitSink.java | 2 +- .../compact/CompactionPlanEvent.java | 2 +- .../compact/CompactionPlanOperator.java | 2 +- .../event/BatchWriteSuccessEvent.java | 6 +- .../partitioner/BucketAssignFunction.java | 4 +- .../partitioner/BucketAssigner.java | 2 +- .../partitioner/BucketAssigners.java | 4 +- .../partitioner/delta/DeltaBucketAssigner.java | 4 +- .../JsonStringToHoodieRecordMapFunction.java | 2 +- .../transform/RowDataToHoodieFunction.java | 4 +- .../StreamReadMonitoringFunction.java | 11 +- .../{operator => source}/StreamReadOperator.java | 6 +- .../apache/hudi/streamer/HoodieFlinkStreamer.java | 12 +- .../hudi/streamer/HoodieFlinkStreamerV2.java | 8 +- .../{factory => table}/HoodieTableFactory.java | 6 +- .../hudi/{sink => table}/HoodieTableSink.java | 20 +-- .../hudi/{source => table}/HoodieTableSource.java | 20 +-- .../{source => table}/format/FilePathUtils.java | 4 +- .../hudi/{source => table}/format/FormatUtils.java | 6 +- .../format/cow/AbstractColumnReader.java | 2 +- .../format/cow/CopyOnWriteInputFormat.java | 2 +- .../format/cow/Int64TimestampColumnReader.java | 2 +- .../format/cow/ParquetColumnarRowSplitReader.java | 6 +- .../format/cow/ParquetDecimalVector.java | 2 +- .../format/cow/ParquetSplitReaderUtil.java | 2 +- .../format/cow/RunLengthDecoder.java | 2 +- .../{source => table}/format/mor/InstantRange.java | 2 +- .../format/mor/MergeOnReadInputFormat.java | 14 +- .../format/mor/MergeOnReadInputSplit.java | 2 +- .../format/mor/MergeOnReadTableState.java | 2 +- .../apache/hudi/util/RowDataToAvroConverters.java | 9 +- .../java/org/apache/hudi/util/StreamerUtil.java | 2 +- .../org.apache.flink.table.factories.TableFactory | 2 +- .../hudi/{operator => sink}/StreamWriteITCase.java | 22 +-- .../TestStreamWriteOperatorCoordinator.java} | 8 +- .../{operator => sink}/TestWriteCopyOnWrite.java | 11 +- .../{operator => sink}/TestWriteMergeOnRead.java | 4 +- .../TestWriteMergeOnReadWithCompact.java | 3 +- .../partitioner/TestBucketAssigner.java | 4 +- .../TestJsonStringToHoodieRecordMapFunction.java | 2 +- .../utils/CompactFunctionWrapper.java | 14 +- .../utils/MockFunctionInitializationContext.java | 2 +- .../{operator => sink}/utils/MockMapState.java | 2 +- .../utils/MockOperatorStateStore.java | 2 +- .../utils/MockStreamingRuntimeContext.java | 2 +- .../utils/StreamWriteFunctionWrapper.java | 15 +- .../source/TestStreamReadMonitoringFunction.java | 9 +- .../apache/hudi/source/TestStreamReadOperator.java | 16 +- .../{source => table}/HoodieDataSourceITCase.java | 10 +- .../{factory => table}/TestHoodieTableFactory.java | 8 +- .../{source => table}/TestHoodieTableSource.java | 10 +- .../{source => table}/format/TestInputFormat.java | 10 +- .../{operator => }/utils/TestConfigurations.java | 4 +- .../apache/hudi/{operator => }/utils/TestData.java | 5 +- .../test/java/org/apache/hudi/utils/TestUtils.java | 6 +- .../utils/factory/CollectSinkTableFactory.java | 2 +- .../utils/factory/ContinuousFileSourceFactory.java | 2 +- .../hudi/utils/source/ContinuousFileSource.java | 2 +- .../org.apache.flink.table.factories.TableFactory | 2 +- packaging/hudi-flink-bundle/pom.xml | 163 ++++++++++++++++++++- 72 files changed, 357 insertions(+), 203 deletions(-) rename hudi-flink/src/main/java/org/apache/hudi/{operator => configuration}/FlinkOptions.java (99%) rename hudi-flink/src/main/java/org/apache/hudi/{operator => sink}/InstantGenerateOperator.java (99%) rename hudi-flink/src/main/java/org/apache/hudi/{operator => sink}/KeyedWriteProcessFunction.java (99%) rename hudi-flink/src/main/java/org/apache/hudi/{operator => sink}/KeyedWriteProcessOperator.java (98%) rename hudi-flink/src/main/java/org/apache/hudi/{operator => sink}/StreamWriteFunction.java (98%) rename hudi-flink/src/main/java/org/apache/hudi/{operator => sink}/StreamWriteOperator.java (98%) rename hudi-flink/src/main/java/org/apache/hudi/{operator => sink}/StreamWriteOperatorCoordinator.java (99%) rename hudi-flink/src/main/java/org/apache/hudi/{operator => sink}/StreamWriteOperatorFactory.java (98%) rename hudi-flink/src/main/java/org/apache/hudi/{operator => sink}/compact/CompactFunction.java (98%) rename hudi-flink/src/main/java/org/apache/hudi/{operator => sink}/compact/CompactionCommitEvent.java (97%) rename hudi-flink/src/main/java/org/apache/hudi/{operator => sink}/compact/CompactionCommitSink.java (99%) rename hudi-flink/src/main/java/org/apache/hudi/{operator => sink}/compact/CompactionPlanEvent.java (97%) rename hudi-flink/src/main/java/org/apache/hudi/{operator => sink}/compact/CompactionPlanOperator.java (99%) rename hudi-flink/src/main/java/org/apache/hudi/{operator => sink}/event/BatchWriteSuccessEvent.java (98%) rename hudi-flink/src/main/java/org/apache/hudi/{operator => sink}/partitioner/BucketAssignFunction.java (99%) rename hudi-flink/src/main/java/org/apache/hudi/{operator => sink}/partitioner/BucketAssigner.java (99%) rename hudi-flink/src/main/java/org/apache/hudi/{operator => sink}/partitioner/BucketAssigners.java (93%) rename hudi-flink/src/main/java/org/apache/hudi/{operator => sink}/partitioner/delta/DeltaBucketAssigner.java (97%) rename hudi-flink/src/main/java/org/apache/hudi/{source => sink/transform}/JsonStringToHoodieRecordMapFunction.java (98%) rename hudi-flink/src/main/java/org/apache/hudi/{operator => sink}/transform/RowDataToHoodieFunction.java (97%) rename hudi-flink/src/main/java/org/apache/hudi/{operator => source}/StreamReadMonitoringFunction.java (97%) rename hudi-flink/src/main/java/org/apache/hudi/{operator => source}/StreamReadOperator.java (98%) rename hudi-flink/src/main/java/org/apache/hudi/{factory => table}/HoodieTableFactory.java (96%) rename hudi-flink/src/main/java/org/apache/hudi/{sink => table}/HoodieTableSink.java (89%) rename hudi-flink/src/main/java/org/apache/hudi/{source => table}/HoodieTableSource.java (96%) rename hudi-flink/src/main/java/org/apache/hudi/{source => table}/format/FilePathUtils.java (99%) rename hudi-flink/src/main/java/org/apache/hudi/{source => table}/format/FormatUtils.java (96%) rename hudi-flink/src/main/java/org/apache/hudi/{source => table}/format/cow/AbstractColumnReader.java (99%) rename hudi-flink/src/main/java/org/apache/hudi/{source => table}/format/cow/CopyOnWriteInputFormat.java (99%) rename hudi-flink/src/main/java/org/apache/hudi/{source => table}/format/cow/Int64TimestampColumnReader.java (98%) rename hudi-flink/src/main/java/org/apache/hudi/{source => table}/format/cow/ParquetColumnarRowSplitReader.java (98%) rename hudi-flink/src/main/java/org/apache/hudi/{source => table}/format/cow/ParquetDecimalVector.java (98%) rename hudi-flink/src/main/java/org/apache/hudi/{source => table}/format/cow/ParquetSplitReaderUtil.java (99%) rename hudi-flink/src/main/java/org/apache/hudi/{source => table}/format/cow/RunLengthDecoder.java (99%) rename hudi-flink/src/main/java/org/apache/hudi/{source => table}/format/mor/InstantRange.java (98%) rename hudi-flink/src/main/java/org/apache/hudi/{source => table}/format/mor/MergeOnReadInputFormat.java (97%) rename hudi-flink/src/main/java/org/apache/hudi/{source => table}/format/mor/MergeOnReadInputSplit.java (98%) rename hudi-flink/src/main/java/org/apache/hudi/{source => table}/format/mor/MergeOnReadTableState.java (98%) rename hudi-flink/src/test/java/org/apache/hudi/{operator => sink}/StreamWriteITCase.java (95%) rename hudi-flink/src/test/java/org/apache/hudi/{operator/StreamWriteOperatorCoordinatorTest.java => sink/TestStreamWriteOperatorCoordinator.java} (96%) rename hudi-flink/src/test/java/org/apache/hudi/{operator => sink}/TestWriteCopyOnWrite.java (98%) rename hudi-flink/src/test/java/org/apache/hudi/{operator => sink}/TestWriteMergeOnRead.java (97%) rename hudi-flink/src/test/java/org/apache/hudi/{operator => sink}/TestWriteMergeOnReadWithCompact.java (95%) rename hudi-flink/src/test/java/org/apache/hudi/{operator => sink}/partitioner/TestBucketAssigner.java (98%) rename hudi-flink/src/test/java/org/apache/hudi/{source => sink/transform}/TestJsonStringToHoodieRecordMapFunction.java (98%) rename hudi-flink/src/test/java/org/apache/hudi/{operator => sink}/utils/CompactFunctionWrapper.java (91%) rename hudi-flink/src/test/java/org/apache/hudi/{operator => sink}/utils/MockFunctionInitializationContext.java (97%) rename hudi-flink/src/test/java/org/apache/hudi/{operator => sink}/utils/MockMapState.java (98%) rename hudi-flink/src/test/java/org/apache/hudi/{operator => sink}/utils/MockOperatorStateStore.java (99%) rename hudi-flink/src/test/java/org/apache/hudi/{operator => sink}/utils/MockStreamingRuntimeContext.java (99%) rename hudi-flink/src/test/java/org/apache/hudi/{operator => sink}/utils/StreamWriteFunctionWrapper.java (94%) rename hudi-flink/src/test/java/org/apache/hudi/{source => table}/HoodieDataSourceITCase.java (97%) rename hudi-flink/src/test/java/org/apache/hudi/{factory => table}/TestHoodieTableFactory.java (96%) rename hudi-flink/src/test/java/org/apache/hudi/{source => table}/TestHoodieTableSource.java (94%) rename hudi-flink/src/test/java/org/apache/hudi/{source => table}/format/TestInputFormat.java (96%) rename hudi-flink/src/test/java/org/apache/hudi/{operator => }/utils/TestConfigurations.java (98%) rename hudi-flink/src/test/java/org/apache/hudi/{operator => }/utils/TestData.java (99%)