@Test public void ParseCommandPrefixTest() { String cmd = "java test.jar $master:$port"; String parsedCmd = "java test.jar localhost:8080"; List<Integer> parents = new ArrayList<Integer>(); List<Integer> children = new ArrayList<Integer>(); List<ByteBuffer> data = new ArrayList<ByteBuffer>(); Collection<Integer> parentDependencies = new ArrayList<Integer>(); Dependency dep = new Dependency(0, parents, children, cmd, data, "Dependency Test", "Tachyon Tests", "0.4", DependencyType.Narrow, parentDependencies, 0L); Assert.assertEquals(parsedCmd, dep.parseCommandPrefix()); }
String parseCommandPrefix() { String rtn = COMMAND_PREFIX; for (String s : DependencyVariables.sVariables.keySet()) { rtn = rtn.replace("$" + s, DependencyVariables.sVariables.get(s)); } return rtn; }
Dependency extends ImageWriter { String parseCommandPrefix() { String rtn = COMMAND_PREFIX; for (String s : DependencyVariables.sVariables.keySet()) { rtn = rtn.replace("$" + s, DependencyVariables.sVariables.get(s)); } return rtn; } }
Dependency extends ImageWriter { String parseCommandPrefix() { String rtn = COMMAND_PREFIX; for (String s : DependencyVariables.sVariables.keySet()) { rtn = rtn.replace("$" + s, DependencyVariables.sVariables.get(s)); } return rtn; } Dependency(int id, List<Integer> parents, List<Integer> children, String commandPrefix,
      List<ByteBuffer> data, String comment, String framework, String frameworkVersion,
      DependencyType type, Collection<Integer> parentDependencies, long creationTimeMs); }
Dependency extends ImageWriter { String parseCommandPrefix() { String rtn = COMMAND_PREFIX; for (String s : DependencyVariables.sVariables.keySet()) { rtn = rtn.replace("$" + s, DependencyVariables.sVariables.get(s)); } return rtn; } Dependency(int id, List<Integer> parents, List<Integer> children, String commandPrefix,
      List<ByteBuffer> data, String comment, String framework, String frameworkVersion,
      DependencyType type, Collection<Integer> parentDependencies, long creationTimeMs); synchronized void addChildrenDependency(int childDependencyId); synchronized void addLostFile(int fileId); synchronized void childCheckpointed(int childFileId); ClientDependencyInfo generateClientDependencyInfo(); synchronized List<Integer> getChildrenDependency(); synchronized String getCommand(); synchronized List<Integer> getLostFiles(); synchronized boolean hasCheckpointed(); synchronized boolean hasChildrenDependency(); synchronized boolean hasLostFile(); @Override String toString(); @Override synchronized void writeImage(ObjectWriter objWriter, DataOutputStream dos); }
Dependency extends ImageWriter { String parseCommandPrefix() { String rtn = COMMAND_PREFIX; for (String s : DependencyVariables.sVariables.keySet()) { rtn = rtn.replace("$" + s, DependencyVariables.sVariables.get(s)); } return rtn; } Dependency(int id, List<Integer> parents, List<Integer> children, String commandPrefix,
      List<ByteBuffer> data, String comment, String framework, String frameworkVersion,
      DependencyType type, Collection<Integer> parentDependencies, long creationTimeMs); synchronized void addChildrenDependency(int childDependencyId); synchronized void addLostFile(int fileId); synchronized void childCheckpointed(int childFileId); ClientDependencyInfo generateClientDependencyInfo(); synchronized List<Integer> getChildrenDependency(); synchronized String getCommand(); synchronized List<Integer> getLostFiles(); synchronized boolean hasCheckpointed(); synchronized boolean hasChildrenDependency(); synchronized boolean hasLostFile(); @Override String toString(); @Override synchronized void writeImage(ObjectWriter objWriter, DataOutputStream dos); final int ID; final long CREATION_TIME_MS; final List<Integer> PARENT_FILES; final List<Integer> CHILDREN_FILES; final String COMMAND_PREFIX; final List<ByteBuffer> DATA; final String COMMENT; final String FRAMEWORK; final String FRAMEWORK_VERSION; final DependencyType TYPE; final List<Integer> PARENT_DEPENDENCIES; }