partitionQuery = new PartitionQueryImpl<>(
- query);
- partitionQuery.setConf(this.getConf());
- partitions.add(partitionQuery);
- return partitions;
- }
-
- @Override
- public void flush() {
- LOG.info("Geode datastore flushed successfully.");
- }
-
- @Override
- public void close() {
-
- }
-}
diff --git a/gora-geode/src/main/java/org/apache/gora/geode/store/GeodeStoreParameters.java b/gora-geode/src/main/java/org/apache/gora/geode/store/GeodeStoreParameters.java
deleted file mode 100644
index 138bc299..00000000
--- a/gora-geode/src/main/java/org/apache/gora/geode/store/GeodeStoreParameters.java
+++ /dev/null
@@ -1,60 +0,0 @@
-/*
- * 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.geode.store;
-
-/**
- * Configuration Properties.
- */
-public class GeodeStoreParameters {
-
- /**
- * Property pointing to geode server contact points.
- * string (multiple values with comma separated)
- */
- public static final String GEODE_SERVER_HOST = "gora.geode.server.hostname";
-
- /**
- * Property pointing to the port to use to connect to the geode hosts.
- * integer
- */
- public static final String GEODE_SERVER_PORT = "gora.geode.server.port";
-
- /**
- * Property pointing to the gora schemaName.
- * integer
- */
- public static final String PREFERRED_SCHEMA_NAME = "gora.geode.preferred.schemaName";
-
- /**
- * Property pointing to the geode region shortcut.
- * integer
- */
- public static final String GEODE_REGION_SHORTCUT = "gora.geode.region.shortcut";
-
- /**
- * Property pointing to the username to connect to the server.
- * string
- */
- public static final String GEODE_USERNAME = "gora.geode.username";
-
- /**
- * Property pointing to the password to connect to the server.
- * string
- */
- public static final String GEODE_PASSWORD = "gora.geode.password";
-
-}
diff --git a/gora-geode/src/test/conf/gora.properties b/gora-geode/src/test/conf/gora.properties
deleted file mode 100644
index 3e8e111a..00000000
--- a/gora-geode/src/test/conf/gora.properties
+++ /dev/null
@@ -1,18 +0,0 @@
-# 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.geode.store.GeodeStore
-gora.datastore.geode.server=localhost
-gora.datastore.geode.port="gora.geode.server.port"
\ No newline at end of file
diff --git a/gora-geode/src/test/java/org/apache/gora/geode/GeodeStartupLogWaitStrategy.java b/gora-geode/src/test/java/org/apache/gora/geode/GeodeStartupLogWaitStrategy.java
deleted file mode 100644
index 67110ba1..00000000
--- a/gora-geode/src/test/java/org/apache/gora/geode/GeodeStartupLogWaitStrategy.java
+++ /dev/null
@@ -1,36 +0,0 @@
-/*
- * 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.geode;
-
-import org.testcontainers.containers.wait.strategy.LogMessageWaitStrategy;
-
-
-/**
- * Log based Geode server startup wait strategy to sync server
- * startup to test suit startup.
- */
-public class GeodeStartupLogWaitStrategy extends LogMessageWaitStrategy {
-
- private static final String regEx = ".*Apache Geode has started. Time to relax..*";
-
- public GeodeStartupLogWaitStrategy() {
- withRegEx(regEx);
- }
-
-}
\ No newline at end of file
diff --git a/gora-geode/src/test/java/org/apache/gora/geode/GoraGeodeTestDriver.java b/gora-geode/src/test/java/org/apache/gora/geode/GoraGeodeTestDriver.java
deleted file mode 100644
index c11e5c51..00000000
--- a/gora-geode/src/test/java/org/apache/gora/geode/GoraGeodeTestDriver.java
+++ /dev/null
@@ -1,88 +0,0 @@
-/**
- * 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.geode;
-
-import org.apache.gora.GoraTestDriver;
-
-import org.apache.gora.geode.store.GeodeStore;
-import org.apache.gora.geode.store.GeodeStoreParameters;
-import org.apache.gora.persistency.Persistent;
-import org.apache.gora.store.DataStore;
-import org.apache.gora.store.DataStoreFactory;
-import org.apache.gora.util.GoraException;
-import org.testcontainers.containers.GenericContainer;
-
-import java.util.Properties;
-
-import static org.apache.gora.geode.store.GeodeStoreParameters.GEODE_SERVER_PORT;
-
-/**
- * Helper class for third party tests using gora-geode backend.
- * @see GoraTestDriver for test specifics.
- * This driver is the base for all test cases that require an Geode server.
- * In this case we use docker container. A docker container is run before tests
- * and it is stopped after tests.
- *
- */
-public class GoraGeodeTestDriver extends GoraTestDriver {
-
- private final GenericContainer GeodeContainer;
- private Properties properties = DataStoreFactory.createProps();
-
- /**
- * Default constructor
- */
- public GoraGeodeTestDriver(GenericContainer GeodeContainer) {
- super(GeodeStore.class);
- this.GeodeContainer = GeodeContainer;
- }
-
- @Override
- public void setUpClass() {
- log.info("Setting up Geode Test Driver");
- properties.put(GeodeStoreParameters.GEODE_SERVER_HOST, GeodeContainer.getContainerIpAddress());
- properties.put(GEODE_SERVER_PORT, GeodeContainer.getMappedPort(10334).toString());
- }
-
- @Override
- public void tearDownClass() {
- log.info("Teardown Geode test driver");
- }
-
- /**
- * Instantiate a new {@link DataStore}. Uses 'null' schema.
- *
- * @param keyClass The key class.
- * @param persistentClass The value class.
- * @return A new store instance.
- * @throws GoraException
- */
- @Override
- public DataStore createDataStore(Class keyClass, Class persistentClass)
- throws GoraException {
-
- final DataStore dataStore = DataStoreFactory
- .createDataStore((Class>) dataStoreClass, keyClass, persistentClass, conf,
- properties);
- dataStores.add(dataStore);
- log.info("Datastore for {} was added.", persistentClass);
- return dataStore;
- }
-
-}
diff --git a/gora-geode/src/test/java/store/TestGeodeStore.java b/gora-geode/src/test/java/store/TestGeodeStore.java
deleted file mode 100644
index 421a7666..00000000
--- a/gora-geode/src/test/java/store/TestGeodeStore.java
+++ /dev/null
@@ -1,161 +0,0 @@
-/**
- * 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 store;
-
-
-
-import org.apache.avro.util.Utf8;
-import org.apache.gora.examples.WebPageDataCreator;
-import org.apache.gora.examples.generated.WebPage;
-import org.apache.gora.geode.GeodeStartupLogWaitStrategy;
-import org.apache.gora.geode.GoraGeodeTestDriver;
-import org.apache.gora.geode.query.GeodeResult;
-import org.apache.gora.query.Query;
-import org.apache.gora.store.DataStoreTestBase;
-import org.apache.gora.util.GoraException;
-import org.junit.ClassRule;
-import org.junit.Ignore;
-import org.junit.Test;
-import org.testcontainers.containers.GenericContainer;
-
-
-
-import java.io.IOException;
-import java.nio.ByteBuffer;
-import java.nio.charset.Charset;
-import java.time.Duration;
-
-import static org.junit.Assert.*;
-
-/**
- * Tests extending {@link DataStoreTestBase}
- * which run the base JUnit test suite for Gora.
- */
-public class TestGeodeStore extends DataStoreTestBase {
-
- private static final String DOCKER_CONTAINER_NAME = "apachegeode/" +
- "" +
- "geode:1.15.0";
-
- /**
- * JUnit integration testing with Docker and Testcontainers
- */
- @ClassRule
- public static GenericContainer Geode_CONTAINER = new GenericContainer(DOCKER_CONTAINER_NAME)
- .withExposedPorts(10334)
- .waitingFor(new GeodeStartupLogWaitStrategy())
- .withStartupTimeout(Duration.ofSeconds(300));
-
-
- // void withCommand("tail","-f","/dev/null").start();
-
- // geode = new GenericContainer<>("apachegeode/geode:1.12.0");
-
-
- static {
- try {
- setTestDriver(new GoraGeodeTestDriver(Geode_CONTAINER));
- } catch (Exception e) {
- throw new RuntimeException(e);
- }
- }
-
- @Override
- public void setUp() throws Exception {
- super.setUp();
- }
-
- @Test
- public void testPutAndGet() throws GoraException {
- WebPage page = webPageStore.newPersistent();
-
- // Write webpage data
- page.setUrl(new Utf8("http://example.com"));
- byte[] contentBytes = "example content in example.com".getBytes(Charset.defaultCharset());
- ByteBuffer buff = ByteBuffer.wrap(contentBytes);
- page.setContent(buff);
- webPageStore.put("com.example/http", page);
- webPageStore.flush();
-
- WebPage storedPage = webPageStore.get("com.example/http");
-
- assertNotNull(storedPage);
- assertEquals(page.getUrl(), storedPage.getUrl());
- }
-
- @Test
- public void testCreateAndDeleteSchema() throws IOException {
- WebPage page = webPageStore.newPersistent();
-
- // Write webpage data
- page.setUrl(new Utf8("http://example.com"));
- webPageStore.put("com.example/http", page);
- webPageStore.flush();
-
- assertEquals("WebPage isn't created.", page.getUrl(), webPageStore.get("com.example/http").getUrl());
-
- webPageStore.deleteSchema();
-
- assertNull(webPageStore.get("com.example/http"));
- }
-
- @Test
- public void testGetSchemaName() throws IOException {
- assertEquals("WebPage", webPageStore.getSchemaName());
- assertEquals("Employee", employeeStore.getSchemaName());
- }
-
- @Test
- public void testExecute() throws IOException {
- WebPageDataCreator.createWebPageData(webPageStore);
-
- final Query query = webPageStore.newQuery();
-
- int limit = 5;
- query.setLimit(limit);
- GeodeResult result = (GeodeResult) webPageStore.execute(query);
- assertEquals(limit, result.size());
-
- limit = 10;
- query.setLimit(limit);
- result = (GeodeResult) webPageStore.execute(query);
- assertEquals(limit, result.size());
-
- }
-
- /**
- * By design, you cannot update a Geode document blindly, you can only attempt to update a specific revision of a document. FIXME
- */
- @Test
- @Ignore
- public void testUpdate() throws Exception {
- //By design, you cannot update a Geode document blindly, you can only attempt to update a specific revision of a document. FIXME
- }
-
- @Ignore("GeodeStore doesn't support 3 types union field yet")
- @Override
- public void testGet3UnionField() throws Exception {
- // GeodeStore doesn't support 3 types union field yet
- }
-
- @Ignore("Skip until GORA-66 is fixed: need better semantic for end/start keys")
- @Override
- public void testDeleteByQueryFields() throws IOException {
- // Skip until GORA-66 is fixed: need better semantic for end/start keys
- }
-
-}
diff --git a/pom.xml b/pom.xml
index ab2244ef..5dc91eac 100755
--- a/pom.xml
+++ b/pom.xml
@@ -780,7 +780,6 @@
gora-arangodb
gora-rethinkdb
gora-elasticsearch
- gora-geode
gora-tutorial
gora-benchmark
sources-dist
@@ -1640,13 +1639,6 @@
2.0.10
-
-
- org.apache.geode
- geode-core
- 1.15.0
-
-
com.amazonaws