gen entities should initialize list,set,map by default && timeout handling && thrift removing

Author: shijiesheng

build.gradle

@@ -1,6 +1,5 @@
 buildscript {
     dependencies {
-        classpath "gradle.plugin.org.jruyi.gradle:thrift-gradle-plugin:0.4.1"
         classpath 'com.google.protobuf:protobuf-gradle-plugin:0.8.11'
     }
 }
@@ -34,7 +33,6 @@ repositories {
 apply plugin: 'com.google.protobuf'
 apply plugin: 'idea' // IntelliJ plugin to see files generated from protos
 apply plugin: 'maven'
-apply plugin: 'org.jruyi.thrift'
 apply plugin: 'maven-publish'
 apply plugin: 'com.github.sherter.google-java-format'
 
@@ -77,7 +75,6 @@ dependencies {
 
     compile group: 'com.uber.tchannel', name: 'tchannel-core', version: '0.8.30'
     compile group: 'org.slf4j', name: 'slf4j-api', version: '1.7.36'
-    compile group: 'org.apache.thrift', name: 'libthrift', version: '0.9.3'
     compile group: 'com.google.code.gson', name: 'gson', version: '2.10'
     compile group: 'com.uber.m3', name: 'tally-core', version: '0.11.1'
     compile group: 'com.google.guava', name: 'guava', version: '31.1-jre'

scripts/v4_entity_generator/generator.go

@@ -19,6 +19,7 @@ const (
 type Field struct {
 	Name string
 	Type string
+	Initializer string
 }
 
 type TemplateEntity struct {
@@ -119,9 +120,22 @@ func (g *Generator) generateStruct(v *ast.Struct, outputDir string, packageName
 			return fmt.Errorf("failed to map field type: %w", err)
 		}
 
+		initializer := ""
+		switch field.Type.(type) {
+		case ast.SetType:
+			initializer = " = new HashSet<>();"
+		case ast.ListType:
+			initializer = " = new ArrayList<>();"
+		case ast.MapType:
+			initializer = " = new HashMap<>();"
+		}
+
+		fmt.Println(field.Name, initializer, typeStr)
+
 		fields = append(fields, Field{
 			Name: field.Name,
 			Type: typeStr,
+			Initializer: initializer,
 		})
 	}
 

scripts/v4_entity_generator/template/java_struct.tmpl

@@ -11,6 +11,6 @@ import {{.}};
 @Accessors(chain = true)
 public class {{.ClassName}} {
   {{- range .Fields}}
-  private {{.Type}} {{.Name}};
+  private {{.Type}} {{.Name}}{{.Initializer}};
   {{- end}}
 }

src/gen/java/com/uber/cadence/BadBinaries.java

@@ -7,5 +7,5 @@
 @Data
 @Accessors(chain = true)
 public class BadBinaries {
-  private Map<String, BadBinaryInfo> binaries;
+  private Map<String, BadBinaryInfo> binaries = new HashMap<>();;
 }

src/gen/java/com/uber/cadence/CrossClusterApplyParentClosePolicyRequestAttributes.java

@@ -7,5 +7,5 @@
 @Data
 @Accessors(chain = true)
 public class CrossClusterApplyParentClosePolicyRequestAttributes {
-  private List<ApplyParentClosePolicyRequest> children;
+  private List<ApplyParentClosePolicyRequest> children = new ArrayList<>();;
 }

src/gen/java/com/uber/cadence/CrossClusterApplyParentClosePolicyResponseAttributes.java

@@ -7,5 +7,5 @@
 @Data
 @Accessors(chain = true)
 public class CrossClusterApplyParentClosePolicyResponseAttributes {
-  private List<ApplyParentClosePolicyResult> childrenStatus;
+  private List<ApplyParentClosePolicyResult> childrenStatus = new ArrayList<>();;
 }

src/gen/java/com/uber/cadence/CrossClusterStartChildExecutionRequestAttributes.java

@@ -12,5 +12,5 @@ public class CrossClusterStartChildExecutionRequestAttributes {
   private long initiatedEventID;
   private StartChildWorkflowExecutionInitiatedEventAttributes initiatedEventAttributes;
   private String targetRunID;
-  private Map<String, String> partitionConfig;
+  private Map<String, String> partitionConfig = new HashMap<>();;
 }

src/gen/java/com/uber/cadence/DescribeHistoryHostResponse.java

@@ -8,7 +8,7 @@
 @Accessors(chain = true)
 public class DescribeHistoryHostResponse {
   private int numberOfShards;
-  private List<Integer> shardIDs;
+  private List<Integer> shardIDs = new ArrayList<>();;
   private DomainCacheInfo domainCache;
   private String shardControllerStatus;
   private String address;

src/gen/java/com/uber/cadence/DescribeQueueResponse.java

@@ -7,5 +7,5 @@
 @Data
 @Accessors(chain = true)
 public class DescribeQueueResponse {
-  private List<String> processingQueueStates;
+  private List<String> processingQueueStates = new ArrayList<>();;
 }

src/gen/java/com/uber/cadence/DescribeShardDistributionResponse.java

@@ -8,5 +8,5 @@
 @Accessors(chain = true)
 public class DescribeShardDistributionResponse {
   private int numberOfShards;
-  private Map<Integer, String> shards;
+  private Map<Integer, String> shards = new HashMap<>();;
 }