You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@giraph.apache.org by rv...@apache.org on 2014/10/26 02:22:26 UTC
[43/47] git commit: updated refs/heads/release-1.1 to 4c139ee
GIRAPH-946. Upgrade to Gora 0.5 (Renato Javier Marroquín Mogrovejo via rvs)
Project: http://git-wip-us.apache.org/repos/asf/giraph/repo
Commit: http://git-wip-us.apache.org/repos/asf/giraph/commit/7c61dcf4
Tree: http://git-wip-us.apache.org/repos/asf/giraph/tree/7c61dcf4
Diff: http://git-wip-us.apache.org/repos/asf/giraph/diff/7c61dcf4
Branch: refs/heads/release-1.1
Commit: 7c61dcf4abaa422637a68839bf0d547a164375a3
Parents: 0bcc76d
Author: Roman Shaposhnik <rv...@apache.org>
Authored: Sun Oct 19 16:54:39 2014 -0700
Committer: Roman Shaposhnik <rv...@apache.org>
Committed: Sun Oct 19 16:54:39 2014 -0700
----------------------------------------------------------------------
giraph-gora/conf/edge_result.avsc | 12 +
giraph-gora/conf/vertex.avsc | 10 +
giraph-gora/conf/vertex.json | 18 -
giraph-gora/conf/vertex_result.avsc | 10 +
giraph-gora/pom.xml | 241 +++---
.../giraph/io/gora/GoraEdgeInputFormat.java | 12 +-
.../giraph/io/gora/GoraEdgeOutputFormat.java | 10 +-
.../io/gora/GoraGEdgeEdgeInputFormat.java | 9 +-
.../io/gora/GoraGEdgeEdgeOutputFormat.java | 5 +-
.../io/gora/GoraGVertexVertexInputFormat.java | 10 +-
.../io/gora/GoraGVertexVertexOutputFormat.java | 11 +-
.../giraph/io/gora/GoraVertexInputFormat.java | 14 +-
.../giraph/io/gora/GoraVertexOutputFormat.java | 8 +-
.../apache/giraph/io/gora/generated/GEdge.java | 842 +++++++++++++++---
.../giraph/io/gora/generated/GEdgeResult.java | 849 ++++++++++++++++---
.../giraph/io/gora/generated/GVertex.java | 641 +++++++++++---
.../giraph/io/gora/generated/GVertexResult.java | 644 +++++++++++---
.../io/gora/utils/ExtraGoraInputFormat.java | 9 +-
.../apache/giraph/io/gora/utils/GoraUtils.java | 42 +-
.../giraph/io/gora/GoraTestEdgeInputFormat.java | 14 +-
.../io/gora/GoraTestEdgeOutputFormat.java | 25 +-
.../io/gora/GoraTestVertexInputFormat.java | 12 +-
.../io/gora/GoraTestVertexOutputFormat.java | 23 +-
.../giraph/io/gora/TestGoraEdgeInputFormat.java | 4 +-
.../io/gora/TestGoraEdgeOutputFormat.java | 2 +-
pom.xml | 4 +-
26 files changed, 2728 insertions(+), 753 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/giraph/blob/7c61dcf4/giraph-gora/conf/edge_result.avsc
----------------------------------------------------------------------
diff --git a/giraph-gora/conf/edge_result.avsc b/giraph-gora/conf/edge_result.avsc
new file mode 100644
index 0000000..9319fa1
--- /dev/null
+++ b/giraph-gora/conf/edge_result.avsc
@@ -0,0 +1,12 @@
+{
+ "type": "record",
+ "name": "GEdgeResult",
+ "namespace": "org.apache.giraph.io.gora.generated",
+ "fields" : [
+ {"name": "edgeId", "type": "string"},
+ {"name": "edgeWeight", "type": "float"},
+ {"name": "vertexInId", "type": "string"},
+ {"name": "vertexOutId", "type": "string"},
+ {"name": "label", "type": "string"}
+ ]
+}
http://git-wip-us.apache.org/repos/asf/giraph/blob/7c61dcf4/giraph-gora/conf/vertex.avsc
----------------------------------------------------------------------
diff --git a/giraph-gora/conf/vertex.avsc b/giraph-gora/conf/vertex.avsc
new file mode 100644
index 0000000..88d4234
--- /dev/null
+++ b/giraph-gora/conf/vertex.avsc
@@ -0,0 +1,10 @@
+{
+ "type": "record",
+ "name": "GVertex",
+ "namespace": "org.apache.giraph.io.gora.generated",
+ "fields" : [
+ {"name": "vertexId", "type": "string"},
+ {"name": "vertexValue", "type": "float"},
+ {"name": "edges", "type": {"type": "map", "values": "string"}}
+ ]
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/giraph/blob/7c61dcf4/giraph-gora/conf/vertex.json
----------------------------------------------------------------------
diff --git a/giraph-gora/conf/vertex.json b/giraph-gora/conf/vertex.json
deleted file mode 100644
index 9f435fa..0000000
--- a/giraph-gora/conf/vertex.json
+++ /dev/null
@@ -1,18 +0,0 @@
-{
- "type": "record",
- "name": "Vertex",
- "namespace": "org.apache.giraph.gora.generated",
- "fields" : [
- {"name": "vertexId", "type": "long"},
- {"name": "value", "type": "float"},
- {"name": "edges", "type": {"type":"array", "items": {
- "name": "Edge",
- "type": "record",
- "namespace": "org.apache.giraph.gora.generated",
- "fields": [
- {"name": "vertexId", "type": "long"},
- {"name": "edgeValue", "type": "float"}
- ]
- }}}
- ]
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/giraph/blob/7c61dcf4/giraph-gora/conf/vertex_result.avsc
----------------------------------------------------------------------
diff --git a/giraph-gora/conf/vertex_result.avsc b/giraph-gora/conf/vertex_result.avsc
new file mode 100644
index 0000000..b594ca9
--- /dev/null
+++ b/giraph-gora/conf/vertex_result.avsc
@@ -0,0 +1,10 @@
+{
+ "type": "record",
+ "name": "GVertexResult",
+ "namespace": "org.apache.giraph.io.gora.generated",
+ "fields" : [
+ {"name": "vertexId", "type": "string"},
+ {"name": "vertexValue", "type": "float"},
+ {"name": "edges", "type": {"type": "map", "values": "string"}}
+ ]
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/giraph/blob/7c61dcf4/giraph-gora/pom.xml
----------------------------------------------------------------------
diff --git a/giraph-gora/pom.xml b/giraph-gora/pom.xml
index 38e3ab7..7f499c6 100644
--- a/giraph-gora/pom.xml
+++ b/giraph-gora/pom.xml
@@ -1,122 +1,139 @@
-<!--
-Licensed to the Apache Software Foundation (ASF) under one
-or more contributor license agreements. See the NOTICE file
-distributed with this work for additional information
-regarding copyright ownership. The ASF licenses this file
-to you under the Apache License, Version 2.0 (the
-"License"); you may not use this file except in compliance
-with the License. You may obtain a copy of the License at
-
-http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing,
-software distributed under the License is distributed on an
-"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-KIND, either express or implied. See the License for the
-specific language governing permissions and limitations
-under the License.
--->
+<!-- Licensed to the Apache Software Foundation (ASF) under one or more contributor
+ license agreements. See the NOTICE file distributed with this work for additional
+ information regarding copyright ownership. The ASF licenses this file to
+ you under the Apache License, Version 2.0 (the "License"); you may not use
+ this file except in compliance with the License. You may obtain a copy of
+ the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required
+ by applicable law or agreed to in writing, software distributed under the
+ License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS
+ OF ANY KIND, either express or implied. See the License for the specific
+ language governing permissions and limitations under the License. -->
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
- <modelVersion>4.0.0</modelVersion>
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+ <modelVersion>4.0.0</modelVersion>
- <parent>
- <groupId>org.apache.giraph</groupId>
- <artifactId>giraph-parent</artifactId>
- <version>1.1.0-SNAPSHOT</version>
- </parent>
- <artifactId>giraph-gora</artifactId>
- <packaging>jar</packaging>
+ <parent>
+ <groupId>org.apache.giraph</groupId>
+ <artifactId>giraph-parent</artifactId>
+ <version>1.1.0-SNAPSHOT</version>
+ </parent>
+ <artifactId>giraph-gora</artifactId>
+ <packaging>jar</packaging>
- <name>Apache Giraph Gora I/O</name>
- <url>http://gora.apache.org/giraph-gora/</url>
- <description>Giraph Gora input/output classes</description>
+ <name>Apache Giraph Gora I/O</name>
+ <url>http://gora.apache.org/giraph-gora/</url>
+ <description>Giraph Gora input/output classes</description>
- <properties>
- <top.dir>${project.basedir}/..</top.dir>
- </properties>
+ <properties>
+ <top.dir>${project.basedir}/..</top.dir>
+ </properties>
- <build>
- <plugins>
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-assembly-plugin</artifactId>
- </plugin>
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-checkstyle-plugin</artifactId>
- </plugin>
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-jar-plugin</artifactId>
- </plugin>
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-javadoc-plugin</artifactId>
- </plugin>
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-site-plugin</artifactId>
- <configuration>
- <siteDirectory>${project.basedir}/src/site</siteDirectory>
- </configuration>
- </plugin>
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-surefire-plugin</artifactId>
- <version>2.6</version>
- <configuration>
- <systemProperties>
- <property>
- <name>prop.jarLocation</name>
- <value>${top.dir}/giraph-core/target/giraph-${project.version}-${forHadoop}-jar-with-dependencies.jar</value>
- </property>
- </systemProperties>
- </configuration>
- </plugin>
- <plugin>
- <groupId>org.codehaus.mojo</groupId>
- <artifactId>findbugs-maven-plugin</artifactId>
- </plugin>
- </plugins>
- </build>
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-assembly-plugin</artifactId>
+ </plugin>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-checkstyle-plugin</artifactId>
+ </plugin>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-jar-plugin</artifactId>
+ </plugin>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-javadoc-plugin</artifactId>
+ </plugin>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-site-plugin</artifactId>
+ <configuration>
+ <siteDirectory>${project.basedir}/src/site</siteDirectory>
+ </configuration>
+ </plugin>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-surefire-plugin</artifactId>
+ <version>2.6</version>
+ <configuration>
+ <systemProperties>
+ <property>
+ <name>prop.jarLocation</name>
+ <value>${top.dir}/giraph-core/target/giraph-${project.version}-${forHadoop}-jar-with-dependencies.jar</value>
+ </property>
+ </systemProperties>
+ </configuration>
+ </plugin>
+ <plugin>
+ <groupId>org.codehaus.mojo</groupId>
+ <artifactId>findbugs-maven-plugin</artifactId>
+ </plugin>
+ </plugins>
+ </build>
- <dependencies>
- <!-- compile dependencies. sorted lexicographically. -->
- <dependency>
- <groupId>log4j</groupId>
- <artifactId>log4j</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.giraph</groupId>
- <artifactId>giraph-core</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.gora</groupId>
- <artifactId>gora-core</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.hadoop</groupId>
- <artifactId>avro</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.zookeeper</groupId>
- <artifactId>zookeeper</artifactId>
- </dependency>
+ <dependencies>
+ <!-- compile dependencies. sorted lexicographically. -->
+ <dependency>
+ <groupId>log4j</groupId>
+ <artifactId>log4j</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.giraph</groupId>
+ <artifactId>giraph-core</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.gora</groupId>
+ <artifactId>gora-core</artifactId>
+ <exclusions>
+ <exclusion>
+ <groupId>org.codehaus.jackson</groupId>
+ <artifactId>jackson-core-asl</artifactId>
+ </exclusion>
+ <exclusion>
+ <groupId>org.codehaus.jackson</groupId>
+ <artifactId>jackson-mapper-asl</artifactId>
+ </exclusion>
+ <exclusion>
+ <groupId>org.apache.gora</groupId>
+ <artifactId>gora-shims-distribution</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.avro</groupId>
+ <artifactId>avro</artifactId>
+ <version>${dep.avro.version}</version>
+ <exclusions>
+ <exclusion>
+ <groupId>org.codehaus.jackson</groupId>
+ <artifactId>jackson-core-asl</artifactId>
+ </exclusion>
+ <exclusion>
+ <groupId>org.codehaus.jackson</groupId>
+ <artifactId>jackson-mapper-asl</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.zookeeper</groupId>
+ <artifactId>zookeeper</artifactId>
+ </dependency>
- <!-- runtime dependency -->
- <dependency>
- <groupId>org.slf4j</groupId>
- <artifactId>slf4j-api</artifactId>
- <scope>runtime</scope>
- </dependency>
+ <!-- runtime dependency -->
+ <dependency>
+ <groupId>org.slf4j</groupId>
+ <artifactId>slf4j-api</artifactId>
+ <scope>runtime</scope>
+ </dependency>
- <!-- test dependencies. sorted lexicographically. -->
- <dependency>
- <groupId>junit</groupId>
- <artifactId>junit</artifactId>
- <scope>test</scope>
- </dependency>
- </dependencies>
+ <!-- test dependencies. sorted lexicographically. -->
+ <dependency>
+ <groupId>junit</groupId>
+ <artifactId>junit</artifactId>
+ <scope>test</scope>
+ </dependency>
+ </dependencies>
</project>
http://git-wip-us.apache.org/repos/asf/giraph/blob/7c61dcf4/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraEdgeInputFormat.java
----------------------------------------------------------------------
diff --git a/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraEdgeInputFormat.java b/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraEdgeInputFormat.java
index d0dcc32..8ef91f6 100644
--- a/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraEdgeInputFormat.java
+++ b/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraEdgeInputFormat.java
@@ -34,8 +34,8 @@ import org.apache.giraph.io.gora.utils.ExtraGoraInputFormat;
import org.apache.giraph.io.gora.utils.GoraUtils;
import org.apache.giraph.io.gora.utils.KeyFactory;
import org.apache.gora.persistency.Persistent;
-import org.apache.gora.query.Query;
import org.apache.gora.query.Result;
+import org.apache.gora.query.impl.QueryBase;
import org.apache.gora.store.DataStore;
import org.apache.gora.util.GoraException;
import org.apache.hadoop.conf.Configuration;
@@ -114,7 +114,7 @@ public abstract class GoraEdgeInputFormat
setPersistentClass((Class<? extends Persistent>) persistentClass);
setDatastoreClass((Class<? extends DataStore>) dataStoreClass);
setKeyFactoryClass(keyFactoryClass);
- setDataStore(createDataStore());
+ setDataStore(createDataStore(getConf()));
GORA_INPUT_FORMAT.setDataStore(getDataStore());
} catch (ClassNotFoundException e) {
LOG.error("Error while reading Gora Input parameters");
@@ -154,8 +154,9 @@ public abstract class GoraEdgeInputFormat
kFact.setDataStore(getDataStore());
setStartKey(kFact.buildKey(sKey));
setEndKey(kFact.buildKey(eKey));
- Query tmpQuery = GoraUtils.getQuery(
+ QueryBase tmpQuery = GoraUtils.getQuery(
getDataStore(), getStartKey(), getEndKey());
+ tmpQuery.setConf(context.getConfiguration());
GORA_INPUT_FORMAT.setQuery(tmpQuery);
List<InputSplit> splits = GORA_INPUT_FORMAT.getSplits(context);
return splits;
@@ -273,12 +274,13 @@ public abstract class GoraEdgeInputFormat
/**
* Gets the data store object initialized.
+ * @param conf Configuration
* @return DataStore created
*/
- public DataStore createDataStore() {
+ public DataStore createDataStore(Configuration conf) {
DataStore dsCreated = null;
try {
- dsCreated = GoraUtils.createSpecificDataStore(getDatastoreClass(),
+ dsCreated = GoraUtils.createSpecificDataStore(conf, getDatastoreClass(),
getKeyClass(), getPersistentClass());
} catch (GoraException e) {
LOG.error("Error creating data store.");
http://git-wip-us.apache.org/repos/asf/giraph/blob/7c61dcf4/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraEdgeOutputFormat.java
----------------------------------------------------------------------
diff --git a/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraEdgeOutputFormat.java b/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraEdgeOutputFormat.java
index be9f472..d030d70 100644
--- a/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraEdgeOutputFormat.java
+++ b/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraEdgeOutputFormat.java
@@ -30,11 +30,12 @@ import org.apache.giraph.io.gora.utils.GoraUtils;
import org.apache.gora.persistency.Persistent;
import org.apache.gora.store.DataStore;
import org.apache.gora.util.GoraException;
+import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.io.Writable;
import org.apache.hadoop.io.WritableComparable;
import org.apache.hadoop.mapreduce.JobContext;
-import org.apache.hadoop.mapreduce.TaskAttemptContext;
import org.apache.hadoop.mapreduce.OutputCommitter;
+import org.apache.hadoop.mapreduce.TaskAttemptContext;
import org.apache.log4j.Logger;
/**
@@ -83,12 +84,13 @@ public abstract class GoraEdgeOutputFormat<I extends WritableComparable,
/**
* Gets the data store object initialized.
+ * @param conf Configuration
* @return DataStore created
*/
- public DataStore createDataStore() {
+ public DataStore createDataStore(Configuration conf) {
DataStore dsCreated = null;
try {
- dsCreated = GoraUtils.createSpecificDataStore(getDatastoreClass(),
+ dsCreated = GoraUtils.createSpecificDataStore(conf, getDatastoreClass(),
getKeyClass(), getPersistentClass());
} catch (GoraException e) {
getLogger().error("Error creating data store.");
@@ -159,7 +161,7 @@ public abstract class GoraEdgeOutputFormat<I extends WritableComparable,
setKeyClass(keyClass);
setPersistentClass((Class<? extends Persistent>) persistentClass);
setDatastoreClass((Class<? extends DataStore>) dataStoreClass);
- setDataStore(createDataStore());
+ setDataStore(createDataStore(context.getConfiguration()));
if (getDataStore() != null) {
getLogger().debug("The data store has been created.");
}
http://git-wip-us.apache.org/repos/asf/giraph/blob/7c61dcf4/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraGEdgeEdgeInputFormat.java
----------------------------------------------------------------------
diff --git a/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraGEdgeEdgeInputFormat.java b/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraGEdgeEdgeInputFormat.java
index e738f36..a2a3417 100644
--- a/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraGEdgeEdgeInputFormat.java
+++ b/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraGEdgeEdgeInputFormat.java
@@ -69,14 +69,11 @@ public class GoraGEdgeEdgeInputFormat
(Object goraObject) {
Edge<LongWritable, FloatWritable> edge = null;
GEdge goraEdge = (GEdge) goraObject;
- Long dest;
- Long value;
- dest = Long.valueOf(goraEdge.getVertexOutId().toString());
this.sourceId = new LongWritable();
this.sourceId.set(Long.valueOf(goraEdge.getVertexInId().toString()));
- value = (long) goraEdge.getEdgeWeight();
- edge = EdgeFactory.create(new LongWritable(dest),
- new FloatWritable(value));
+ edge = EdgeFactory.create(
+ new LongWritable(Long.valueOf(goraEdge.getVertexOutId().toString())),
+ new FloatWritable(goraEdge.getEdgeWeight()));
return edge;
}
http://git-wip-us.apache.org/repos/asf/giraph/blob/7c61dcf4/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraGEdgeEdgeOutputFormat.java
----------------------------------------------------------------------
diff --git a/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraGEdgeEdgeOutputFormat.java b/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraGEdgeEdgeOutputFormat.java
index d350d37..82b02d0 100644
--- a/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraGEdgeEdgeOutputFormat.java
+++ b/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraGEdgeEdgeOutputFormat.java
@@ -19,7 +19,6 @@ package org.apache.giraph.io.gora;
import java.io.IOException;
-import org.apache.avro.util.Utf8;
import org.apache.giraph.edge.Edge;
import org.apache.giraph.io.gora.generated.GEdgeResult;
import org.apache.gora.persistency.Persistent;
@@ -57,9 +56,9 @@ public class GoraGEdgeEdgeOutputFormat
protected Persistent getGoraEdge(LongWritable srcId,
DoubleWritable srcValue, Edge<LongWritable, FloatWritable> edge) {
GEdgeResult tmpGEdge = new GEdgeResult();
- tmpGEdge.setEdgeId(new Utf8(srcId.toString()));
+ tmpGEdge.setEdgeId(srcId.toString());
tmpGEdge.setEdgeWeight(edge.getValue().get());
- tmpGEdge.setVertexOutId(new Utf8(edge.getTargetVertexId().toString()));
+ tmpGEdge.setVertexOutId(edge.getTargetVertexId().toString());
getLogger().debug("GoraObject created: " + tmpGEdge.toString());
return tmpGEdge;
}
http://git-wip-us.apache.org/repos/asf/giraph/blob/7c61dcf4/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraGVertexVertexInputFormat.java
----------------------------------------------------------------------
diff --git a/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraGVertexVertexInputFormat.java b/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraGVertexVertexInputFormat.java
index cb0f005..34ba7ec 100644
--- a/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraGVertexVertexInputFormat.java
+++ b/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraGVertexVertexInputFormat.java
@@ -20,7 +20,6 @@ package org.apache.giraph.io.gora;
import java.io.IOException;
import java.util.Set;
-import org.apache.avro.util.Utf8;
import org.apache.giraph.edge.Edge;
import org.apache.giraph.edge.EdgeFactory;
import org.apache.giraph.graph.Vertex;
@@ -75,12 +74,13 @@ public class GoraGVertexVertexInputFormat
GVertex tmpGVertex = (GVertex) goraObject;
LongWritable vrtxId = new LongWritable(
- Long.parseLong(tmpGVertex.getVertexId().toString()));
- DoubleWritable vrtxValue = new DoubleWritable(tmpGVertex.getValue());
+ Long.parseLong(tmpGVertex.getVertexId().toString()));
+ DoubleWritable vrtxValue = new DoubleWritable(
+ tmpGVertex.getVertexValue());
vertex.initialize(vrtxId, vrtxValue);
if (tmpGVertex.getEdges() != null && !tmpGVertex.getEdges().isEmpty()) {
- Set<Utf8> keyIt = tmpGVertex.getEdges().keySet();
- for (Utf8 key : keyIt) {
+ Set<CharSequence> keyIt = tmpGVertex.getEdges().keySet();
+ for (CharSequence key : keyIt) {
String keyVal = key.toString();
String valVal = tmpGVertex.getEdges().get(key).toString();
Edge<LongWritable, FloatWritable> edge;
http://git-wip-us.apache.org/repos/asf/giraph/blob/7c61dcf4/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraGVertexVertexOutputFormat.java
----------------------------------------------------------------------
diff --git a/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraGVertexVertexOutputFormat.java b/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraGVertexVertexOutputFormat.java
index 893e083..4a9c229 100644
--- a/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraGVertexVertexOutputFormat.java
+++ b/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraGVertexVertexOutputFormat.java
@@ -20,7 +20,6 @@ package org.apache.giraph.io.gora;
import java.io.IOException;
import java.util.Iterator;
-import org.apache.avro.util.Utf8;
import org.apache.giraph.edge.Edge;
import org.apache.giraph.graph.Vertex;
import org.apache.giraph.io.VertexWriter;
@@ -60,15 +59,15 @@ public class GoraGVertexVertexOutputFormat
protected Persistent getGoraVertex(
Vertex<LongWritable, DoubleWritable, FloatWritable> vertex) {
GVertexResult tmpGVertex = new GVertexResult();
- tmpGVertex.setVertexId(new Utf8(vertex.getId().toString()));
- tmpGVertex.setValue(Float.parseFloat(vertex.getValue().toString()));
+ tmpGVertex.setVertexId(vertex.getId().toString());
+ tmpGVertex.setVertexValue(Float.parseFloat(vertex.getValue().toString()));
Iterator<Edge<LongWritable, FloatWritable>> it =
vertex.getEdges().iterator();
while (it.hasNext()) {
Edge<LongWritable, FloatWritable> edge = it.next();
- tmpGVertex.putToEdges(
- new Utf8(edge.getTargetVertexId().toString()),
- new Utf8(edge.getValue().toString()));
+ tmpGVertex.getEdges().put(
+ edge.getTargetVertexId().toString(),
+ edge.getValue().toString());
}
return tmpGVertex;
}
http://git-wip-us.apache.org/repos/asf/giraph/blob/7c61dcf4/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraVertexInputFormat.java
----------------------------------------------------------------------
diff --git a/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraVertexInputFormat.java b/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraVertexInputFormat.java
index 9a6ad8c..ee5e7b6 100644
--- a/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraVertexInputFormat.java
+++ b/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraVertexInputFormat.java
@@ -30,12 +30,12 @@ import java.util.List;
import org.apache.giraph.graph.Vertex;
import org.apache.giraph.io.VertexInputFormat;
import org.apache.giraph.io.VertexReader;
-import org.apache.giraph.io.gora.utils.KeyFactory;
import org.apache.giraph.io.gora.utils.ExtraGoraInputFormat;
import org.apache.giraph.io.gora.utils.GoraUtils;
+import org.apache.giraph.io.gora.utils.KeyFactory;
import org.apache.gora.persistency.Persistent;
-import org.apache.gora.query.Query;
import org.apache.gora.query.Result;
+import org.apache.gora.query.impl.QueryBase;
import org.apache.gora.store.DataStore;
import org.apache.gora.util.GoraException;
import org.apache.hadoop.conf.Configuration;
@@ -115,7 +115,7 @@ public abstract class GoraVertexInputFormat<
setPersistentClass((Class<? extends Persistent>) persistentClass);
setDatastoreClass((Class<? extends DataStore>) dataStoreClass);
setKeyFactoryClass(keyFactoryClass);
- setDataStore(createDataStore());
+ setDataStore(createDataStore(conf));
GORA_INPUT_FORMAT.setDataStore(getDataStore());
} catch (ClassNotFoundException e) {
LOG.error("Error while reading Gora Input parameters");
@@ -170,8 +170,9 @@ public abstract class GoraVertexInputFormat<
setStartKey(kFact.buildKey(sKey));
setEndKey(kFact.buildKey(eKey));
}
- Query tmpQuery = GoraUtils.getQuery(
+ QueryBase tmpQuery = GoraUtils.getQuery(
getDataStore(), getStartKey(), getEndKey());
+ tmpQuery.setConf(getConf());
GORA_INPUT_FORMAT.setQuery(tmpQuery);
List<InputSplit> splits = GORA_INPUT_FORMAT.getSplits(context);
return splits;
@@ -179,12 +180,13 @@ public abstract class GoraVertexInputFormat<
/**
* Gets the data store object initialized.
+ * @param conf Configuration
* @return DataStore created
*/
- public DataStore createDataStore() {
+ public DataStore createDataStore(Configuration conf) {
DataStore dsCreated = null;
try {
- dsCreated = GoraUtils.createSpecificDataStore(getDatastoreClass(),
+ dsCreated = GoraUtils.createSpecificDataStore(conf, getDatastoreClass(),
getKeyClass(), getPersistentClass());
} catch (GoraException e) {
LOG.error("Error creating data store.");
http://git-wip-us.apache.org/repos/asf/giraph/blob/7c61dcf4/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraVertexOutputFormat.java
----------------------------------------------------------------------
diff --git a/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraVertexOutputFormat.java b/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraVertexOutputFormat.java
index 5fcc684..93143da 100644
--- a/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraVertexOutputFormat.java
+++ b/giraph-gora/src/main/java/org/apache/giraph/io/gora/GoraVertexOutputFormat.java
@@ -30,6 +30,7 @@ import org.apache.giraph.io.gora.utils.GoraUtils;
import org.apache.gora.persistency.Persistent;
import org.apache.gora.store.DataStore;
import org.apache.gora.util.GoraException;
+import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.io.Writable;
import org.apache.hadoop.io.WritableComparable;
import org.apache.hadoop.mapreduce.JobContext;
@@ -89,12 +90,13 @@ public abstract class GoraVertexOutputFormat<
/**
* Gets the data store object initialized.
+ * @param conf Configuration.
* @return DataStore created
*/
- public DataStore createDataStore() {
+ public DataStore createDataStore(Configuration conf) {
DataStore dsCreated = null;
try {
- dsCreated = GoraUtils.createSpecificDataStore(getDatastoreClass(),
+ dsCreated = GoraUtils.createSpecificDataStore(conf, getDatastoreClass(),
getKeyClass(), getPersistentClass());
} catch (GoraException e) {
getLogger().error("Error creating data store.");
@@ -166,7 +168,7 @@ public abstract class GoraVertexOutputFormat<
setKeyClass(keyClass);
setPersistentClass((Class<? extends Persistent>) persistentClass);
setDatastoreClass((Class<? extends DataStore>) dataStoreClass);
- setDataStore(createDataStore());
+ setDataStore(createDataStore(context.getConfiguration()));
if (getDataStore() != null) {
getLogger().info("The output data store has been created.");
}
http://git-wip-us.apache.org/repos/asf/giraph/blob/7c61dcf4/giraph-gora/src/main/java/org/apache/giraph/io/gora/generated/GEdge.java
----------------------------------------------------------------------
diff --git a/giraph-gora/src/main/java/org/apache/giraph/io/gora/generated/GEdge.java b/giraph-gora/src/main/java/org/apache/giraph/io/gora/generated/GEdge.java
index f6ac3f7..c8b0667 100644
--- a/giraph-gora/src/main/java/org/apache/giraph/io/gora/generated/GEdge.java
+++ b/giraph-gora/src/main/java/org/apache/giraph/io/gora/generated/GEdge.java
@@ -15,35 +15,30 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.giraph.io.gora.generated;
-import org.apache.avro.Schema;
-import org.apache.avro.AvroRuntimeException;
-import org.apache.avro.util.Utf8;
-import org.apache.gora.persistency.StateManager;
-import org.apache.gora.persistency.impl.PersistentBase;
-import org.apache.gora.persistency.impl.StateManagerImpl;
-
/**
* Example class for defining a Giraph-Edge.
*/
@SuppressWarnings("all")
-public class GEdge extends PersistentBase {
- /**
- * Schema used for the class.
- */
- public static final Schema OBJ_SCHEMA = Schema.parse("{\"type\":\"record\"," +
- "\"name\":\"GEdge\",\"namespace\":\"org.apache.giraph.gora.generated\"," +
- "\"fields\":[{\"name\":\"edgeId\",\"type\":\"string\"}," +
- "{\"name\":\"edgeWeight\",\"type\":\"float\"}," +
- "{\"name\":\"vertexInId\",\"type\":\"string\"}," +
- "{\"name\":\"vertexOutId\",\"type\":\"string\"}," +
- "{\"name\":\"label\",\"type\":\"string\"}]}");
+public class GEdge extends org.apache.gora.persistency.impl.PersistentBase
+ implements org.apache.avro.specific.SpecificRecord,
+ org.apache.gora.persistency.Persistent {
/**
- * Field enum
+ * Schema used for the class.
*/
+ public static final org.apache.avro.Schema SCHEMAS =
+ new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\"," +
+ "\"name\":\"GEdge\"," +
+ "\"namespace\":\"org.apache.giraph.gora.generated\"," +
+ "\"fields\":[{\"name\":\"edgeId\",\"type\":\"string\"}," +
+ "{\"name\":\"edgeWeight\",\"type\":\"float\"}," +
+ "{\"name\":\"vertexInId\",\"type\":\"string\"}," +
+ "{\"name\":\"vertexOutId\",\"type\":\"string\"}," +
+ "{\"name\":\"label\",\"type\":\"string\"}]}");
+
+ /** Enum containing all data bean's fields. */
public static enum Field {
/**
* Edge id.
@@ -71,19 +66,19 @@ public class GEdge extends PersistentBase {
LABEL(4, "label");
/**
- * Field index
+ * Field's index.
*/
private int index;
/**
- * Field name
+ * Field's name.
*/
private String name;
/**
- * Field constructor
- * @param index of attribute
- * @param name of attribute
+ * Field's constructor
+ * @param index field's index.
+ * @param name field's name.
*/
Field(int index, String name) {
this.index = index;
@@ -91,24 +86,24 @@ public class GEdge extends PersistentBase {
}
/**
- * Gets index
- * @return int of attribute.
+ * Gets field's index.
+ * @return int field's index.
*/
public int getIndex() {
return index;
}
/**
- * Gets name
- * @return String of name.
+ * Gets field's name.
+ * @return String field's name.
*/
public String getName() {
return name;
}
/**
- * Gets name
- * @return String of name.
+ * Gets field's attributes to string.
+ * @return String field's attributes to string.
*/
public String toString() {
return name;
@@ -119,77 +114,61 @@ public class GEdge extends PersistentBase {
* Array containing all fields/
*/
private static final String[] ALL_FIELDS = {
- "edgeId", "edgeWeight", "vertexInId", "vertexOutId", "label"
- };
-
- static {
- PersistentBase.registerFields(GEdge.class, ALL_FIELDS);
- }
-
- /**
- * edgeId
- */
- private Utf8 edgeId;
+ "edgeId", "edgeWeight", "vertexInId", "vertexOutId", "label"};
/**
- * edgeWeight
+ * Tombstone.
*/
- private float edgeWeight;
+ private static final Tombstone TOMBSTONE = new Tombstone();
/**
- * vertexInId
+ * edgeId.
*/
- private Utf8 vertexInId;
+ private java.lang.CharSequence edgeId;
/**
- * vertexOutId
+ * edgeWeight.
*/
- private Utf8 vertexOutId;
+ private float edgeWeight;
/**
- * label
+ * vertexInId.
*/
- private Utf8 label;
+ private java.lang.CharSequence vertexInId;
/**
- * Default constructor.
+ * vertexOutId.
*/
- public GEdge() {
- this(new StateManagerImpl());
- }
+ private java.lang.CharSequence vertexOutId;
/**
- * Constructor
- * @param stateManager from which the object will be created.
+ * label.
*/
- public GEdge(StateManager stateManager) {
- super(stateManager);
- }
+ private java.lang.CharSequence label;
/**
- * Creates a new instance
- * @param stateManager from which the object will be created.
- * @return GEdge created
+ * Gets the total field count.
+ * @return int field count
*/
- public GEdge newInstance(StateManager stateManager) {
- return new GEdge(stateManager);
+ public int getFieldsCount() {
+ return GEdge.ALL_FIELDS.length;
}
/**
- * Gets the object schema
- * @return Schema of the object.
+ * Gets the schema
+ * @return Schema
*/
- public Schema getSchema() {
- return OBJ_SCHEMA;
+ public org.apache.avro.Schema getSchema() {
+ return SCHEMAS;
}
/**
* Gets field
- * @param fieldIndex index field.
+ * @param field index field.
* @return Object from an index.
*/
- public Object get(int fieldIndex) {
- switch (fieldIndex) {
+ public java.lang.Object get(int field) {
+ switch (field) {
case 0:
return edgeId;
case 1:
@@ -201,114 +180,725 @@ public class GEdge extends PersistentBase {
case 4:
return label;
default:
- throw new AvroRuntimeException("Bad index");
+ throw new org.apache.avro.AvroRuntimeException("Bad index");
}
}
/**
* Puts a value into a field.
- * @param fieldIndex index of field used.
- * @param fieldValue value of field used.
+ * @param field index of field used.
+ * @param value value of field used.
*/
@SuppressWarnings(value = "unchecked")
- public void put(int fieldIndex, Object fieldValue) {
- if (isFieldEqual(fieldIndex, fieldValue)) {
- return;
- }
- getStateManager().setDirty(this, fieldIndex);
- switch (fieldIndex) {
+ public void put(int field, java.lang.Object value) {
+ switch (field) {
case 0:
- edgeId = (Utf8) fieldValue; break;
+ edgeId = (java.lang.CharSequence) value;
+ break;
case 1:
- edgeWeight = (Float) fieldValue; break;
+ edgeWeight = (java.lang.Float) value;
+ break;
case 2:
- vertexInId = (Utf8) fieldValue; break;
+ vertexInId = (java.lang.CharSequence) value;
+ break;
case 3:
- vertexOutId = (Utf8) fieldValue; break;
+ vertexOutId = (java.lang.CharSequence) value;
+ break;
case 4:
- label = (Utf8) fieldValue; break;
+ label = (java.lang.CharSequence) value;
+ break;
default:
- throw new AvroRuntimeException("Bad index");
+ throw new org.apache.avro.AvroRuntimeException("Bad index");
}
}
/**
- * Gets edgeId
- * @return Utf8 edgeId
+ * Gets the value of the 'edgeId' field.
+ * @return CharSequence.
+ */
+ public java.lang.CharSequence getEdgeId() {
+ return edgeId;
+ }
+
+ /**
+ * Sets the value of the 'edgeId' field.
+ * @param value the value to set.
+ */
+ public void setEdgeId(java.lang.CharSequence value) {
+ this.edgeId = value;
+ setDirty(0);
+ }
+
+ /**
+ * Checks the dirty status of the 'edgeId' field. A field is dirty if it
+ * represents a change that has not yet been written to the database.
+ * @param value the value to set.
+ * @return boolean
+ */
+ public boolean isEdgeIdDirty(java.lang.CharSequence value) {
+ return isDirty(0);
+ }
+
+ /**
+ * Gets the value of the 'edgeWeight' field.
+ * @return Float
*/
- public Utf8 getEdgeId() {
- return (Utf8) get(0);
+ public java.lang.Float getEdgeWeight() {
+ return edgeWeight;
}
/**
- * Sets edgeId
- * @param value edgeId
+ * Sets the value of the 'edgeWeight' field.
+ * @param value the value to set.
*/
- public void setEdgeId(Utf8 value) {
- put(0, value);
+ public void setEdgeWeight(java.lang.Float value) {
+ this.edgeWeight = value;
+ setDirty(1);
}
/**
- * Gets edgeWeight
- * @return float edgeWeight
+ * Checks the dirty status of the 'edgeWeight' field. A field is dirty if it
+ * represents a change that has not yet been written to the database.
+ * @param value the value to set.
+ * @return boolean
*/
- public float getEdgeWeight() {
- return (Float) get(1);
+ public boolean isEdgeWeightDirty(java.lang.Float value) {
+ return isDirty(1);
}
/**
- * Sets edgeWeight
- * @param value edgeWeight
+ * Gets the value of the 'vertexInId' field.
+ * @return CharSequence
*/
- public void setEdgeWeight(float value) {
- put(1, value);
+ public java.lang.CharSequence getVertexInId() {
+ return vertexInId;
}
/**
- * Gets edgeVertexInId
- * @return Utf8 edgeVertexInId
+ * Sets the value of the 'vertexInId' field.
+ * @param value the value to set.
*/
- public Utf8 getVertexInId() {
- return (Utf8) get(2);
+ public void setVertexInId(java.lang.CharSequence value) {
+ this.vertexInId = value;
+ setDirty(2);
}
/**
- * Sets edgeVertexInId
- * @param value edgeVertexInId
+ * Checks the dirty status of the 'vertexInId' field. A field is dirty if it
+ * represents a change that has not yet been written to the database.
+ * @param value the value to set.
+ * @return boolean
*/
- public void setVertexInId(Utf8 value) {
- put(2, value);
+ public boolean isVertexInIdDirty(java.lang.CharSequence value) {
+ return isDirty(2);
}
/**
- * Gets edgeVertexOutId
- * @return Utf8 edgeVertexOutId
+ * Gets the value of the 'vertexOutId' field.
+ * @return CharSequence
*/
- public Utf8 getVertexOutId() {
- return (Utf8) get(3);
+ public java.lang.CharSequence getVertexOutId() {
+ return vertexOutId;
}
/**
- * Sets edgeVertexOutId
- * @param value edgeVertexOutId
+ * Sets the value of the 'vertexOutId' field.
+ * @param value the value to set.
*/
- public void setVertexOutId(Utf8 value) {
- put(3, value);
+ public void setVertexOutId(java.lang.CharSequence value) {
+ this.vertexOutId = value;
+ setDirty(3);
}
/**
- * Gets edgeLabel
- * @return Utf8 edgeLabel
+ * Checks the dirty status of the 'vertexOutId' field. A field is dirty if it
+ * represents a change that has not yet been written to the database.
+ * @param value the value to set.
+ * @return boolean
*/
- public Utf8 getLabel() {
- return (Utf8) get(4);
+ public boolean isVertexOutIdDirty(java.lang.CharSequence value) {
+ return isDirty(3);
}
/**
- * Sets edgeLabel
- * @param value edgeLabel
+ * Gets the value of the 'label' field.
+ * @return CharSequence
*/
- public void setLabel(Utf8 value) {
- put(4, value);
+ public java.lang.CharSequence getLabel() {
+ return label;
+ }
+
+ /**
+ * Sets the value of the 'label' field.
+ * @param value the value to set.
+ */
+ public void setLabel(java.lang.CharSequence value) {
+ this.label = value;
+ setDirty(4);
+ }
+
+ /**
+ * Checks the dirty status of the 'label' field. A field is dirty if it
+ * represents a change that has not yet been written to the database.
+ * @param value the value to set.
+ * @return boolean
+ */
+ public boolean isLabelDirty(java.lang.CharSequence value) {
+ return isDirty(4);
+ }
+
+ /**
+ * Creates a new GEdge RecordBuilder.
+ * @return GEdge.Builder
+ */
+ public static org.apache.giraph.io.gora.generated.GEdge.Builder newBuilder() {
+ return new org.apache.giraph.io.gora.generated.GEdge.Builder();
+ }
+
+ /**
+ * Creates a new GEdge RecordBuilder by copying an existing Builder
+ * @param other GEdge.Builder
+ * @return org.apache.giraph.io.gora.generated.GEdge.Builder
+ */
+ public static org.apache.giraph.io.gora.generated.GEdge.Builder newBuilder(
+ org.apache.giraph.io.gora.generated.GEdge.Builder other) {
+ return new org.apache.giraph.io.gora.generated.GEdge.Builder(other);
+ }
+
+ /**
+ * Creates a new GEdge RecordBuilder by copying an existing GEdge instance.
+ * @param other GEdge
+ * @return org.apache.giraph.io.gora.generated.GEdge.Builder
+ */
+ public static org.apache.giraph.io.gora.generated.GEdge.Builder newBuilder(
+ org.apache.giraph.io.gora.generated.GEdge other) {
+ return new org.apache.giraph.io.gora.generated.GEdge.Builder(other);
+ }
+
+ /**
+ * Makes a deep copy from a bytebuffer.
+ * @param input ByteBuffer
+ * @return ByteBuffer
+ */
+ private static java.nio.ByteBuffer deepCopyToReadOnlyBuffer(
+ java.nio.ByteBuffer input) {
+ java.nio.ByteBuffer copy = java.nio.ByteBuffer.allocate(input.capacity());
+ int position = input.position();
+ input.reset();
+ int mark = input.position();
+ int limit = input.limit();
+ input.rewind();
+ input.limit(input.capacity());
+ copy.put(input);
+ input.rewind();
+ copy.rewind();
+ input.position(mark);
+ input.mark();
+ copy.position(mark);
+ copy.mark();
+ input.position(position);
+ copy.position(position);
+ input.limit(limit);
+ copy.limit(limit);
+ return copy.asReadOnlyBuffer();
+ }
+
+ /**
+ * RecordBuilder for GEdge instances.
+ */
+ public static class Builder extends
+ org.apache.avro.specific.SpecificRecordBuilderBase<GEdge> implements
+ org.apache.avro.data.RecordBuilder<GEdge> {
+
+ /**
+ * edgeId.
+ */
+ private java.lang.CharSequence edgeId;
+
+ /**
+ * edgeWeight.
+ */
+ private float edgeWeight;
+
+ /**
+ * vertexInId
+ */
+ private java.lang.CharSequence vertexInId;
+
+ /**
+ * vertexOutId.
+ */
+ private java.lang.CharSequence vertexOutId;
+
+ /**
+ * label.
+ */
+ private java.lang.CharSequence label;
+
+ /**
+ * Creates a new Builder
+ */
+ private Builder() {
+ super(org.apache.giraph.io.gora.generated.GEdge.SCHEMAS);
+ }
+
+ /**
+ * Creates a Builder by copying an existing Builder.
+ * @param other GEdge.Builder
+ */
+ private Builder(org.apache.giraph.io.gora.generated.GEdge.Builder other) {
+ super(other);
+ }
+
+ /**
+ * Creates a Builder by copying an existing GEdge instance.
+ * @param other GEdge
+ */
+ // CHECKSTYLE: stop Indentation
+ private Builder(org.apache.giraph.io.gora.generated.GEdge other) {
+ super(org.apache.giraph.io.gora.generated.GEdge.SCHEMAS);
+ if (isValidValue(fields()[0], other.edgeId)) {
+ this.edgeId = (java.lang.CharSequence) data().deepCopy(
+ fields()[0].schema(), other.edgeId);
+ fieldSetFlags()[0] = true;
+ }
+ if (isValidValue(fields()[1], other.edgeWeight)) {
+ this.edgeWeight = (java.lang.Float) data().deepCopy(
+ fields()[1].schema(), other.edgeWeight);
+ fieldSetFlags()[1] = true;
+ }
+ if (isValidValue(fields()[2], other.vertexInId)) {
+ this.vertexInId = (java.lang.CharSequence) data().deepCopy(
+ fields()[2].schema(), other.vertexInId);
+ fieldSetFlags()[2] = true;
+ }
+ if (isValidValue(fields()[3], other.vertexOutId)) {
+ this.vertexOutId = (java.lang.CharSequence) data().deepCopy(
+ fields()[3].schema(), other.vertexOutId);
+ fieldSetFlags()[3] = true;
+ }
+ if (isValidValue(fields()[4], other.label)) {
+ this.label = (java.lang.CharSequence) data().deepCopy(
+ fields()[4].schema(), other.label);
+ fieldSetFlags()[4] = true;
+ }
+ }
+ // CHECKSTYLE: resume Indentation
+
+ /**
+ * Gets the value of the 'edgeId' field
+ * @return CharSequence
+ */
+ public java.lang.CharSequence getEdgeId() {
+ return edgeId;
+ }
+
+ /**
+ * Sets the value of the 'edgeId' field
+ * @param value CharSequence
+ * @return GEdge.Builder
+ */
+ // CHECKSTYLE: stop Indentation
+ public org.apache.giraph.io.gora.generated.GEdge.Builder setEdgeId(
+ java.lang.CharSequence value) {
+ validate(fields()[0], value);
+ this.edgeId = value;
+ fieldSetFlags()[0] = true;
+ return this;
+ }
+ // CHECKSTYLE: resume Indentation
+
+ /**
+ * Checks whether the 'edgeId' field has been set.
+ * @return boolean.
+ */
+ public boolean hasEdgeId() {
+ return fieldSetFlags()[0];
+ }
+
+ /**
+ * Clears the value of the 'edgeId' field.
+ * @return GEdge.Builder
+ */
+ // CHECKSTYLE: stop Indentation
+ public org.apache.giraph.io.gora.generated.GEdge.Builder clearEdgeId() {
+ edgeId = null;
+ fieldSetFlags()[0] = false;
+ return this;
+ }
+ // CHECKSTYLE: resume Indentation
+
+ /**
+ * Gets the value of the 'edgeWeight' field.
+ * @return Float
+ */
+ public java.lang.Float getEdgeWeight() {
+ return edgeWeight;
+ }
+
+ /**
+ * Sets the value of the 'edgeWeight' field
+ * @param value float
+ * @return GEdge.Builder
+ */
+ // CHECKSTYLE: stop Indentation
+ public org.apache.giraph.io.gora.generated.GEdge.Builder setEdgeWeight(
+ float value) {
+ validate(fields()[1], value);
+ this.edgeWeight = value;
+ fieldSetFlags()[1] = true;
+ return this;
+ }
+ // CHECKSTYLE: resume Indentation
+
+ /**
+ * Checks whether the 'edgeWeight' field has been set.
+ * @return boolean
+ */
+ public boolean hasEdgeWeight() {
+ return fieldSetFlags()[1];
+ }
+
+ /**
+ * Clears the value of the 'edgeWeight' field.
+ * @return GEdge.Builder
+ */
+ // CHECKSTYLE: stop Indentation
+ public org.apache.giraph.io.gora.generated.GEdge.Builder clearEdgeWeight() {
+ fieldSetFlags()[1] = false;
+ return this;
+ }
+ // CHECKSTYLE: resume Indentation
+
+ /**
+ * Gets the value of the 'vertexInId' field
+ * @return CharSequence
+ */
+ public java.lang.CharSequence getVertexInId() {
+ return vertexInId;
+ }
+
+ /**
+ * Sets the value of the 'vertexInId' field.
+ * @param value CharSequence
+ * @return value
+ */
+ // CHECKSTYLE: stop Indentation
+ public org.apache.giraph.io.gora.generated.GEdge.Builder setVertexInId(
+ java.lang.CharSequence value) {
+ validate(fields()[2], value);
+ this.vertexInId = value;
+ fieldSetFlags()[2] = true;
+ return this;
+ }
+ // CHECKSTYLE: resume Indentation
+
+ /**
+ * Checks whether the 'vertexInId' field has been set.
+ * @return boolean
+ */
+ public boolean hasVertexInId() {
+ return fieldSetFlags()[2];
+ }
+
+ /**
+ * Clears the value of the 'vertexInId' field.
+ * @return GEdge.Builder
+ */
+ // CHECKSTYLE: stop Indentation
+ public org.apache.giraph.io.gora.generated.GEdge.Builder
+ clearVertexInId() {
+ vertexInId = null;
+ fieldSetFlags()[2] = false;
+ return this;
+ }
+ // CHECKSTYLE: resume Indentation
+
+ /**
+ * Gets the value of the 'vertexOutId' field.
+ * @return java.lang.CharSequence
+ */
+ public java.lang.CharSequence getVertexOutId() {
+ return vertexOutId;
+ }
+
+ /**
+ * Sets the value of the 'vertexOutId' field.
+ * @param value CharSequence
+ * @return GEdge.Builder
+ */
+ // CHECKSTYLE: stop Indentation
+ public org.apache.giraph.io.gora.generated.GEdge.Builder setVertexOutId(
+ java.lang.CharSequence value) {
+ validate(fields()[3], value);
+ this.vertexOutId = value;
+ fieldSetFlags()[3] = true;
+ return this;
+ }
+ // CHECKSTYLE: resume Indentation
+
+ /**
+ * Checks whether the 'vertexOutId' field has been set.
+ * @return boolean
+ */
+ public boolean hasVertexOutId() {
+ return fieldSetFlags()[3];
+ }
+
+ /**
+ * Clears the value of the 'vertexOutId' field.
+ * @return GEdge.Builder
+ */
+ // CHECKSTYLE: stop Indentation
+ public org.apache.giraph.io.gora.generated.GEdge.Builder
+ clearVertexOutId() {
+ vertexOutId = null;
+ fieldSetFlags()[3] = false;
+ return this;
+ }
+ // CHECKSTYLE: resume Indentation
+
+ /**
+ * Gets the value of the 'label' field.
+ * @return CharSequence
+ */
+ public java.lang.CharSequence getLabel() {
+ return label;
+ }
+
+ /**
+ * Sets the value of the 'label' field.
+ * @param value CharSequence
+ * @return GEdge.Builder
+ */
+ // CHECKSTYLE: stop Indentation
+ public org.apache.giraph.io.gora.generated.GEdge.Builder setLabel(
+ java.lang.CharSequence value) {
+ validate(fields()[4], value);
+ this.label = value;
+ fieldSetFlags()[4] = true;
+ return this;
+ }
+ // CHECKSTYLE: resume Indentation
+
+ /**
+ * Checks whether the 'label' field has been set.
+ * @return boolean
+ */
+ public boolean hasLabel() {
+ return fieldSetFlags()[4];
+ }
+
+ /**
+ * Clears the value of the 'label' field.
+ * @return GEdge.Builder
+ */
+ // CHECKSTYLE: stop Indentation
+ public org.apache.giraph.io.gora.generated.GEdge.Builder clearLabel() {
+ label = null;
+ fieldSetFlags()[4] = false;
+ return this;
+ }
+ // CHECKSTYLE: resume Indentation
+
+ @Override
+ /**
+ * Builds a GEdge.
+ * @return GEdge
+ */
+ // CHECKSTYLE: stop IllegalCatch
+ public GEdge build() {
+ try {
+ GEdge record = new GEdge();
+ record.edgeId = fieldSetFlags()[0] ? this.edgeId :
+ (java.lang.CharSequence) defaultValue(fields()[0]);
+ record.edgeWeight = fieldSetFlags()[1] ? this.edgeWeight :
+ (java.lang.Float) defaultValue(fields()[1]);
+ record.vertexInId = fieldSetFlags()[2] ? this.vertexInId :
+ (java.lang.CharSequence) defaultValue(fields()[2]);
+ record.vertexOutId = fieldSetFlags()[3] ? this.vertexOutId :
+ (java.lang.CharSequence) defaultValue(fields()[3]);
+ record.label = fieldSetFlags()[4] ? this.label :
+ (java.lang.CharSequence) defaultValue(fields()[4]);
+ return record;
+ } catch (Exception e) {
+ throw new org.apache.avro.AvroRuntimeException(e);
+ }
+ }
+ // CHECKSTYLE: resume IllegalCatch
+ }
+
+ /**
+ * Gets a tombstone
+ * @return GEdge.Tombstone
+ */
+ public GEdge.Tombstone getTombstone() {
+ return TOMBSTONE;
+ }
+
+ /**
+ * Gets a new instance
+ * @return GEdge.
+ */
+ public GEdge newInstance() {
+ return newBuilder().build();
+ }
+
+ /**
+ * Tombstone class.
+ */
+ public static final class Tombstone extends GEdge implements
+ org.apache.gora.persistency.Tombstone {
+
+ /**
+ * Default constructor.
+ */
+ private Tombstone() {
+ }
+
+ /**
+ * Gets the value of the 'edgeId' field.
+ * @return java.lang.CharSequence
+ */
+ public java.lang.CharSequence getEdgeId() {
+ throw new java.lang.UnsupportedOperationException(
+ "Get is not supported on tombstones");
+ }
+
+ /**
+ * Sets the value of the 'edgeId' field.
+ * @param value the value to set.
+ */
+ public void setEdgeId(java.lang.CharSequence value) {
+ throw new java.lang.UnsupportedOperationException(
+ "Set is not supported on tombstones");
+ }
+
+ /**
+ * Checks the dirty status of the 'edgeId' field. A field is dirty if it
+ * represents a change that has not yet been written to the database.
+ * @param value the value to set.
+ * @return boolean
+ */
+ public boolean isEdgeIdDirty(java.lang.CharSequence value) {
+ throw new java.lang.UnsupportedOperationException(
+ "IsDirty is not supported on tombstones");
+ }
+
+ /**
+ * Gets the value of the 'edgeWeight' field.
+ * @return Float
+ */
+ public java.lang.Float getEdgeWeight() {
+ throw new java.lang.UnsupportedOperationException(
+ "Get is not supported on tombstones");
+ }
+
+ /**
+ * Sets the value of the 'edgeWeight' field.
+ * @param value the value to set.
+ */
+ public void setEdgeWeight(java.lang.Float value) {
+ throw new java.lang.UnsupportedOperationException(
+ "Set is not supported on tombstones");
+ }
+
+ /**
+ * Checks the dirty status of the 'edgeWeight' field. A field is dirty if it
+ * represents a change that has not yet been written to the database.
+ * @param value the value to set.
+ * @return boolean
+ */
+ public boolean isEdgeWeightDirty(java.lang.Float value) {
+ throw new java.lang.UnsupportedOperationException(
+ "IsDirty is not supported on tombstones");
+ }
+
+ /**
+ * Gets the value of the 'vertexInId' field.
+ * @return CharSequence
+ */
+ public java.lang.CharSequence getVertexInId() {
+ throw new java.lang.UnsupportedOperationException(
+ "Get is not supported on tombstones");
+ }
+
+ /**
+ * Sets the value of the 'vertexInId' field.
+ * @param value the value to set.
+ */
+ public void setVertexInId(java.lang.CharSequence value) {
+ throw new java.lang.UnsupportedOperationException(
+ "Set is not supported on tombstones");
+ }
+
+ /**
+ * Checks the dirty status of the 'vertexInId' field. A field is dirty if it
+ * represents a change that has not yet been written to the database.
+ * @param value the value to set.
+ * @return boolean
+ */
+ public boolean isVertexInIdDirty(java.lang.CharSequence value) {
+ throw new java.lang.UnsupportedOperationException(
+ "IsDirty is not supported on tombstones");
+ }
+
+ /**
+ * Gets the value of the 'vertexOutId' field.
+ * @return CharSequence
+ */
+ public java.lang.CharSequence getVertexOutId() {
+ throw new java.lang.UnsupportedOperationException(
+ "Get is not supported on tombstones");
+ }
+
+ /**
+ * Sets the value of the 'vertexOutId' field.
+ * @param value the value to set.
+ */
+ public void setVertexOutId(java.lang.CharSequence value) {
+ throw new java.lang.UnsupportedOperationException(
+ "Set is not supported on tombstones");
+ }
+
+ /**
+ * Checks the dirty status of the 'vertexOutId' field. A field is dirty if
+ * it represents a change that has not yet been written to the database.
+ * @param value the value to set.
+ * @return boolean
+ */
+ public boolean isVertexOutIdDirty(java.lang.CharSequence value) {
+ throw new java.lang.UnsupportedOperationException(
+ "IsDirty is not supported on tombstones");
+ }
+
+ /**
+ * Gets the value of the 'label' field.
+ * @return CharSequence
+ */
+ public java.lang.CharSequence getLabel() {
+ throw new java.lang.UnsupportedOperationException(
+ "Get is not supported on tombstones");
+ }
+
+ /**
+ * Sets the value of the 'label' field.
+ * @param value the value to set.
+ */
+ public void setLabel(java.lang.CharSequence value) {
+ throw new java.lang.UnsupportedOperationException(
+ "Set is not supported on tombstones");
+ }
+
+ /**
+ * Checks the dirty status of the 'label' field. A field is dirty if it
+ * represents a change that has not yet been written to the database.
+ * @param value the value to set.
+ * @return boolean
+ */
+ public boolean isLabelDirty(java.lang.CharSequence value) {
+ throw new java.lang.UnsupportedOperationException(
+ "IsDirty is not supported on tombstones");
+ }
}
}
http://git-wip-us.apache.org/repos/asf/giraph/blob/7c61dcf4/giraph-gora/src/main/java/org/apache/giraph/io/gora/generated/GEdgeResult.java
----------------------------------------------------------------------
diff --git a/giraph-gora/src/main/java/org/apache/giraph/io/gora/generated/GEdgeResult.java b/giraph-gora/src/main/java/org/apache/giraph/io/gora/generated/GEdgeResult.java
index 0c3501c..c54e40e 100644
--- a/giraph-gora/src/main/java/org/apache/giraph/io/gora/generated/GEdgeResult.java
+++ b/giraph-gora/src/main/java/org/apache/giraph/io/gora/generated/GEdgeResult.java
@@ -15,35 +15,31 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.giraph.io.gora.generated;
-import org.apache.avro.Schema;
-import org.apache.avro.AvroRuntimeException;
-import org.apache.avro.util.Utf8;
-import org.apache.gora.persistency.StateManager;
-import org.apache.gora.persistency.impl.PersistentBase;
-import org.apache.gora.persistency.impl.StateManagerImpl;
-
/**
- * Example Class for defining a Giraph-Edge.
+ * Example class for defining a Giraph-Edge result.
*/
@SuppressWarnings("all")
-public class GEdgeResult extends PersistentBase {
- /**
- * Schema used for the class.
- */
- public static final Schema OBJ_SCHEMA = Schema.parse("{\"type\":\"record\"," +
- "\"name\":\"GEdge\",\"namespace\":\"org.apache.giraph.gora.generated\"," +
- "\"fields\":[{\"name\":\"edgeId\",\"type\":\"string\"}," +
- "{\"name\":\"edgeWeight\",\"type\":\"float\"}," +
- "{\"name\":\"vertexInId\",\"type\":\"string\"}," +
- "{\"name\":\"vertexOutId\",\"type\":\"string\"}," +
- "{\"name\":\"label\",\"type\":\"string\"}]}");
+public class GEdgeResult extends
+ org.apache.gora.persistency.impl.PersistentBase implements
+ org.apache.avro.specific.SpecificRecord,
+ org.apache.gora.persistency.Persistent {
/**
- * Field enum
+ * Schema used for the class.
*/
+ public static final org.apache.avro.Schema SCHEMAS =
+ new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\"," +
+ "\"name\":\"GEdgeResult\"," +
+ "\"namespace\":\"org.apache.giraph.io.gora.generated\"," +
+ "\"fields\":[{\"name\":\"edgeId\",\"type\":\"string\"}," +
+ "{\"name\":\"edgeWeight\",\"type\":\"float\"}," +
+ "{\"name\":\"vertexInId\",\"type\":\"string\"}," +
+ "{\"name\":\"vertexOutId\",\"type\":\"string\"}," +
+ "{\"name\":\"label\",\"type\":\"string\"}]}");
+
+ /** Enum containing all data bean's fields. */
public static enum Field {
/**
* Edge id.
@@ -71,19 +67,19 @@ public class GEdgeResult extends PersistentBase {
LABEL(4, "label");
/**
- * Field index
+ * Field's index.
*/
private int index;
/**
- * Field name
+ * Field's name.
*/
private String name;
/**
- * Field constructor
- * @param index of attribute
- * @param name of attribute
+ * Field's constructor
+ * @param index field's index.
+ * @param name field's name.
*/
Field(int index, String name) {
this.index = index;
@@ -91,24 +87,24 @@ public class GEdgeResult extends PersistentBase {
}
/**
- * Gets index
- * @return int of attribute.
+ * Gets field's index.
+ * @return int field's index.
*/
public int getIndex() {
return index;
}
/**
- * Gets name
- * @return String of name.
+ * Gets field's name.
+ * @return String field's name.
*/
public String getName() {
return name;
}
/**
- * Gets name
- * @return String of name.
+ * Gets field's attributes to string.
+ * @return String field's attributes to string.
*/
public String toString() {
return name;
@@ -119,77 +115,61 @@ public class GEdgeResult extends PersistentBase {
* Array containing all fields/
*/
private static final String[] ALL_FIELDS = {
- "edgeId", "edgeWeight", "vertexInId", "vertexOutId", "label"
- };
-
- static {
- PersistentBase.registerFields(GEdgeResult.class, ALL_FIELDS);
- }
-
- /**
- * edgeId
- */
- private Utf8 edgeId;
+ "edgeId", "edgeWeight", "vertexInId", "vertexOutId", "label"};
/**
- * edgeWeight
+ * Tombstone.
*/
- private float edgeWeight;
+ private static final Tombstone TOMBSTONE = new Tombstone();
/**
- * vertexInId
+ * edgeId.
*/
- private Utf8 vertexInId;
+ private java.lang.CharSequence edgeId;
/**
- * vertexOutId
+ * edgeWeight.
*/
- private Utf8 vertexOutId;
+ private float edgeWeight;
/**
- * label
+ * vertexInId.
*/
- private Utf8 label;
+ private java.lang.CharSequence vertexInId;
/**
- * Default constructor.
+ * vertexOutId.
*/
- public GEdgeResult() {
- this(new StateManagerImpl());
- }
+ private java.lang.CharSequence vertexOutId;
/**
- * Constructor
- * @param stateManager from which the object will be created.
+ * label.
*/
- public GEdgeResult(StateManager stateManager) {
- super(stateManager);
- }
+ private java.lang.CharSequence label;
/**
- * Creates a new instance
- * @param stateManager from which the object will be created.
- * @return GEdge created
+ * Gets the total field count.
+ * @return int field count
*/
- public GEdgeResult newInstance(StateManager stateManager) {
- return new GEdgeResult(stateManager);
+ public int getFieldsCount() {
+ return GEdgeResult.ALL_FIELDS.length;
}
/**
- * Gets the object schema
- * @return Schema of the object.
+ * Gets the schema
+ * @return Schema
*/
- public Schema getSchema() {
- return OBJ_SCHEMA;
+ public org.apache.avro.Schema getSchema() {
+ return SCHEMAS;
}
/**
* Gets field
- * @param fieldIndex index field.
+ * @param field index field.
* @return Object from an index.
*/
- public Object get(int fieldIndex) {
- switch (fieldIndex) {
+ public java.lang.Object get(int field) {
+ switch (field) {
case 0:
return edgeId;
case 1:
@@ -201,114 +181,729 @@ public class GEdgeResult extends PersistentBase {
case 4:
return label;
default:
- throw new AvroRuntimeException("Bad index");
+ throw new org.apache.avro.AvroRuntimeException("Bad index");
}
}
/**
* Puts a value into a field.
- * @param fieldIndex index of field used.
- * @param fieldValue value of field used.
+ * @param field index of field used.
+ * @param value value of field used.
*/
@SuppressWarnings(value = "unchecked")
- public void put(int fieldIndex, Object fieldValue) {
- if (isFieldEqual(fieldIndex, fieldValue)) {
- return;
- }
- getStateManager().setDirty(this, fieldIndex);
- switch (fieldIndex) {
+ public void put(int field, java.lang.Object value) {
+ switch (field) {
case 0:
- edgeId = (Utf8) fieldValue; break;
+ edgeId = (java.lang.CharSequence) value;
+ break;
case 1:
- edgeWeight = (Float) fieldValue; break;
+ edgeWeight = (java.lang.Float) value;
+ break;
case 2:
- vertexInId = (Utf8) fieldValue; break;
+ vertexInId = (java.lang.CharSequence) value;
+ break;
case 3:
- vertexOutId = (Utf8) fieldValue; break;
+ vertexOutId = (java.lang.CharSequence) value;
+ break;
case 4:
- label = (Utf8) fieldValue; break;
+ label = (java.lang.CharSequence) value;
+ break;
default:
- throw new AvroRuntimeException("Bad index");
+ throw new org.apache.avro.AvroRuntimeException("Bad index");
}
}
/**
- * Gets edgeId
- * @return Utf8 edgeId
+ * Gets the value of the 'edgeId' field.
+ * @return CharSequence.
+ */
+ public java.lang.CharSequence getEdgeId() {
+ return edgeId;
+ }
+
+ /**
+ * Sets the value of the 'edgeId' field.
+ * @param value the value to set.
+ */
+ public void setEdgeId(java.lang.CharSequence value) {
+ this.edgeId = value;
+ setDirty(0);
+ }
+
+ /**
+ * Checks the dirty status of the 'edgeId' field. A field is dirty if it
+ * represents a change that has not yet been written to the database.
+ * @param value the value to set.
+ * @return boolean
+ */
+ public boolean isEdgeIdDirty(java.lang.CharSequence value) {
+ return isDirty(0);
+ }
+
+ /**
+ * Gets the value of the 'edgeWeight' field.
+ * @return Float
+ */
+ public java.lang.Float getEdgeWeight() {
+ return edgeWeight;
+ }
+
+ /**
+ * Sets the value of the 'edgeWeight' field.
+ * @param value the value to set.
+ */
+ public void setEdgeWeight(java.lang.Float value) {
+ this.edgeWeight = value;
+ setDirty(1);
+ }
+
+ /**
+ * Checks the dirty status of the 'edgeWeight' field. A field is dirty if it
+ * represents a change that has not yet been written to the database.
+ * @param value the value to set.
+ * @return boolean
+ */
+ public boolean isEdgeWeightDirty(java.lang.Float value) {
+ return isDirty(1);
+ }
+
+ /**
+ * Gets the value of the 'vertexInId' field.
+ * @return CharSequence
+ */
+ public java.lang.CharSequence getVertexInId() {
+ return vertexInId;
+ }
+
+ /**
+ * Sets the value of the 'vertexInId' field.
+ * @param value the value to set.
*/
- public Utf8 getEdgeId() {
- return (Utf8) get(0);
+ public void setVertexInId(java.lang.CharSequence value) {
+ this.vertexInId = value;
+ setDirty(2);
}
/**
- * Sets edgeId
- * @param value edgeId
+ * Checks the dirty status of the 'vertexInId' field. A field is dirty if it
+ * represents a change that has not yet been written to the database.
+ * @param value the value to set.
+ * @return boolean
*/
- public void setEdgeId(Utf8 value) {
- put(0, value);
+ public boolean isVertexInIdDirty(java.lang.CharSequence value) {
+ return isDirty(2);
}
/**
- * Gets edgeWeight
- * @return float edgeWeight
+ * Gets the value of the 'vertexOutId' field.
+ * @return CharSequence
*/
- public float getEdgeWeight() {
- return (Float) get(1);
+ public java.lang.CharSequence getVertexOutId() {
+ return vertexOutId;
}
/**
- * Sets edgeWeight
- * @param value edgeWeight
+ * Sets the value of the 'vertexOutId' field.
+ * @param value the value to set.
*/
- public void setEdgeWeight(float value) {
- put(1, value);
+ public void setVertexOutId(java.lang.CharSequence value) {
+ this.vertexOutId = value;
+ setDirty(3);
}
/**
- * Gets edgeVertexInId
- * @return Utf8 edgeVertexInId
+ * Checks the dirty status of the 'vertexOutId' field. A field is dirty if it
+ * represents a change that has not yet been written to the database.
+ * @param value the value to set.
+ * @return boolean
*/
- public Utf8 getVertexInId() {
- return (Utf8) get(2);
+ public boolean isVertexOutIdDirty(java.lang.CharSequence value) {
+ return isDirty(3);
}
/**
- * Sets edgeVertexInId
- * @param value edgeVertexInId
+ * Gets the value of the 'label' field.
+ * @return CharSequence
*/
- public void setVertexInId(Utf8 value) {
- put(2, value);
+ public java.lang.CharSequence getLabel() {
+ return label;
}
/**
- * Gets edgeVertexOutId
- * @return Utf8 edgeVertexOutId
+ * Sets the value of the 'label' field.
+ * @param value the value to set.
*/
- public Utf8 getVertexOutId() {
- return (Utf8) get(3);
+ public void setLabel(java.lang.CharSequence value) {
+ this.label = value;
+ setDirty(4);
}
/**
- * Sets edgeVertexOutId
- * @param value edgeVertexOutId
+ * Checks the dirty status of the 'label' field. A field is dirty if it
+ * represents a change that has not yet been written to the database.
+ * @param value the value to set.
+ * @return boolean
*/
- public void setVertexOutId(Utf8 value) {
- put(3, value);
+ public boolean isLabelDirty(java.lang.CharSequence value) {
+ return isDirty(4);
}
/**
- * Gets edgeLabel
- * @return Utf8 edgeLabel
+ * Creates a new GEdgeResult RecordBuilder.
+ * @return GEdge.Builder
*/
- public Utf8 getLabel() {
- return (Utf8) get(4);
+ public static org.apache.giraph.io.gora.generated.GEdgeResult.Builder
+ newBuilder() {
+ return new org.apache.giraph.io.gora.generated.GEdgeResult.Builder();
}
/**
- * Sets edgeLabel
- * @param value edgeLabel
+ * Creates a new GEdgeResult RecordBuilder by copying an existing Builder.
+ * @param other GEdgeResult.Builder
+ * @return GEdge.Builder
*/
- public void setLabel(Utf8 value) {
- put(4, value);
+ public static org.apache.giraph.io.gora.generated.GEdgeResult.Builder
+ newBuilder(org.apache.giraph.io.gora.generated.GEdgeResult.Builder other) {
+ return new org.apache.giraph.io.gora.generated.GEdgeResult.Builder(other);
+ }
+
+ /**
+ * Creates a new GEdgeResult RecordBuilder by copying an existing GEdgeResult
+ * instance
+ * @param other GEdgeResult
+ * @return GEdge.Builder
+ */
+ public static org.apache.giraph.io.gora.generated.GEdgeResult.Builder
+ newBuilder(org.apache.giraph.io.gora.generated.GEdgeResult other) {
+ return new org.apache.giraph.io.gora.generated.GEdgeResult.Builder(other);
+ }
+
+ /**
+ * Makes a deep copy from a bytebuffer.
+ * @param input ByteBuffer
+ * @return ByteBuffer
+ */
+ private static java.nio.ByteBuffer deepCopyToReadOnlyBuffer(
+ java.nio.ByteBuffer input) {
+ java.nio.ByteBuffer copy = java.nio.ByteBuffer.allocate(input.capacity());
+ int position = input.position();
+ input.reset();
+ int mark = input.position();
+ int limit = input.limit();
+ input.rewind();
+ input.limit(input.capacity());
+ copy.put(input);
+ input.rewind();
+ copy.rewind();
+ input.position(mark);
+ input.mark();
+ copy.position(mark);
+ copy.mark();
+ input.position(position);
+ copy.position(position);
+ input.limit(limit);
+ copy.limit(limit);
+ return copy.asReadOnlyBuffer();
+ }
+
+ /**
+ * RecordBuilder for GEdgeResult instances.
+ */
+ public static class Builder extends
+ org.apache.avro.specific.SpecificRecordBuilderBase<GEdgeResult> implements
+ org.apache.avro.data.RecordBuilder<GEdgeResult> {
+
+ /**
+ * edgeId.
+ */
+ private java.lang.CharSequence edgeId;
+
+ /**
+ * edgeWeight.
+ */
+ private float edgeWeight;
+
+ /**
+ * vertexInId
+ */
+ private java.lang.CharSequence vertexInId;
+
+ /**
+ * vertexOutId.
+ */
+ private java.lang.CharSequence vertexOutId;
+
+ /**
+ * label.
+ */
+ private java.lang.CharSequence label;
+
+ /** Creates a new Builder */
+ private Builder() {
+ super(org.apache.giraph.io.gora.generated.GEdgeResult.SCHEMAS);
+ }
+
+ /**
+ * Creates a Builder by copying an existing Builder.
+ * @param other GEdgeResult.Builder
+ */
+ private Builder(
+ org.apache.giraph.io.gora.generated.GEdgeResult.Builder other) {
+ super(other);
+ }
+
+ /**
+ * Creates a Builder by copying an existing GEdgeResult instance.
+ * @param other GEdgeResult
+ */
+ // CHECKSTYLE: stop Indentation
+ private Builder(org.apache.giraph.io.gora.generated.GEdgeResult other) {
+ super(org.apache.giraph.io.gora.generated.GEdgeResult.SCHEMAS);
+ if (isValidValue(fields()[0], other.edgeId)) {
+ this.edgeId = (java.lang.CharSequence) data().deepCopy(
+ fields()[0].schema(), other.edgeId);
+ fieldSetFlags()[0] = true;
+ }
+ if (isValidValue(fields()[1], other.edgeWeight)) {
+ this.edgeWeight = (java.lang.Float) data().deepCopy(
+ fields()[1].schema(), other.edgeWeight);
+ fieldSetFlags()[1] = true;
+ }
+ if (isValidValue(fields()[2], other.vertexInId)) {
+ this.vertexInId = (java.lang.CharSequence) data().deepCopy(
+ fields()[2].schema(), other.vertexInId);
+ fieldSetFlags()[2] = true;
+ }
+ if (isValidValue(fields()[3], other.vertexOutId)) {
+ this.vertexOutId = (java.lang.CharSequence) data().deepCopy(
+ fields()[3].schema(), other.vertexOutId);
+ fieldSetFlags()[3] = true;
+ }
+ if (isValidValue(fields()[4], other.label)) {
+ this.label = (java.lang.CharSequence) data().deepCopy(
+ fields()[4].schema(), other.label);
+ fieldSetFlags()[4] = true;
+ }
+ }
+ // CHECKSTYLE: resume Indentation
+
+ /**
+ * Gets the value of the 'edgeId' field.
+ * @return CharSequence
+ */
+ public java.lang.CharSequence getEdgeId() {
+ return edgeId;
+ }
+
+ /**
+ * Sets the value of the 'edgeId' field.
+ * @param value CharSequence
+ * @return GEdgeResult.Builder
+ */
+ // CHECKSTYLE: stop Indentation
+ public org.apache.giraph.io.gora.generated.GEdgeResult.Builder setEdgeId(
+ java.lang.CharSequence value) {
+ validate(fields()[0], value);
+ this.edgeId = value;
+ fieldSetFlags()[0] = true;
+ return this;
+ }
+ // CHECKSTYLE: resume Indentation
+
+ /**
+ * Checks whether the 'edgeId' field has been set.
+ * @return boolean
+ */
+ public boolean hasEdgeId() {
+ return fieldSetFlags()[0];
+ }
+
+ /**
+ * Clears the value of the 'edgeId' field.
+ * @return GEdgeResult.Builder
+ */
+ // CHECKSTYLE: stop Indentation
+ public org.apache.giraph.io.gora.generated.GEdgeResult.Builder
+ clearEdgeId() {
+ edgeId = null;
+ fieldSetFlags()[0] = false;
+ return this;
+ }
+ // CHECKSTYLE: resume Indentation
+
+ /**
+ * Gets the value of the 'edgeWeight' field.
+ * @return Float
+ */
+ public java.lang.Float getEdgeWeight() {
+ return edgeWeight;
+ }
+
+ /**
+ * Sets the value of the 'edgeWeight' field.
+ * @param value float
+ * @return GEdgeResult.Builder
+ */
+ // CHECKSTYLE: stop Indentation
+ public org.apache.giraph.io.gora.generated.GEdgeResult.Builder
+ setEdgeWeight(float value) {
+ validate(fields()[1], value);
+ this.edgeWeight = value;
+ fieldSetFlags()[1] = true;
+ return this;
+ }
+ // CHECKSTYLE: resume Indentation
+
+ /**
+ * Checks whether the 'edgeWeight' field has been set.
+ * @return boolean
+ */
+ public boolean hasEdgeWeight() {
+ return fieldSetFlags()[1];
+ }
+
+ /**
+ * Clears the value of the 'edgeWeight' field.
+ * @return GEdgeResult.Builder
+ */
+ // CHECKSTYLE: stop Indentation
+ public org.apache.giraph.io.gora.generated.GEdgeResult.Builder
+ clearEdgeWeight() {
+ fieldSetFlags()[1] = false;
+ return this;
+ }
+ // CHECKSTYLE: resume Indentation
+
+ /**
+ * Gets the value of the 'vertexInId' field.
+ * @return CharSequence
+ */
+ public java.lang.CharSequence getVertexInId() {
+ return vertexInId;
+ }
+
+ /**
+ * Sets the value of the 'vertexInId' field.
+ * @param value CharSequence
+ * @return GEdgeResult.Builder
+ */
+ // CHECKSTYLE: stop Indentation
+ public org.apache.giraph.io.gora.generated.GEdgeResult.Builder
+ setVertexInId(java.lang.CharSequence value) {
+ validate(fields()[2], value);
+ this.vertexInId = value;
+ fieldSetFlags()[2] = true;
+ return this;
+ }
+ // CHECKSTYLE: resume Indentation
+
+ /**
+ * Checks whether the 'vertexInId' field has been set.
+ * @return boolean.
+ */
+ public boolean hasVertexInId() {
+ return fieldSetFlags()[2];
+ }
+
+ /**
+ * Clears the value of the 'vertexInId' field.
+ * @return GEdgeResult.Builder
+ */
+ // CHECKSTYLE: stop Indentation
+ public org.apache.giraph.io.gora.generated.GEdgeResult.Builder
+ clearVertexInId() {
+ vertexInId = null;
+ fieldSetFlags()[2] = false;
+ return this;
+ }
+ // CHECKSTYLE: resume Indentation
+
+ /**
+ * Gets the value of the 'vertexOutId' field.
+ * @return CharSequence
+ */
+ public java.lang.CharSequence getVertexOutId() {
+ return vertexOutId;
+ }
+
+ /**
+ * Sets the value of the 'vertexOutId' field.
+ * @param value CharSequence
+ * @return GEdgeResult.Builder
+ */
+ // CHECKSTYLE: stop Indentation
+ public org.apache.giraph.io.gora.generated.GEdgeResult.Builder
+ setVertexOutId(java.lang.CharSequence value) {
+ validate(fields()[3], value);
+ this.vertexOutId = value;
+ fieldSetFlags()[3] = true;
+ return this;
+ }
+ // CHECKSTYLE: resume Indentation
+
+ /**
+ * Checks whether the 'vertexOutId' field has been set.
+ * @return boolean
+ */
+ public boolean hasVertexOutId() {
+ return fieldSetFlags()[3];
+ }
+
+ /**
+ * Clears the value of the 'vertexOutId' field.
+ * @return GEdgeResult.Builder
+ */
+ // CHECKSTYLE: stop Indentation
+ public org.apache.giraph.io.gora.generated.GEdgeResult.Builder
+ clearVertexOutId() {
+ vertexOutId = null;
+ fieldSetFlags()[3] = false;
+ return this;
+ }
+ // CHECKSTYLE: resume Indentation
+
+ /**
+ * Gets the value of the 'label' field.
+ * @return CharSequence
+ */
+ public java.lang.CharSequence getLabel() {
+ return label;
+ }
+
+ /**
+ * Sets the value of the 'label' field.
+ * @param value CharSequence
+ * @return GEdgeResult.Builder
+ */
+ // CHECKSTYLE: stop Indentation
+ public org.apache.giraph.io.gora.generated.GEdgeResult.Builder setLabel(
+ java.lang.CharSequence value) {
+ validate(fields()[4], value);
+ this.label = value;
+ fieldSetFlags()[4] = true;
+ return this;
+ }
+ // CHECKSTYLE: resume Indentation
+
+ /**
+ * Checks whether the 'label' field has been set.
+ * @return boolean
+ */
+ public boolean hasLabel() {
+ return fieldSetFlags()[4];
+ }
+
+ /**
+ * Clears the value of the 'label' field.
+ * @return GEdgeResult.Builder
+ */
+ // CHECKSTYLE: stop Indentation
+ public org.apache.giraph.io.gora.generated.GEdgeResult.Builder
+ clearLabel() {
+ label = null;
+ fieldSetFlags()[4] = false;
+ return this;
+ }
+ // CHECKSTYLE: resume Indentation
+
+ @Override
+ /**
+ * Builds a GEdgeResult.
+ * @return GEdgeResult
+ */
+ // CHECKSTYLE: stop IllegalCatch
+ public GEdgeResult build() {
+ try {
+ GEdgeResult record = new GEdgeResult();
+ record.edgeId = fieldSetFlags()[0] ? this.edgeId :
+ (java.lang.CharSequence) defaultValue(fields()[0]);
+ record.edgeWeight = fieldSetFlags()[1] ? this.edgeWeight :
+ (java.lang.Float) defaultValue(fields()[1]);
+ record.vertexInId = fieldSetFlags()[2] ? this.vertexInId :
+ (java.lang.CharSequence) defaultValue(fields()[2]);
+ record.vertexOutId = fieldSetFlags()[3] ? this.vertexOutId :
+ (java.lang.CharSequence) defaultValue(fields()[3]);
+ record.label = fieldSetFlags()[4] ? this.label :
+ (java.lang.CharSequence) defaultValue(fields()[4]);
+ return record;
+ } catch (Exception e) {
+ throw new org.apache.avro.AvroRuntimeException(e);
+ }
+ }
+ // CHECKSTYLE: resume IllegalCatch
+ }
+
+ /**
+ * Gets tombstone
+ * @return GEdgeResult.Tombstone
+ */
+ public GEdgeResult.Tombstone getTombstone() {
+ return TOMBSTONE;
+ }
+
+ /**
+ * Gets a new instance
+ * @return GEdgeResult.
+ */
+ public GEdgeResult newInstance() {
+ return newBuilder().build();
+ }
+
+ /**
+ * Tombstone class.
+ */
+ public static final class Tombstone extends GEdgeResult implements
+ org.apache.gora.persistency.Tombstone {
+
+ /**
+ * Default constructor.
+ */
+ private Tombstone() {
+ }
+
+ /**
+ * Gets the value of the 'edgeId' field.
+ * @return CharSequence
+ */
+ public java.lang.CharSequence getEdgeId() {
+ throw new java.lang.UnsupportedOperationException(
+ "Get is not supported on tombstones");
+ }
+
+ /**
+ * Sets the value of the 'edgeId' field.
+ * @param value the value to set.
+ */
+ public void setEdgeId(java.lang.CharSequence value) {
+ throw new java.lang.UnsupportedOperationException(
+ "Set is not supported on tombstones");
+ }
+
+ /**
+ * Checks the dirty status of the 'edgeId' field. A field is dirty if it
+ * represents a change that has not yet been written to the database.
+ * @param value the value to set.
+ * @return boolean
+ */
+ public boolean isEdgeIdDirty(java.lang.CharSequence value) {
+ throw new java.lang.UnsupportedOperationException(
+ "IsDirty is not supported on tombstones");
+ }
+
+ /**
+ * Gets the value of the 'edgeWeight' field.
+ * @return Float
+ */
+ public java.lang.Float getEdgeWeight() {
+ throw new java.lang.UnsupportedOperationException(
+ "Get is not supported on tombstones");
+ }
+
+ /**
+ * Sets the value of the 'edgeWeight' field.
+ * @param value the value to set.
+ */
+ public void setEdgeWeight(java.lang.Float value) {
+ throw new java.lang.UnsupportedOperationException(
+ "Set is not supported on tombstones");
+ }
+
+ /**
+ * Checks the dirty status of the 'edgeWeight' field. A field is dirty if it
+ * represents a change that has not yet been written to the database.
+ * @param value the value to set.
+ * @return boolean
+ */
+ public boolean isEdgeWeightDirty(java.lang.Float value) {
+ throw new java.lang.UnsupportedOperationException(
+ "IsDirty is not supported on tombstones");
+ }
+
+ /**
+ * Gets the value of the 'vertexInId' field.
+ * @return CharSequence
+ */
+ public java.lang.CharSequence getVertexInId() {
+ throw new java.lang.UnsupportedOperationException(
+ "Get is not supported on tombstones");
+ }
+
+ /**
+ * Sets the value of the 'vertexInId' field.
+ * @param value the value to set.
+ */
+ public void setVertexInId(java.lang.CharSequence value) {
+ throw new java.lang.UnsupportedOperationException(
+ "Set is not supported on tombstones");
+ }
+
+ /**
+ * Checks the dirty status of the 'vertexInId' field. A field is dirty if it
+ * represents a change that has not yet been written to the database.
+ * @param value the value to set.
+ * @return boolean
+ */
+ public boolean isVertexInIdDirty(java.lang.CharSequence value) {
+ throw new java.lang.UnsupportedOperationException(
+ "IsDirty is not supported on tombstones");
+ }
+
+ /**
+ * Gets the value of the 'vertexOutId' field.
+ * @return CharSequence
+ */
+ public java.lang.CharSequence getVertexOutId() {
+ throw new java.lang.UnsupportedOperationException(
+ "Get is not supported on tombstones");
+ }
+
+ /**
+ * Sets the value of the 'vertexOutId' field.
+ * @param value the value to set.
+ */
+ public void setVertexOutId(java.lang.CharSequence value) {
+ throw new java.lang.UnsupportedOperationException(
+ "Set is not supported on tombstones");
+ }
+
+ /**
+ * Checks the dirty status of the 'vertexOutId' field. A field is dirty if
+ * it represents a change that has not yet been written to the database.
+ * @param value the value to set.
+ * @return boolean
+ */
+ public boolean isVertexOutIdDirty(java.lang.CharSequence value) {
+ throw new java.lang.UnsupportedOperationException(
+ "IsDirty is not supported on tombstones");
+ }
+
+ /**
+ * Gets the value of the 'label' field.
+ * @return CharSequence
+ */
+ public java.lang.CharSequence getLabel() {
+ throw new java.lang.UnsupportedOperationException(
+ "Get is not supported on tombstones");
+ }
+
+ /**
+ * Sets the value of the 'label' field.
+ * @param value the value to set.
+ */
+ public void setLabel(java.lang.CharSequence value) {
+ throw new java.lang.UnsupportedOperationException(
+ "Set is not supported on tombstones");
+ }
+
+ /**
+ * Checks the dirty status of the 'label' field. A field is dirty if it
+ * represents a change that has not yet been written to the database.
+ * @param value the value to set.
+ * @return boolean
+ */
+ public boolean isLabelDirty(java.lang.CharSequence value) {
+ throw new java.lang.UnsupportedOperationException(
+ "IsDirty is not supported on tombstones");
+ }
}
}