Skip to content

Commit e3e1c67

Browse files
[Chore] fix typos filed -> field (apache#9757)
1 parent e67466f commit e3e1c67

File tree

23 files changed

+126
-126
lines changed

23 files changed

+126
-126
lines changed

docs/en/concept/sql-config.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -122,7 +122,7 @@ CREATE TABLE sink_table WITH (
122122
INSERT INTO sink_table SELECT id, name, age, email FROM source_table;
123123
```
124124

125-
* The `SELECT FROM` part is the table name of the source-mapped table. If the select field has keyword([refrence](https://github.com/JSQLParser/JSqlParser/blob/master/src/main/jjtree/net/sf/jsqlparser/parser/JSqlParserCC.jjt)),you should use it like \`filedName\`.
125+
* The `SELECT FROM` part is the table name of the source-mapped table. If the select field has keyword([refrence](https://github.com/JSQLParser/JSqlParser/blob/master/src/main/jjtree/net/sf/jsqlparser/parser/JSqlParserCC.jjt)),you should use it like \`fieldName\`.
126126
```sql
127127
INSERT INTO sink_table SELECT id, name, age, email,`output` FROM source_table;
128128
```

docs/en/transform-v2/field-mapper.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ The data read from source is a table like this:
3131
| 3 | Kin Dom | 20 | 123 |
3232
| 4 | Joy Dom | 20 | 123 |
3333

34-
We want to delete `age` field and update the filed order to `id`, `card`, `name` and rename `name` to `new_name`. We can add `FieldMapper` transform like this
34+
We want to delete `age` field and update the field order to `id`, `card`, `name` and rename `name` to `new_name`. We can add `FieldMapper` transform like this
3535

3636
```
3737
transform {

docs/zh/concept/sql-config.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -122,7 +122,7 @@ CREATE TABLE sink_table WITH (
122122
INSERT INTO sink_table SELECT id, name, age, email FROM source_table;
123123
```
124124

125-
* `SELECT FROM` 部分为源端映射表的表名,`SELECT` 部分的语法参考:[SQL-transform](../transform-v2/sql.md) `query` 配置项。如果select的字段是关键字([参考](https://github.com/JSQLParser/JSqlParser/blob/master/src/main/jjtree/net/sf/jsqlparser/parser/JSqlParserCC.jjt)),你应该像这样使用\`filedName\`
125+
* `SELECT FROM` 部分为源端映射表的表名,`SELECT` 部分的语法参考:[SQL-transform](../transform-v2/sql.md) `query` 配置项。如果select的字段是关键字([参考](https://github.com/JSQLParser/JSqlParser/blob/master/src/main/jjtree/net/sf/jsqlparser/parser/JSqlParserCC.jjt)),你应该像这样使用\`fieldName\`
126126
```sql
127127
INSERT INTO sink_table SELECT id, name, age, email,`output` FROM source_table;
128128
```

seatunnel-connectors-v2/connector-aerospike/src/main/java/org/apache/seatunnel/connectors/seatunnel/aerospike/config/AerospikeSinkOptions.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,7 @@ public AerospikeSinkOptions(ReadonlyConfig config) {
104104
.defaultValue(new HashMap<>())
105105
.withDescription(
106106
"Fields to be written with their Aerospike data types. Example: \"schema\": {\n"
107-
+ " \"filed\": {\n"
107+
+ " \"field\": {\n"
108108
+ " \"name\": \"STRING\"\n"
109109
+ " }\n"
110110
+ " }");

seatunnel-connectors-v2/connector-common/src/test/java/org/apache/seatunnel/connectors/seatunnel/common/source/arrow/ArrowToSeatunnelRowReaderTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -459,7 +459,7 @@ private SeaTunnelRowType getSeatunnelRowType(boolean allType) {
459459
String[] fieldNames =
460460
seaTunnelDataTypeHolder.stream()
461461
.filter(h -> allType ? h.getFlag() >= 0 : h.getFlag() == 1)
462-
.map(SeaTunnelDataTypeHolder::getFiledName)
462+
.map(SeaTunnelDataTypeHolder::getFieldName)
463463
.toArray(String[]::new);
464464
SeaTunnelDataType[] seaTunnelDataTypes =
465465
seaTunnelDataTypeHolder.stream()

seatunnel-connectors-v2/connector-common/src/test/java/org/apache/seatunnel/connectors/seatunnel/common/source/arrow/SeaTunnelDataTypeHolder.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -25,24 +25,24 @@
2525
import org.apache.seatunnel.api.table.type.SeaTunnelDataType;
2626

2727
public class SeaTunnelDataTypeHolder {
28-
private final String filedName;
28+
private final String fieldName;
2929
private final int flag;
3030

31-
public SeaTunnelDataTypeHolder(String filedName, int flag) {
32-
this.filedName = filedName;
31+
public SeaTunnelDataTypeHolder(String fieldName, int flag) {
32+
this.fieldName = fieldName;
3333
this.flag = flag;
3434
}
3535

36-
public String getFiledName() {
37-
return filedName;
36+
public String getFieldName() {
37+
return fieldName;
3838
}
3939

4040
public int getFlag() {
4141
return flag;
4242
}
4343

4444
public SeaTunnelDataType getSeatunnelDataType() {
45-
switch (filedName) {
45+
switch (fieldName) {
4646
case "boolean":
4747
return BasicType.BOOLEAN_TYPE;
4848
case "byte":

seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/data/RowConverter.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -128,9 +128,9 @@ private GenericRecord convertToStruct(
128128
int structFieldId,
129129
SchemaChangeWrapper wrapper) {
130130
GenericRecord result = GenericRecord.create(schema);
131-
String[] filedNames = fromType.getFieldNames();
132-
for (int i = 0; i < filedNames.length; i++) {
133-
String recordField = filedNames[i];
131+
String[] fieldNames = fromType.getFieldNames();
132+
for (int i = 0; i < fieldNames.length; i++) {
133+
String recordField = fieldNames[i];
134134
Type afterType = SchemaUtils.toIcebergType(fromType.getFieldType(i));
135135
Types.NestedField tableField = lookupStructField(recordField, schema, structFieldId);
136136
// add column

seatunnel-connectors-v2/connector-jdbc/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/executor/FieldNamedPreparedStatementTest.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@
2828

2929
public class FieldNamedPreparedStatementTest {
3030

31-
private static final String[] SPECIAL_FILEDNAMES =
31+
private static final String[] SPECIAL_FIELDNAMES =
3232
new String[] {
3333
"USER@TOKEN",
3434
"字段%名称",
@@ -60,9 +60,9 @@ public void testParseNamedStatementWithSpecialCharacters() {
6060
Map<String, List<Integer>> paramMap = new HashMap<>();
6161
String actualSQL = FieldNamedPreparedStatement.parseNamedStatement(sql, paramMap);
6262
assertEquals(exceptPreparedstatement, actualSQL);
63-
for (int i = 0; i < SPECIAL_FILEDNAMES.length; i++) {
64-
assertTrue(paramMap.containsKey(SPECIAL_FILEDNAMES[i]));
65-
assertEquals(i + 1, paramMap.get(SPECIAL_FILEDNAMES[i]).get(0));
63+
for (int i = 0; i < SPECIAL_FIELDNAMES.length; i++) {
64+
assertTrue(paramMap.containsKey(SPECIAL_FIELDNAMES[i]));
65+
assertEquals(i + 1, paramMap.get(SPECIAL_FIELDNAMES[i]).get(0));
6666
}
6767
}
6868

seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/exception/KuduConnectorErrorCode.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@
2222
public enum KuduConnectorErrorCode implements SeaTunnelErrorCode {
2323
GET_KUDUSCAN_OBJECT_FAILED("KUDU-01", "Get the Kuduscan object for each splice failed"),
2424
CLOSE_KUDU_CLIENT_FAILED("KUDU-02", "Close Kudu client failed"),
25-
DATA_TYPE_CAST_FILED("KUDU-03", "Value type does not match column type"),
25+
DATA_TYPE_CAST_FIELD("KUDU-03", "Value type does not match column type"),
2626
WRITE_DATA_FAILED("KUDU-04", "while sending value to Kudu failed"),
2727
INIT_KUDU_CLIENT_FAILED("KUDU-05", "Initialize the Kudu client failed"),
2828
GENERATE_KUDU_PARAMETERS_FAILED(

seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/serialize/KuduRowSerializer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -111,7 +111,7 @@ private void transform(Operation operation, SeaTunnelRow element) {
111111
}
112112
} catch (ClassCastException e) {
113113
throw new KuduConnectorException(
114-
KuduConnectorErrorCode.DATA_TYPE_CAST_FILED,
114+
KuduConnectorErrorCode.DATA_TYPE_CAST_FIELD,
115115
"Value type does not match column type "
116116
+ type.getSqlType()
117117
+ " for column "

0 commit comments

Comments
 (0)