@Override public void write(Writable key,RyaStatementWritable value) throws IOException {
  RyaStatement ryaStatement=value.getRyaStatement();
  if (ryaStatement.getColumnVisibility() == null) {
    ryaStatement.setColumnVisibility(cv);
  }
  if (ryaStatement.getContext() == null) {
    ryaStatement.setContext(defaultContext);
  }
  buffer.add(ryaStatement);
  bufferCurrentSize+=statementSize(ryaStatement);
  if (bufferCurrentSize >= bufferSizeLimit) {
    flushBuffer();
  }
}

@ Override public void write ( Writable key , RyaStatementWritable value ) throws IOException { RyaStatement ryaStatement = value . getRyaStatement ( ) ; if ( ryaStatement . getColumnVisibility ( ) == null ) { ryaStatement . setColumnVisibility ( cv ) ; } if ( ryaStatement . getContext ( ) == null ) { ryaStatement . setContext ( defaultContext ) ; } buffer . add ( ryaStatement ) ; bufferCurrentSize += statementSize ( ryaStatement ) ; if ( bufferCurrentSize >= bufferSizeLimit ) { flushBuffer ( ) ; } }
writes a ( key , value ) pair to rya . adds the statement to a buffer , and flushes the statement buffer to the database if full .
