make the api consistent

Author: polyzos

fluss-client/src/main/java/org/apache/fluss/client/table/writer/Append.java

@@ -36,5 +36,5 @@ public interface Append {
     AppendWriter createWriter();
 
     /** Create a new typed {@link AppendWriter} to write POJOs directly. */
-    <T> TypedAppendWriter<T> createWriter(Class<T> pojoClass);
+    <T> TypedAppendWriter<T> createTypedWriter(Class<T> pojoClass);
 }

fluss-client/src/main/java/org/apache/fluss/client/table/writer/TableAppend.java

@@ -40,7 +40,7 @@ public AppendWriter createWriter() {
     }
 
     @Override
-    public <T> TypedAppendWriter<T> createWriter(Class<T> pojoClass) {
+    public <T> TypedAppendWriter<T> createTypedWriter(Class<T> pojoClass) {
         AppendWriterImpl delegate = new AppendWriterImpl(tablePath, tableInfo, writerClient);
         return new TypedAppendWriterImpl<>(delegate, pojoClass, tableInfo);
     }

fluss-client/src/main/java/org/apache/fluss/client/table/writer/TableUpsert.java

@@ -97,7 +97,7 @@ public UpsertWriter createWriter() {
     }
 
     @Override
-    public <T> TypedUpsertWriter<T> createWriter(Class<T> pojoClass) {
+    public <T> TypedUpsertWriter<T> createTypedWriter(Class<T> pojoClass) {
         UpsertWriterImpl delegate =
                 new UpsertWriterImpl(tablePath, tableInfo, targetColumns, writerClient);
         return new TypedUpsertWriterImpl<>(delegate, pojoClass, tableInfo, targetColumns);

fluss-client/src/main/java/org/apache/fluss/client/table/writer/Upsert.java

@@ -63,5 +63,5 @@ public interface Upsert {
     UpsertWriter createWriter();
 
     /** Create a new typed {@link UpsertWriter} to write POJOs directly. */
-    <T> TypedUpsertWriter<T> createWriter(Class<T> pojoClass);
+    <T> TypedUpsertWriter<T> createTypedWriter(Class<T> pojoClass);
 }

fluss-client/src/test/java/org/apache/fluss/client/table/FlussTypedClientITCase.java

@@ -227,7 +227,7 @@ void testTypedAppendWriteAndScan() throws Exception {
         try (Table table = conn.getTable(path)) {
             // write
             TypedAppendWriter<AllTypesPojo> writer =
-                    table.newAppend().createWriter(AllTypesPojo.class);
+                    table.newAppend().createTypedWriter(AllTypesPojo.class);
             List<AllTypesPojo> expected = new ArrayList<>();
             for (int i = 0; i < 5; i++) {
                 AllTypesPojo u = newAllTypesPojo(i);
@@ -265,7 +265,7 @@ void testTypedUpsertWriteAndScan() throws Exception {
 
         try (Table table = conn.getTable(path)) {
             Upsert upsert = table.newUpsert();
-            TypedUpsertWriter<AllTypesPojo> writer = upsert.createWriter(AllTypesPojo.class);
+            TypedUpsertWriter<AllTypesPojo> writer = upsert.createTypedWriter(AllTypesPojo.class);
 
             AllTypesPojo p1 = newAllTypesPojo(1);
             AllTypesPojo p2 = newAllTypesPojo(2);
@@ -310,7 +310,7 @@ void testTypedLookups() throws Exception {
 
         try (Table table = conn.getTable(path)) {
             TypedUpsertWriter<AllTypesPojo> writer =
-                    table.newUpsert().createWriter(AllTypesPojo.class);
+                    table.newUpsert().createTypedWriter(AllTypesPojo.class);
             writer.upsert(newAllTypesPojo(1)).get();
             writer.upsert(newAllTypesPojo(2)).get();
             writer.close();
@@ -338,7 +338,7 @@ void testInternalRowLookup() throws Exception {
         try (Table table = conn.getTable(path)) {
             // write a couple of rows via POJO writer
             TypedUpsertWriter<AllTypesPojo> writer =
-                    table.newUpsert().createWriter(AllTypesPojo.class);
+                    table.newUpsert().createTypedWriter(AllTypesPojo.class);
             writer.upsert(newAllTypesPojo(101)).get();
             writer.upsert(newAllTypesPojo(202)).get();
             writer.close();
@@ -371,7 +371,7 @@ void testTypedProjections() throws Exception {
 
         try (Table table = conn.getTable(path)) {
             TypedAppendWriter<AllTypesPojo> writer =
-                    table.newAppend().createWriter(AllTypesPojo.class);
+                    table.newAppend().createTypedWriter(AllTypesPojo.class);
             writer.append(newAllTypesPojo(10)).get();
             writer.append(newAllTypesPojo(11)).get();
             writer.flush();
@@ -410,7 +410,7 @@ void testTypedPartialUpdates() throws Exception {
 
         try (Table table = conn.getTable(path)) {
             Upsert upsert = table.newUpsert().partialUpdate("a", "str", "dec");
-            TypedUpsertWriter<AllTypesPojo> writer = upsert.createWriter(AllTypesPojo.class);
+            TypedUpsertWriter<AllTypesPojo> writer = upsert.createTypedWriter(AllTypesPojo.class);
 
             // initial full row
             writer.upsert(newAllTypesPojo(1)).get();