@@ -33,20 +33,20 @@ public GeneToGeneOrthologyIndexer(IndexerConfig config) {
3333 public void index () {
3434 try {
3535 log .info ("Getting orthologs" );
36-
36+
3737 SearchResponse <GeneToGeneOrthologyGenerated > orthologyResponse = service .getGeneToGeneOrthology (0 , 0 );
38-
38+
3939 log .info ("GeneToGeneParalogy count: " + orthologyResponse .getTotalResults ());
40-
41- int totalPages = (int )(orthologyResponse .getTotalResults () / indexerConfig .getBufferSize ());
42-
40+
41+ int totalPages = (int ) (orthologyResponse .getTotalResults () / indexerConfig .getBufferSize ());
42+
4343 LinkedBlockingDeque <String > queue = new LinkedBlockingDeque <>();
4444 for (int i = 0 ; i <= totalPages ; i ++) {
4545 queue .add (String .valueOf (i ));
4646 }
47-
47+
4848 initiateThreading (queue );
49-
49+
5050 } catch (Exception e ) {
5151 e .printStackTrace ();
5252 }
@@ -58,27 +58,28 @@ protected ObjectMapper customizeObjectMapper(ObjectMapper objectMapper) {
5858 return RestConfig .config .getJacksonObjectMapperFactory ().createObjectMapper ();
5959 }
6060
61-
6261 protected void startSingleThread (LinkedBlockingDeque <String > queue ) {
63- while (true ) {
64- try {
65- if (queue .isEmpty ()) {
66- return ;
67- }
68- String page = queue .takeFirst ();
69- SearchResponse <GeneToGeneOrthologyGenerated > resp = service .getGeneToGeneOrthology (Integer .valueOf (page ), indexerConfig .getBufferSize ());
62+ while (true ) {
63+ try {
64+ if (queue .isEmpty ()) {
65+ return ;
66+ }
67+ String page = queue .takeFirst ();
68+ SearchResponse <GeneToGeneOrthologyGenerated > resp = service
69+ .getGeneToGeneOrthology (Integer .valueOf (page ), indexerConfig .getBufferSize ());
7070 List <GeneToGeneOrthologyDocument > docs = createGeneToGeneOrthologyDocuments (resp .getResults ());
71-
72- indexDocuments (docs );
73- } catch (Exception e ) {
74- log .error ("Error while indexing..." , e );
75- System .exit (-1 );
76- return ;
77- }
78- }
71+
72+ indexDocuments (docs );
73+ } catch (Exception e ) {
74+ log .error ("Error while indexing..." , e );
75+ System .exit (-1 );
76+ return ;
77+ }
78+ }
7979 }
8080
81- private List <GeneToGeneOrthologyDocument > createGeneToGeneOrthologyDocuments (List <GeneToGeneOrthologyGenerated > g2gOrthoList ) {
81+ private List <GeneToGeneOrthologyDocument > createGeneToGeneOrthologyDocuments (
82+ List <GeneToGeneOrthologyGenerated > g2gOrthoList ) {
8283 List <GeneToGeneOrthologyDocument > documents = new ArrayList <>();
8384 for (GeneToGeneOrthologyGenerated g2gOrtho : g2gOrthoList ) {
8485 GeneToGeneOrthologyDocument document = new GeneToGeneOrthologyDocument ();
@@ -93,7 +94,6 @@ private List<GeneToGeneOrthologyDocument> createGeneToGeneOrthologyDocuments(Lis
9394 return documents ;
9495 }
9596
96-
9797 private void createStringencyFilter (GeneToGeneOrthologyGenerated g2gOrtho , GeneToGeneOrthologyDocument document ) {
9898 if (Boolean .TRUE .equals (g2gOrtho .getStrictFilter ())) {
9999 document .setStringencyFilter ("stringent" );
@@ -108,7 +108,7 @@ private void createGeneAnnotations(GeneToGeneOrthologyGenerated g2gOrtho, GeneTo
108108 putGeneInfo (map , g2gOrtho .getObjectGene ());
109109 document .setGeneAnnotations (map );
110110 }
111-
111+
112112 private void putGeneInfo (Map <String , Object > map , Gene gene ) {
113113 Map <String , Object > data = new HashMap <>();
114114 data .put ("hasExpressionAnnotations" , hasExpressionAnnotations (gene ));
@@ -131,6 +131,4 @@ private void removeAnnotationLists(GeneToGeneOrthologyDocument document) {
131131 document .getGeneToGeneOrthologyGenerated ().getObjectGene ().setGeneExpressionAnnotations (null );
132132 }
133133
134-
135-
136134}
0 commit comments