/** * Constructor */ public OfflineEditsBinaryLoader(OfflineEditsVisitor visitor, EditLogInputStream inputStream, OfflineEditsViewer.Flags flags) { this.visitor = visitor; this.inputStream = inputStream; this.fixTxIds = flags.getFixTxIds(); this.recoveryMode = flags.getRecoveryMode(); this.nextTxId = -1; }
public OfflineEditsXmlLoader(OfflineEditsVisitor visitor, File inputFile, OfflineEditsViewer.Flags flags) throws FileNotFoundException { this.visitor = visitor; this.fileReader = new InputStreamReader(new FileInputStream(inputFile), Charsets.UTF_8); this.fixTxIds = flags.getFixTxIds(); }
/** * Run OfflineEditsViewer * * @param inFilename input edits filename * @param outFilename oputput edits filename */ private void runOev(String inFilename, String outFilename, String processor) throws IOException { LOG.info("Running oev [" + inFilename + "] [" + outFilename + "]"); OfflineEditsViewer oev = new OfflineEditsViewer(); oev.go( EditsVisitorFactory.getEditsVisitor( outFilename, processor, TokenizerFactory.getTokenizer(inFilename), false)); }