[hotfix][table-planner] Move EnrichedRowData to table-runtime

Signed-off-by: slinkydeveloper <[email protected]> This closes apache#17753.
liuyongvs · Nov 12, 2021 · 815bc2a · 815bc2a
1 parent d687f65
commit 815bc2a
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/...ink/table/data/utils/EnrichedRowData.java → ...ink/table/filesystem/EnrichedRowData.java b/...ink/table/data/utils/EnrichedRowData.java → ...ink/table/filesystem/EnrichedRowData.java
@@ -16,9 +16,9 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.data.utils;
+package org.apache.flink.table.filesystem;
 
-import org.apache.flink.annotation.PublicEvolving;
+import org.apache.flink.annotation.Internal;
 import org.apache.flink.table.data.ArrayData;
 import org.apache.flink.table.data.DecimalData;
 import org.apache.flink.table.data.MapData;
@@ -36,7 +36,7 @@
  * index mapping, One of the rows is fixed, while the other can be swapped for performant changes in
  * hot code paths. The {@link RowKind} is inherited from the mutable row.
  */
-@PublicEvolving
+@Internal
 public class EnrichedRowData implements RowData {
 
     private final RowData fixedRow;

diff --git a/...-runtime/src/main/java/org/apache/flink/table/filesystem/FileInfoExtractorBulkFormat.java b/...-runtime/src/main/java/org/apache/flink/table/filesystem/FileInfoExtractorBulkFormat.java
@@ -26,7 +26,6 @@
 import org.apache.flink.table.api.DataTypes;
 import org.apache.flink.table.data.GenericRowData;
 import org.apache.flink.table.data.RowData;
-import org.apache.flink.table.data.utils.EnrichedRowData;
 import org.apache.flink.table.runtime.typeutils.InternalTypeInfo;
 import org.apache.flink.table.types.DataType;
 import org.apache.flink.table.utils.PartitionPathUtils;

diff --git a/...table/data/utils/EnrichedRowDataTest.java → ...table/filesystem/EnrichedRowDataTest.java b/...table/data/utils/EnrichedRowDataTest.java → ...table/filesystem/EnrichedRowDataTest.java
@@ -16,10 +16,11 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.data.utils;
+package org.apache.flink.table.filesystem;
 
 import org.apache.flink.table.data.GenericRowData;
 import org.apache.flink.table.data.RowData;
+import org.apache.flink.table.data.utils.JoinedRowData;
 import org.apache.flink.types.RowKind;
 
 import org.junit.jupiter.api.Test;
@@ -33,7 +34,7 @@
 public class EnrichedRowDataTest {
 
     @Test
-    public void testJoinedRows() {
+    public void testEnrichedRow() {
         final List<String> completeRowFields =
                 Arrays.asList(
                         "fixedRow1",