Class MigrationUtils
- java.lang.Object
-
- org.apache.unomi.shell.migration.utils.MigrationUtils
-
public class MigrationUtils extends Object
- Author:
- dgaillard
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
MigrationUtils.ScrollCallback
-
Constructor Summary
Constructors Constructor Description MigrationUtils()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static String
buildIndexCreationRequest(String baseIndexSettings, String mapping, MigrationContext context, boolean isMonthlyIndex)
static void
bulkUpdate(org.apache.http.impl.client.CloseableHttpClient httpClient, String url, String jsonData)
static org.json.JSONObject
continueQueryWithScroll(org.apache.http.impl.client.CloseableHttpClient httpClient, String url, String scrollId)
static String
extractMappingFromBundles(org.osgi.framework.BundleContext bundleContext, String fileName)
static String
getFileWithoutComments(org.osgi.framework.BundleContext bundleContext, String resource)
static Set<String>
getIndexesPrefixedBy(org.apache.http.impl.client.CloseableHttpClient httpClient, String esAddress, String prefix)
static boolean
indexExists(org.apache.http.impl.client.CloseableHttpClient httpClient, String esAddress, String indexName)
static org.json.JSONObject
queryWithScroll(org.apache.http.impl.client.CloseableHttpClient httpClient, String url)
static void
reIndex(org.apache.http.impl.client.CloseableHttpClient httpClient, org.osgi.framework.BundleContext bundleContext, String esAddress, String indexName, String newIndexSettings, String painlessScript, MigrationContext migrationContext)
static String
resourceAsString(org.osgi.framework.BundleContext bundleContext, String resource)
static void
scrollQuery(org.apache.http.impl.client.CloseableHttpClient httpClient, String esAddress, String queryURL, String query, String scrollDuration, MigrationUtils.ScrollCallback scrollCallback)
static void
waitForYellowStatus(org.apache.http.impl.client.CloseableHttpClient httpClient, String esAddress, MigrationContext migrationContext)
Utility method that waits for the ES cluster to be in yellow status
-
-
-
Method Detail
-
queryWithScroll
public static org.json.JSONObject queryWithScroll(org.apache.http.impl.client.CloseableHttpClient httpClient, String url) throws IOException
- Throws:
IOException
-
continueQueryWithScroll
public static org.json.JSONObject continueQueryWithScroll(org.apache.http.impl.client.CloseableHttpClient httpClient, String url, String scrollId) throws IOException
- Throws:
IOException
-
bulkUpdate
public static void bulkUpdate(org.apache.http.impl.client.CloseableHttpClient httpClient, String url, String jsonData) throws IOException
- Throws:
IOException
-
resourceAsString
public static String resourceAsString(org.osgi.framework.BundleContext bundleContext, String resource)
-
getFileWithoutComments
public static String getFileWithoutComments(org.osgi.framework.BundleContext bundleContext, String resource)
-
indexExists
public static boolean indexExists(org.apache.http.impl.client.CloseableHttpClient httpClient, String esAddress, String indexName) throws IOException
- Throws:
IOException
-
getIndexesPrefixedBy
public static Set<String> getIndexesPrefixedBy(org.apache.http.impl.client.CloseableHttpClient httpClient, String esAddress, String prefix) throws IOException
- Throws:
IOException
-
extractMappingFromBundles
public static String extractMappingFromBundles(org.osgi.framework.BundleContext bundleContext, String fileName) throws IOException
- Throws:
IOException
-
buildIndexCreationRequest
public static String buildIndexCreationRequest(String baseIndexSettings, String mapping, MigrationContext context, boolean isMonthlyIndex) throws IOException
- Throws:
IOException
-
reIndex
public static void reIndex(org.apache.http.impl.client.CloseableHttpClient httpClient, org.osgi.framework.BundleContext bundleContext, String esAddress, String indexName, String newIndexSettings, String painlessScript, MigrationContext migrationContext) throws Exception
- Throws:
Exception
-
scrollQuery
public static void scrollQuery(org.apache.http.impl.client.CloseableHttpClient httpClient, String esAddress, String queryURL, String query, String scrollDuration, MigrationUtils.ScrollCallback scrollCallback) throws IOException
- Throws:
IOException
-
waitForYellowStatus
public static void waitForYellowStatus(org.apache.http.impl.client.CloseableHttpClient httpClient, String esAddress, MigrationContext migrationContext) throws Exception
Utility method that waits for the ES cluster to be in yellow status- Throws:
Exception
-
-