@Test public void testSyncBatch() { BatchSyncUtil spy = PowerMockito.spy(new BatchSyncUtil()); spy.syncCourseBatch("do_11282833211754086411", null); }
public void syncCourseBatch(String courseId, MessageCollector collector) { List<Row> courseBatchRows = readbatch("course_batch", courseId); for(Row row: courseBatchRows) { if(1 == row.getInt("status")) { List<Row> userCoursesRows = read("user_courses", Arrays.asList(row.getString("batchid"))); pushEventsToKafka(userCoursesRows, collector); LOGGER.info("Pushed the events to sync courseBatch enrollment for : " + courseId); } } }
BatchSyncUtil { public void syncCourseBatch(String courseId, MessageCollector collector) { List<Row> courseBatchRows = readbatch("course_batch", courseId); for(Row row: courseBatchRows) { if(1 == row.getInt("status")) { List<Row> userCoursesRows = read("user_courses", Arrays.asList(row.getString("batchid"))); pushEventsToKafka(userCoursesRows, collector); LOGGER.info("Pushed the events to sync courseBatch enrollment for : " + courseId); } } } }
BatchSyncUtil { public void syncCourseBatch(String courseId, MessageCollector collector) { List<Row> courseBatchRows = readbatch("course_batch", courseId); for(Row row: courseBatchRows) { if(1 == row.getInt("status")) { List<Row> userCoursesRows = read("user_courses", Arrays.asList(row.getString("batchid"))); pushEventsToKafka(userCoursesRows, collector); LOGGER.info("Pushed the events to sync courseBatch enrollment for : " + courseId); } } }  }
BatchSyncUtil { public void syncCourseBatch(String courseId, MessageCollector collector) { List<Row> courseBatchRows = readbatch("course_batch", courseId); for(Row row: courseBatchRows) { if(1 == row.getInt("status")) { List<Row> userCoursesRows = read("user_courses", Arrays.asList(row.getString("batchid"))); pushEventsToKafka(userCoursesRows, collector); LOGGER.info("Pushed the events to sync courseBatch enrollment for : " + courseId); } } }  void syncCourseBatch(String courseId, MessageCollector collector); }
BatchSyncUtil { public void syncCourseBatch(String courseId, MessageCollector collector) { List<Row> courseBatchRows = readbatch("course_batch", courseId); for(Row row: courseBatchRows) { if(1 == row.getInt("status")) { List<Row> userCoursesRows = read("user_courses", Arrays.asList(row.getString("batchid"))); pushEventsToKafka(userCoursesRows, collector); LOGGER.info("Pushed the events to sync courseBatch enrollment for : " + courseId); } } }  void syncCourseBatch(String courseId, MessageCollector collector);  }