summaryrefslogtreecommitdiff
path: root/gi/pf/corpus.cc
blob: cb6e4ed747c6a7dfe3a3fe26f6a0de713dfa8893 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
#include "corpus.h"

#include <set>
#include <vector>
#include <string>

#include "tdict.h"
#include "filelib.h"

using namespace std;

namespace corpus {

void ReadParallelCorpus(const string& filename,
                vector<vector<WordID> >* f,
                vector<vector<WordID> >* e,
                set<WordID>* vocab_f,
                set<WordID>* vocab_e) {
  f->clear();
  e->clear();
  vocab_f->clear();
  vocab_e->clear();
  ReadFile rf(filename);
  istream* in = rf.stream();
  assert(*in);
  string line;
  unsigned lc = 0;
  const WordID kDIV = TD::Convert("|||");
  vector<WordID> tmp;
  while(getline(*in, line)) {
    ++lc;
    e->push_back(vector<int>());
    f->push_back(vector<int>());
    vector<int>& le = e->back();
    vector<int>& lf = f->back();
    tmp.clear();
    TD::ConvertSentence(line, &tmp);
    bool isf = true;
    for (unsigned i = 0; i < tmp.size(); ++i) {
      const int cur = tmp[i];
      if (isf) {
        if (kDIV == cur) {
          isf = false;
        } else {
          lf.push_back(cur);
          vocab_f->insert(cur);
        }
      } else {
        if (cur == kDIV) {
          cerr << "ERROR in " << lc << ": " << line << endl << endl;
          abort();
        }
        le.push_back(cur);
        vocab_e->insert(cur);
      }
    }
    assert(isf == false);
  }
}

}