@Test public void testDataSkewAndLargeShuffleCombination() throws Exception { final List<CompileTimePass> compileTimePasses = new ArrayList<>(); final Set<RunTimePass<?>> runTimePasses = new HashSet<>(); compileTimePasses.addAll(DataSkewPolicy.BUILDER.getCompileTimePasses()); runTimePasses.addAll(DataSkewPolicy.BUILDER.getRunTimePasses()); compileTimePasses.addAll(LargeShufflePolicy.BUILDER.getCompileTimePasses()); runTimePasses.addAll(LargeShufflePolicy.BUILDER.getRunTimePasses()); final Policy combinedPolicy = new PolicyImpl(compileTimePasses, runTimePasses); expectedException.expect(CompileTimeOptimizationException.class); combinedPolicy.runCompileTimeOptimization(dagForSkew, DAG.EMPTY_DAG_DIRECTORY); }
@Override public IRDAG runCompileTimeOptimization(final IRDAG dag, final String dagDirectory) { LOG.info("Launch Compile-time optimizations"); return process(dag, compileTimePasses.iterator(), dagDirectory); }
PolicyImpl implements Policy { @Override public IRDAG runCompileTimeOptimization(final IRDAG dag, final String dagDirectory) { LOG.info("Launch Compile-time optimizations"); return process(dag, compileTimePasses.iterator(), dagDirectory); } }
PolicyImpl implements Policy { @Override public IRDAG runCompileTimeOptimization(final IRDAG dag, final String dagDirectory) { LOG.info("Launch Compile-time optimizations"); return process(dag, compileTimePasses.iterator(), dagDirectory); } PolicyImpl(final List<CompileTimePass> compileTimePasses, final Set<RunTimePass<?>> runTimePasses); }
PolicyImpl implements Policy { @Override public IRDAG runCompileTimeOptimization(final IRDAG dag, final String dagDirectory) { LOG.info("Launch Compile-time optimizations"); return process(dag, compileTimePasses.iterator(), dagDirectory); } PolicyImpl(final List<CompileTimePass> compileTimePasses, final Set<RunTimePass<?>> runTimePasses); @Override IRDAG runCompileTimeOptimization(final IRDAG dag, final String dagDirectory); @Override IRDAG runRunTimeOptimizations(final IRDAG irdag, final Message message); }
PolicyImpl implements Policy { @Override public IRDAG runCompileTimeOptimization(final IRDAG dag, final String dagDirectory) { LOG.info("Launch Compile-time optimizations"); return process(dag, compileTimePasses.iterator(), dagDirectory); } PolicyImpl(final List<CompileTimePass> compileTimePasses, final Set<RunTimePass<?>> runTimePasses); @Override IRDAG runCompileTimeOptimization(final IRDAG dag, final String dagDirectory); @Override IRDAG runRunTimeOptimizations(final IRDAG irdag, final Message message);  }