lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-4471] Relocate AWSDmsAvroPayload class to hudi-common

Browse Source
This commit is contained in:
Dongwook Kwon
2021-03-10 17:42:09 -08:00
committed by wenningd
parent e7c8df7e8b
commit 74d7b4d751
4 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
hudi-spark-datasource/hudi-spark/src/main/java/org/apache/hudi/payload/AWSDmsAvroPayload.java → hudi-common/src/main/java/org/apache/hudi/common/model/AWSDmsAvroPayload.java
View File

@@ -16,9 +16,8 @@
* limitations under the License.
*/
package org.apache.hudi.payload;
package org.apache.hudi.common.model;
import org.apache.hudi.common.model.OverwriteWithLatestAvroPayload;
import org.apache.hudi.common.util.Option;
import org.apache.avro.Schema;

1
hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/payload/TestAWSDmsAvroPayload.java
View File

@@ -18,6 +18,7 @@
package org.apache.hudi.payload;
import org.apache.hudi.common.model.AWSDmsAvroPayload;
import org.apache.hudi.common.model.OverwriteWithLatestAvroPayload;
import org.apache.hudi.common.util.Option;

2
hudi-utilities/src/main/java/org/apache/hudi/utilities/transform/AWSDmsTransformer.java
View File

@@ -19,8 +19,8 @@
package org.apache.hudi.utilities.transform;
import org.apache.hudi.common.config.TypedProperties;
import org.apache.hudi.common.model.AWSDmsAvroPayload;
import org.apache.hudi.common.util.Option;
import org.apache.hudi.payload.AWSDmsAvroPayload;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.sql.Dataset;

2
hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/TestAWSDatabaseMigrationServiceSource.java
View File

@@ -18,7 +18,7 @@
package org.apache.hudi.utilities.functional;
import org.apache.hudi.payload.AWSDmsAvroPayload;
import org.apache.hudi.common.model.AWSDmsAvroPayload;
import org.apache.hudi.testutils.SparkClientFunctionalTestHarness;
import org.apache.hudi.utilities.transform.AWSDmsTransformer;