Added formal command line options & new main class.

git-svn-id: https://ws10smt.googlecode.com/svn/trunk@200 ec762483-ff6d-05da-a07a-a48fb63a330f

1 files changed, 150 insertions, 0 deletions

diff --git a/gi/posterior-regularisation/prjava/src/phrase/Trainer.java b/gi/posterior-regularisation/prjava/src/phrase/Trainer.java
new file mode 100644
index 00000000..b19f3fb9
--- /dev/null
+++ b/gi/posterior-regularisation/prjava/src/phrase/Trainer.java
@@ -0,0 +1,150 @@
+package phrase;
+
+import io.FileUtil;
+import joptsimple.OptionParser;
+import joptsimple.OptionSet;
+import java.io.File;
+import java.io.IOException;
+import java.io.PrintStream;
+import java.util.Random;
+
+import arr.F;
+
+public class Trainer 
+{
+	public static void main(String[] args) 
+	{
+        OptionParser parser = new OptionParser();
+        parser.accepts("help");
+        parser.accepts("in").withRequiredArg().ofType(File.class);
+        parser.accepts("out").withRequiredArg().ofType(File.class);
+        parser.accepts("parameters").withRequiredArg().ofType(File.class);
+        parser.accepts("topics").withRequiredArg().ofType(Integer.class).defaultsTo(5);
+        parser.accepts("em-iterations").withRequiredArg().ofType(Integer.class).defaultsTo(5);
+        parser.accepts("pr-iterations").withRequiredArg().ofType(Integer.class).defaultsTo(0);
+        parser.accepts("threads").withRequiredArg().ofType(Integer.class).defaultsTo(0);
+        parser.accepts("scale-phrase").withRequiredArg().ofType(Double.class).defaultsTo(5.0);
+        parser.accepts("scale-context").withRequiredArg().ofType(Double.class).defaultsTo(0.0);
+        parser.accepts("seed").withRequiredArg().ofType(Long.class).defaultsTo(0l);
+        parser.accepts("convergence-threshold").withRequiredArg().ofType(Double.class).defaultsTo(1e-6);
+        OptionSet options = parser.parse(args);
+
+        if (options.has("help") || !options.has("in"))
+        {
+        	try {
+				parser.printHelpOn(System.err);
+			} catch (IOException e) {
+				System.err.println("This should never happen. Really.");
+				e.printStackTrace();
+			}
+        	System.exit(1);     
+        }
+		
+		int tags = (Integer) options.valueOf("topics");
+		int em_iterations = (Integer) options.valueOf("em-iterations");
+		int pr_iterations = (Integer) options.valueOf("pr-iterations");
+		double scale_phrase = (Double) options.valueOf("scale-phrase");
+		double scale_context = (Double) options.valueOf("scale-context");
+		int threads = (Integer) options.valueOf("threads");
+		double threshold = (Double) options.valueOf("convergence-threshold");
+		
+		if (options.has("seed"))
+			F.rng = new Random((Long) options.valueOf("seed"));
+		
+		if (tags <= 1 || scale_phrase < 0 || scale_context < 0 || threshold < 0)
+		{
+			System.err.println("Invalid arguments. Try again!");
+			System.exit(1);
+		}
+		
+		Corpus corpus = null;
+		File infile = (File) options.valueOf("in");
+		try {
+			System.out.println("Reading concordance from " + infile);
+			corpus = Corpus.readFromFile(FileUtil.reader(infile));
+			corpus.printStats(System.out);
+		} catch (IOException e) {
+			System.err.println("Failed to open input file: " + infile);
+			e.printStackTrace();
+			System.exit(1);
+		}
+		
+ 		System.out.println("Running with " + tags + " tags " +
+ 				"for " + em_iterations + " EM and " + pr_iterations + " PR iterations " +
+ 				"with scale " + scale_phrase + " phrase and " + scale_context + " context " +
+ 				"and " + threads + " threads");
+ 		System.out.println();
+		
+		PhraseCluster cluster = new PhraseCluster(tags, corpus, scale_phrase, scale_context, threads);
+				
+		double last = 0;
+		for (int i=0; i<em_iterations+pr_iterations; i++)
+		{
+			double o;
+			if (i < em_iterations) 
+				o = cluster.EM();
+			else if (scale_context == 0)
+			{
+				if (threads >= 1)
+					o = cluster.PREM_phrase_constraints_parallel();
+				else
+					o = cluster.PREM_phrase_constraints();
+			}
+			else 
+				o = cluster.PREM_phrase_context_constraints();
+			
+			System.out.println("ITER: "+i+" objective: " + o);
+			
+			if (i != 0 && Math.abs((o - last) / o) < threshold)
+			{
+				last = o;
+				if (i < em_iterations)
+				{
+					i = em_iterations - 1;
+					continue;
+				}
+				else
+					break;
+			}
+			last = o;
+		}
+		
+		double pl1lmax = cluster.phrase_l1lmax();
+		double cl1lmax = cluster.context_l1lmax();
+		System.out.println("\nFinal posterior phrase l1lmax " + pl1lmax + " context l1lmax " + cl1lmax);
+		if (pr_iterations == 0) 
+			System.out.println("With PR objective " + (last - scale_phrase*pl1lmax - scale_context*cl1lmax));
+		
+		if (options.has("out"))
+		{
+			File outfile = (File) options.valueOf("out");
+			try {
+				PrintStream ps = FileUtil.printstream(outfile);
+				cluster.displayPosterior(ps);
+				ps.close();
+			} catch (IOException e) {
+				System.err.println("Failed to open output file: " + outfile);
+				e.printStackTrace();
+				System.exit(1);
+			}
+		}
+
+		if (options.has("parameters"))
+		{
+			File outfile = (File) options.valueOf("parameters");
+			PrintStream ps;
+			try {
+				ps = FileUtil.printstream(outfile);
+				cluster.displayModelParam(ps);
+				ps.close();
+			} catch (IOException e) {
+				System.err.println("Failed to open output parameters file: " + outfile);
+				e.printStackTrace();
+				System.exit(1);
+			}
+		}
+		
+		if (cluster.pool != null)
+			cluster.pool.shutdown();
+	}
+}