Package org.apache.unomi.shell.migration.utils

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

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MigrationUtils

public MigrationUtils()

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