gora-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lewi...@apache.org
Subject [01/17] gora git commit: GORA-409 JCache datastore initial project structure commit
Date Fri, 05 Aug 2016 10:41:24 GMT
Repository: gora
Updated Branches:
  refs/heads/master fb4ad6a47 -> f4debf25a


GORA-409 JCache datastore initial project structure commit


Project: http://git-wip-us.apache.org/repos/asf/gora/repo
Commit: http://git-wip-us.apache.org/repos/asf/gora/commit/2b8b0610
Tree: http://git-wip-us.apache.org/repos/asf/gora/tree/2b8b0610
Diff: http://git-wip-us.apache.org/repos/asf/gora/diff/2b8b0610

Branch: refs/heads/master
Commit: 2b8b0610767f4cc51f0a393a0627b721069f052c
Parents: 7325085
Author: Kevin Ratnasekera <djkevincr@yahoo.com>
Authored: Sun May 29 19:17:57 2016 +0530
Committer: Kevin Ratnasekera <djkevincr@yahoo.com>
Committed: Sun May 29 19:17:57 2016 +0530

----------------------------------------------------------------------
 gora-jcache/pom.xml                             | 154 +++++++++++++++++++
 .../apache/gora/jcache/query/JCacheQuery.java   |  34 ++++
 .../apache/gora/jcache/query/JCacheResult.java  |  53 +++++++
 .../apache/gora/jcache/store/JCacheStore.java   | 105 +++++++++++++
 gora-jcache/src/test/resources/gora.properties  |  16 ++
 pom.xml                                         |  18 +++
 6 files changed, 380 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/gora/blob/2b8b0610/gora-jcache/pom.xml
----------------------------------------------------------------------
diff --git a/gora-jcache/pom.xml b/gora-jcache/pom.xml
new file mode 100644
index 0000000..a6fdf39
--- /dev/null
+++ b/gora-jcache/pom.xml
@@ -0,0 +1,154 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  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/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+
+  <parent>
+    <groupId>org.apache.gora</groupId>
+    <artifactId>gora</artifactId>
+    <version>0.7-SNAPSHOT</version>
+    <relativePath>../</relativePath>
+  </parent>
+  <artifactId>gora-jcache</artifactId>
+  <packaging>bundle</packaging>
+
+  <name>Apache Gora :: JCache</name>
+  <url>http://gora.apache.org</url>
+  <description>The Apache Gora open source framework provides an in-memory data model
and
+    persistence for big data. Gora supports persisting to column stores, key value stores,
+    document stores and RDBMSs, and analyzing the data with extensive Apache Hadoop MapReduce
+    support.</description>
+  <inceptionYear>2010</inceptionYear>
+  <organization>
+    <name>The Apache Software Foundation</name>
+    <url>http://www.apache.org/</url>
+  </organization>
+  <issueManagement>
+    <system>JIRA</system>
+    <url>https://issues.apache.org/jira/browse/GORA</url>
+  </issueManagement>
+  <ciManagement>
+    <system>Jenkins</system>
+    <url>https://builds.apache.org/job/Gora-trunk/</url>
+  </ciManagement>
+
+  <properties>
+    <osgi.import>*</osgi.import>
+    <osgi.export>org.apache.gora.jcache*;version="${project.version}";-noimport:=true</osgi.export>
+  </properties>
+
+  <build>
+    <directory>target</directory>
+    <outputDirectory>target/classes</outputDirectory>
+    <finalName>${project.artifactId}-${project.version}</finalName>
+    <testOutputDirectory>target/test-classes</testOutputDirectory>
+    <testSourceDirectory>src/test/java</testSourceDirectory>
+    <sourceDirectory>src/main/java</sourceDirectory>
+    <testResources>
+      <testResource>
+        <directory>${project.basedir}/src/test/resources</directory>
+        <includes>
+          <include>**/*</include>
+        </includes>
+        <!--targetPath>${project.basedir}/target/classes/</targetPath -->
+      </testResource>
+    </testResources>
+    <plugins>
+      <plugin>
+        <groupId>org.codehaus.mojo</groupId>
+        <artifactId>build-helper-maven-plugin</artifactId>
+        <version>${build-helper-maven-plugin.version}</version>
+        <executions>
+          <execution>
+            <phase>generate-sources</phase>
+            <goals>
+              <goal>add-source</goal>
+            </goals>
+            <configuration>
+              <sources>
+                <source>src/examples/java</source>
+              </sources>
+            </configuration>
+          </execution>
+        </executions>
+      </plugin>
+    </plugins>
+  </build>
+
+  <dependencies>
+    <!-- Gora Internal Dependencies -->
+    <dependency>
+      <groupId>org.apache.gora</groupId>
+      <artifactId>gora-core</artifactId>
+    </dependency>
+
+    <dependency>
+      <groupId>org.apache.gora</groupId>
+      <artifactId>gora-core</artifactId>
+      <type>test-jar</type>
+      <scope>test</scope>
+    </dependency>
+
+    <dependency>
+      <groupId>org.apache.avro</groupId>
+      <artifactId>avro</artifactId>
+    </dependency>
+
+    <!-- JCache Dependencies -->
+    <dependency>
+      <groupId>com.hazelcast</groupId>
+      <artifactId>hazelcast-all</artifactId>
+    </dependency>
+
+    <dependency>
+      <groupId>javax.cache</groupId>
+      <artifactId>cache-api</artifactId>
+    </dependency>
+
+    <!-- Logging Dependencies -->
+    <dependency>
+      <groupId>org.slf4j</groupId>
+      <artifactId>slf4j-log4j12</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>log4j</groupId>
+      <artifactId>log4j</artifactId>
+      <exclusions>
+        <exclusion>
+          <groupId>javax.jms</groupId>
+          <artifactId>jms</artifactId>
+        </exclusion>
+      </exclusions>
+    </dependency>
+
+    <!-- Testing Dependencies -->
+    <dependency>
+      <groupId>junit</groupId>
+      <artifactId>junit</artifactId>
+    </dependency>
+
+    <dependency>
+      <groupId>org.apache.hadoop</groupId>
+      <artifactId>hadoop-minicluster</artifactId>
+    </dependency>
+
+  </dependencies>
+
+</project>

http://git-wip-us.apache.org/repos/asf/gora/blob/2b8b0610/gora-jcache/src/main/java/org/apache/gora/jcache/query/JCacheQuery.java
----------------------------------------------------------------------
diff --git a/gora-jcache/src/main/java/org/apache/gora/jcache/query/JCacheQuery.java b/gora-jcache/src/main/java/org/apache/gora/jcache/query/JCacheQuery.java
new file mode 100644
index 0000000..0316fb7
--- /dev/null
+++ b/gora-jcache/src/main/java/org/apache/gora/jcache/query/JCacheQuery.java
@@ -0,0 +1,34 @@
+/**
+ * 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.
+ */
+
+package org.apache.gora.jcache.query;
+
+import org.apache.gora.persistency.impl.PersistentBase;
+import org.apache.gora.query.impl.QueryBase;
+import org.apache.gora.store.DataStore;
+
+public class JCacheQuery<K,T extends PersistentBase> extends QueryBase<K,T> {
+  
+  public JCacheQuery() {
+    super(null);
+  }
+
+  public JCacheQuery(DataStore<K,T> dataStore) {
+    super(dataStore);
+  }
+  
+}

http://git-wip-us.apache.org/repos/asf/gora/blob/2b8b0610/gora-jcache/src/main/java/org/apache/gora/jcache/query/JCacheResult.java
----------------------------------------------------------------------
diff --git a/gora-jcache/src/main/java/org/apache/gora/jcache/query/JCacheResult.java b/gora-jcache/src/main/java/org/apache/gora/jcache/query/JCacheResult.java
new file mode 100644
index 0000000..76ef7ba
--- /dev/null
+++ b/gora-jcache/src/main/java/org/apache/gora/jcache/query/JCacheResult.java
@@ -0,0 +1,53 @@
+/**
+ * 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.
+ */
+
+package org.apache.gora.jcache.query;
+
+import java.io.IOException;
+
+import org.apache.gora.jcache.store.JCacheStore;
+import org.apache.gora.persistency.impl.PersistentBase;
+import org.apache.gora.query.Query;
+import org.apache.gora.query.impl.ResultBase;
+import org.apache.gora.store.DataStore;
+
+public class JCacheResult<K,T extends PersistentBase> extends ResultBase<K,T>
{
+  
+  public JCacheStore<K,T> getDataStore() {
+    return (JCacheStore<K,T>) super.getDataStore();
+  }
+
+  public JCacheResult(DataStore<K,T> dataStore, Query<K,T> query) {
+    super(dataStore, query);
+  }
+  
+  @Override
+  public float getProgress() throws IOException {
+    return 0;
+  }
+  
+  @Override
+  public void close() throws IOException {
+    
+  }
+  
+  @Override
+  protected boolean nextInner() throws IOException {
+    return true;
+  }
+  
+}

http://git-wip-us.apache.org/repos/asf/gora/blob/2b8b0610/gora-jcache/src/main/java/org/apache/gora/jcache/store/JCacheStore.java
----------------------------------------------------------------------
diff --git a/gora-jcache/src/main/java/org/apache/gora/jcache/store/JCacheStore.java b/gora-jcache/src/main/java/org/apache/gora/jcache/store/JCacheStore.java
new file mode 100644
index 0000000..1c52fdd
--- /dev/null
+++ b/gora-jcache/src/main/java/org/apache/gora/jcache/store/JCacheStore.java
@@ -0,0 +1,105 @@
+/**
+ * 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.
+ */
+
+package org.apache.gora.jcache.store;
+
+import java.io.IOException;
+import java.util.List;
+import java.util.Properties;
+
+import org.apache.gora.jcache.query.JCacheQuery;
+import org.apache.gora.persistency.impl.PersistentBase;
+import org.apache.gora.query.PartitionQuery;
+import org.apache.gora.query.Query;
+import org.apache.gora.query.Result;
+import org.apache.gora.store.impl.DataStoreBase;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class JCacheStore<K,T extends PersistentBase> extends DataStoreBase<K,T>
{
+
+
+  public static final Logger LOG = LoggerFactory.getLogger(JCacheStore.class);
+
+
+  @Override
+  public void initialize(Class<K> keyClass, Class<T> persistentClass, Properties
properties) {
+    super.initialize(keyClass, persistentClass, properties);
+  }
+
+  @Override
+  public String getSchemaName() {
+    return null;
+  }
+
+  @Override
+  public void createSchema() {
+  }
+
+  @Override
+  public void deleteSchema() {
+  }
+
+  @Override
+  public boolean schemaExists() {
+    return false;
+  }
+
+
+  @Override
+  public T get(K key, String[] fields) {
+    return null;
+  }
+
+  @Override
+  public void put(K key, T val) {
+  }
+
+  @Override
+  public boolean delete(K key) {
+    return false;
+  }
+
+  @Override
+  public long deleteByQuery(Query<K,T> query) {
+    return 0;
+  }
+
+  @Override
+  public Result<K,T> execute(Query<K,T> query) {
+    return null;
+  }
+
+  @Override
+  public Query<K,T> newQuery() {
+    return new JCacheQuery<>(this);
+  }
+
+  @Override
+  public List<PartitionQuery<K,T>> getPartitions(Query<K,T> query) throws
IOException {
+    return null;
+  }
+
+  @Override
+  public void flush() {
+  }
+
+  @Override
+  public void close() {
+  }
+
+}

http://git-wip-us.apache.org/repos/asf/gora/blob/2b8b0610/gora-jcache/src/test/resources/gora.properties
----------------------------------------------------------------------
diff --git a/gora-jcache/src/test/resources/gora.properties b/gora-jcache/src/test/resources/gora.properties
new file mode 100644
index 0000000..83f920a
--- /dev/null
+++ b/gora-jcache/src/test/resources/gora.properties
@@ -0,0 +1,16 @@
+# 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.
+
+gora.datastore.default=org.apache.gora.jcache.store.JCacheStore

http://git-wip-us.apache.org/repos/asf/gora/blob/2b8b0610/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index 565f3e6..dd5fc52 100644
--- a/pom.xml
+++ b/pom.xml
@@ -702,6 +702,7 @@
     <module>gora-goraci</module>
     <module>gora-hbase</module>
     <module>gora-infinispan</module>
+    <module>gora-jcache</module>
     <!-- module>gora-lucene</module -->
     <module>gora-dynamodb</module>
     <!--module>gora-sql</module -->
@@ -759,6 +760,10 @@
     <log4j.version>1.2.16</log4j.version>
     <slf4j.version>1.6.6</slf4j.version>
 
+    <!-- JCache Dependencies -->
+    <jsr107.api.version>1.0.0</jsr107.api.version>
+    <hazelcast.version>3.6.3</hazelcast.version>
+
     <!-- Testing Dependencies -->
     <junit.version>4.10</junit.version>
 
@@ -1456,6 +1461,19 @@
         </exclusions>
       </dependency>
 
+      <!-- JCache Dependencies -->
+      <dependency>
+        <groupId>com.hazelcast</groupId>
+        <artifactId>hazelcast-all</artifactId>
+        <version>${hazelcast.version}</version>
+      </dependency>
+
+      <dependency>
+        <groupId>javax.cache</groupId>
+        <artifactId>cache-api</artifactId>
+        <version>${jsr107.api.version}</version>
+      </dependency>
+
       <!-- Testing Dependencies -->
       <dependency>
         <groupId>org.apache.hadoop</groupId>


Mime
View raw message