| commit | a6bdfc9462074dbe9b9429de1c1cf6a6a90c0a4e | [log] [tgz] |
|---|---|---|
| author | buyingyi <buyingyi@gmail.com> | Sat Nov 02 02:29:42 2013 -0700 |
| committer | buyingyi <buyingyi@gmail.com> | Sat Nov 02 02:29:42 2013 -0700 |
| tree | 58437276abce175b121e8b968b54245d76348f53 | |
| parent | b60e6fdf318822e592395ccfb971a5bb9b9e27ea [diff] |
fix file write race condition
diff --git a/pregelix/pregelix-dataflow-std-base/pom.xml b/pregelix/pregelix-dataflow-std-base/pom.xml index 2b435a1..77d75bf 100644 --- a/pregelix/pregelix-dataflow-std-base/pom.xml +++ b/pregelix/pregelix-dataflow-std-base/pom.xml
@@ -90,6 +90,13 @@ </dependency> <dependency> <groupId>edu.uci.ics.hyracks</groupId> + <artifactId>hyracks-hdfs-core</artifactId> + <version>0.2.10-SNAPSHOT</version> + <type>jar</type> + <scope>compile</scope> + </dependency> + <dependency> + <groupId>edu.uci.ics.hyracks</groupId> <artifactId>hyracks-storage-am-common</artifactId> <version>0.2.10-SNAPSHOT</version> <type>jar</type>
diff --git a/pregelix/pregelix-dataflow-std-base/src/main/java/edu/uci/ics/pregelix/dataflow/std/base/ISerializerDeserializerFactory.java b/pregelix/pregelix-dataflow-std-base/src/main/java/edu/uci/ics/pregelix/dataflow/std/base/ISerializerDeserializerFactory.java index 1fdd0b6..894cba5 100644 --- a/pregelix/pregelix-dataflow-std-base/src/main/java/edu/uci/ics/pregelix/dataflow/std/base/ISerializerDeserializerFactory.java +++ b/pregelix/pregelix-dataflow-std-base/src/main/java/edu/uci/ics/pregelix/dataflow/std/base/ISerializerDeserializerFactory.java
@@ -16,10 +16,12 @@ import java.io.Serializable; +import org.apache.hadoop.conf.Configuration; + import edu.uci.ics.hyracks.api.dataflow.value.ISerializerDeserializer; public interface ISerializerDeserializerFactory<T> extends Serializable { - public ISerializerDeserializer<T> getSerializerDeserializer(); + public ISerializerDeserializer<T> getSerializerDeserializer(Configuration conf); }