diff --git a/lib/kafkalib/partition/settings.go b/lib/kafkalib/partition/settings.go index 949584f47..1959302df 100644 --- a/lib/kafkalib/partition/settings.go +++ b/lib/kafkalib/partition/settings.go @@ -18,13 +18,13 @@ var ValidPartitionBy = []string{ } type MergePredicates struct { - PartitionField string + PartitionField string `yaml:"partitionField"` } type BigQuerySettings struct { - PartitionType string `yaml:"partitionType" json:"partitionType"` - PartitionField string `yaml:"partitionField" json:"partitionField"` - PartitionBy string `yaml:"partitionBy" json:"partitionBy"` + PartitionType string `yaml:"partitionType"` + PartitionField string `yaml:"partitionField"` + PartitionBy string `yaml:"partitionBy"` } // GenerateMergeString this is used as an equality string for the MERGE statement.