| commit | 04a48a24d5cc371ff555fceec2b0b938605b8faf | [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 | e24de973ba758f7f87acf2106ee4f47699fd8c09 | |
| parent | 11770d102c280dae2b4f1697894ece554dc04e03 [diff] |
fix file write race condition
diff --git a/pregelix-dataflow-std-base/pom.xml b/pregelix-dataflow-std-base/pom.xml index 2b435a1..77d75bf 100644 --- a/pregelix-dataflow-std-base/pom.xml +++ b/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-dataflow-std-base/src/main/java/edu/uci/ics/pregelix/dataflow/std/base/ISerializerDeserializerFactory.java b/pregelix-dataflow-std-base/src/main/java/edu/uci/ics/pregelix/dataflow/std/base/ISerializerDeserializerFactory.java index 1fdd0b6..894cba5 100644 --- a/pregelix-dataflow-std-base/src/main/java/edu/uci/ics/pregelix/dataflow/std/base/ISerializerDeserializerFactory.java +++ b/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); }