Skip to content

Commit 126da6d

Browse files
committed
add testPartitionedTable test
1 parent 44cca1f commit 126da6d

File tree

1 file changed

+29
-1
lines changed

1 file changed

+29
-1
lines changed

fluss-client/src/test/java/com/alibaba/fluss/client/table/NewPartitionedTableITCase.java

Lines changed: 29 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@
2222
import com.alibaba.fluss.metadata.PartitionInfo;
2323
import com.alibaba.fluss.metadata.Schema;
2424
import com.alibaba.fluss.metadata.TableDescriptor;
25+
import com.alibaba.fluss.metadata.TableInfo;
2526
import com.alibaba.fluss.metadata.TablePath;
2627
import com.alibaba.fluss.row.BinaryString;
2728
import com.alibaba.fluss.row.InternalRow;
@@ -33,6 +34,7 @@
3334
import com.alibaba.fluss.types.BytesType;
3435
import com.alibaba.fluss.types.CharType;
3536
import com.alibaba.fluss.types.DataTypeRoot;
37+
import com.alibaba.fluss.types.DataTypes;
3638
import com.alibaba.fluss.types.DateType;
3739
import com.alibaba.fluss.types.DoubleType;
3840
import com.alibaba.fluss.types.FloatType;
@@ -154,7 +156,33 @@ class NewPartitionedTableITCase extends ClientToServerITCaseBase {
154156
"2025-05-31-03-42-35_428");
155157

156158
@Test
157-
void testMultipleTypedPartitionedTable() throws Exception {
159+
public void testPartitionedTable() throws Exception {
160+
TablePath tablePath = TablePath.of("fluss", "person");
161+
162+
TableDescriptor partitionedTable =
163+
TableDescriptor.builder()
164+
.schema(
165+
Schema.newBuilder()
166+
.column("id", DataTypes.INT())
167+
.column("name", DataTypes.STRING())
168+
.column("dt", DataTypes.DATE())
169+
.build())
170+
.distributedBy(3, "name")
171+
.partitionedBy("id", "dt")
172+
.build();
173+
admin.createTable(tablePath, partitionedTable, true).get();
174+
TableInfo tableInfo = admin.getTableInfo(tablePath).get();
175+
176+
assertThat(tableInfo).isNotNull();
177+
assertThat(tableInfo.getTablePath()).isEqualTo(tablePath);
178+
179+
List<String> partitionKeys = tableInfo.getPartitionKeys();
180+
assertThat(partitionKeys).hasSize(2);
181+
assertThat(partitionKeys).containsExactly("id", "dt");
182+
}
183+
184+
@Test
185+
public void testMultipleTypedPartitionedTable() throws Exception {
158186

159187
for (int i = 0; i < allPartitionKeyTypes.length; i++) {
160188
String partitionKey = extraColumn[i].getName();

0 commit comments

Comments
 (0)