SumReducer extends Reducer<Text, IntWritable, Text, IntWritable> { void persist(Integer sum, String code) { PreparedStatement preparedStatement = connect.prepare(INSERT_INTO_CAPSTONE_AIRPORT_POPULARITY_CODE_POPULARITY_VALUES); BoundStatement boundStatement = preparedStatement.bind(code, sum); connect.executeAsync(boundStatement); }  void reduce(Text key, Iterable<IntWritable> values, Context context); TreeBidiMap<Integer, String> getCache(); static final String INSERT_INTO_CAPSTONE_AIRPORT_POPULARITY_CODE_POPULARITY_VALUES; }
@Test public void testPersist() { SumReducer reducer = new SumReducer(); reducer.persist(81923, "NYC"); }