wx-group / juvenile-prosecution

Commit d5531b6c34c72354128591acac30167af24b5b84

Authored by sh
1 parent 28334b9f

修改id为LongType

Inline Side-by-side
Showing 1 changed file with 3 additions and 3 deletions
juvenile-prosecution-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/handle/service/SparkEtlService.java
  View file @d5531b6
@@ -197,7 +197,7 @@ public class SparkEtlService implements Serializable { @@ -197,7 +197,7 @@ public class SparkEtlService implements Serializable {
197 // schemaFields.add(DataTypes.createStructField("updateTime", DataTypes.StringType, true)); 197 // schemaFields.add(DataTypes.createStructField("updateTime", DataTypes.StringType, true));
198 198
199 List<StructField> schemaFields = new ArrayList<StructField>(); 199 List<StructField> schemaFields = new ArrayList<StructField>();
200 - schemaFields.add(DataTypes.createStructField("id", DataTypes.IntegerType, false)); 200 + schemaFields.add(DataTypes.createStructField("id", DataTypes.LongType, false));
201 schemaFields.add(DataTypes.createStructField("name", DataTypes.StringType, true)); 201 schemaFields.add(DataTypes.createStructField("name", DataTypes.StringType, true));
202 schemaFields.add(DataTypes.createStructField("sys_org_code", DataTypes.StringType, true)); 202 schemaFields.add(DataTypes.createStructField("sys_org_code", DataTypes.StringType, true));
203 schemaFields.add(DataTypes.createStructField("household_num", DataTypes.StringType, true)); 203 schemaFields.add(DataTypes.createStructField("household_num", DataTypes.StringType, true));
@@ -281,7 +281,7 @@ public class SparkEtlService implements Serializable { @@ -281,7 +281,7 @@ public class SparkEtlService implements Serializable {
281 // schemaFields.add(DataTypes.createStructField("reason", DataTypes.StringType, true)); 281 // schemaFields.add(DataTypes.createStructField("reason", DataTypes.StringType, true));
282 // schemaFields.add(DataTypes.createStructField("other", DataTypes.StringType, true)); 282 // schemaFields.add(DataTypes.createStructField("other", DataTypes.StringType, true));
283 // schemaFields.add(DataTypes.createStructField("createTime", DataTypes.StringType, true)); 283 // schemaFields.add(DataTypes.createStructField("createTime", DataTypes.StringType, true));
284 - schemaFields.add(DataTypes.createStructField("id", DataTypes.IntegerType, false)); 284 + schemaFields.add(DataTypes.createStructField("id", DataTypes.LongType, false));
285 schemaFields.add(DataTypes.createStructField("name", DataTypes.StringType, true)); 285 schemaFields.add(DataTypes.createStructField("name", DataTypes.StringType, true));
286 schemaFields.add(DataTypes.createStructField("sys_org_code", DataTypes.StringType, true)); 286 schemaFields.add(DataTypes.createStructField("sys_org_code", DataTypes.StringType, true));
287 schemaFields.add(DataTypes.createStructField("household_num", DataTypes.StringType, true)); 287 schemaFields.add(DataTypes.createStructField("household_num", DataTypes.StringType, true));
@@ -370,7 +370,7 @@ public class SparkEtlService implements Serializable { @@ -370,7 +370,7 @@ public class SparkEtlService implements Serializable {
370 // schemaFields.add(DataTypes.createStructField("phoneTwo", DataTypes.StringType, true)); 370 // schemaFields.add(DataTypes.createStructField("phoneTwo", DataTypes.StringType, true));
371 // schemaFields.add(DataTypes.createStructField("phone", DataTypes.StringType, true)); 371 // schemaFields.add(DataTypes.createStructField("phone", DataTypes.StringType, true));
372 // schemaFields.add(DataTypes.createStructField("createTime", DataTypes.StringType, true)); 372 // schemaFields.add(DataTypes.createStructField("createTime", DataTypes.StringType, true));
373 - schemaFields.add(DataTypes.createStructField("id", DataTypes.IntegerType, false)); 373 + schemaFields.add(DataTypes.createStructField("id", DataTypes.LongType, false));
374 schemaFields.add(DataTypes.createStructField("name", DataTypes.StringType, true)); 374 schemaFields.add(DataTypes.createStructField("name", DataTypes.StringType, true));
375 schemaFields.add(DataTypes.createStructField("sys_org_code", DataTypes.StringType, true)); 375 schemaFields.add(DataTypes.createStructField("sys_org_code", DataTypes.StringType, true));
376 schemaFields.add(DataTypes.createStructField("identity", DataTypes.StringType, true)); 376 schemaFields.add(DataTypes.createStructField("identity", DataTypes.StringType, true));