package Ġuk . gov . d wp . data works . k af k ato hbase . re conc iliation . utils Ċ Ċ import Ġuk . gov . d wp . data works . k af k ato hbase . re conc iliation . configuration . Metadata Store Configuration Ċ import Ġuk . gov . d wp . data works . k af k ato hbase . re conc iliation . exceptions . Metadata Store Partitions Not Set Exception ĊĊ Ċ fun Ġvalidate Partitions ( start Partition : ĠString ?, Ġend Partition : ĠString ?): ĠBoolean Ġ{ ĊĊĠĠĠ ĠMetadata Store Configuration . logger . info (" Valid ating Ġmetadata Ġstore Ġpartitions ", ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ" start _ partition " Ġto Ġ( start Partition Ġ?: Ġ" NOT _ SET "), ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ" end _ partition " Ġto Ġ( end Partition Ġ?: Ġ" NOT _ SET ")) ĊĊĠĠĠ Ġval Ġstart Partition Set Ġ= Ġstart Partition Ġ== Ġnull Ġ|| Ġstart Partition Ġ== Ġ" NOT _ SET " ĊĠĠĠ Ġval Ġend Partition Set Ġ= Ġend Partition Ġ== Ġnull Ġ|| Ġend Partition Ġ== Ġ" NOT _ SET " ĊĊĠĠĠ Ġval ĠisValid Ġ= Ġstart Partition Set Ġ== Ġend Partition Set ĊĠĠĠ Ġif Ġ(! isValid ) Ġ{ ĊĠĠĠĠĠĠĠ Ġthrow ĠMetadata Store Partitions Not Set Exception (" Both Ġpartitions Ġneed Ġto Ġbe Ġset Ġto Ġmake Ġuse Ġof Ġpartition ing Ġfunctionality ") ĊĠĠĠ Ġ} ĊĠĠĠ Ġreturn ĠisValid Ċ } Ċ Ċ fun Ġto Partition Id CSV ( start Partition : ĠString , Ġend Partition : ĠString ) Ġ= ĊĠĠĠĠĠĠĠ Ġif Ġ( start Partition Ġ== Ġ" NOT _ SET " Ġ|| Ġend Partition Ġ== Ġ" NOT _ SET ") Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ" NOT _ SET " ĊĠĠĠĠĠĠĠ Ġ} Ġelse Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġstart Partition Int Ġ= Ġstart Partition . toInt () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġend Partition Int Ġ= Ġend Partition . toInt () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġvar Ġpartition CSV Ġ= Ġ"" ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġfor Ġ( i Ġin Ġstart Partition Int .. end Partition Int ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġpartition CSV Ġ+= Ġ" p $ i " ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġif Ġ( i Ġ!= Ġend Partition Int ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġpartition CSV Ġ+= Ġ"," ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġpartition CSV ĊĠĠĠĠĠĠĠ Ġ} Ċ