public class InternalUtilities extends Object implements MarkLogicConstants
Modifier and Type | Field and Description |
---|---|
static org.apache.commons.logging.Log |
LOG |
ADVANCED_MODE, ASSIGNMENT_POLICY, BASIC_MODE, BATCH_SIZE, BIND_SPLIT_RANGE, COLLECTION_FILTER, CONTENT_TYPE, COPY_COLLECTIONS, COPY_METADATA, COPY_QUALITY, DEFAULT_BATCH_SIZE, DEFAULT_CONTENT_TYPE, DEFAULT_LOCAL_MAX_SPLIT_SIZE, DEFAULT_MAX_SPLIT_SIZE, DEFAULT_OUTPUT_CONTENT_ENCODING, DEFAULT_OUTPUT_XML_REPAIR_LEVEL, DEFAULT_PROPERTY_OPERATION_TYPE, DIRECTORY_FILTER, DOCUMENT_SELECTOR, EXECUTION_MODE, EXTRACT_URI, INDENTED, INPUT_DATABASE_NAME, INPUT_HOST, INPUT_KEY_CLASS, INPUT_LEXICON_FUNCTION_CLASS, INPUT_MODE, INPUT_PASSWORD, INPUT_PORT, INPUT_QUERY, INPUT_QUERY_LANGUAGE, INPUT_QUERY_TIMESTAMP, INPUT_RESTRICT_HOSTS, INPUT_SSL_OPTIONS_CLASS, INPUT_SSL_PROTOCOL, INPUT_USE_SSL, INPUT_USERNAME, INPUT_VALUE_CLASS, MAX_SPLIT_SIZE, MIN_NODEUPDATE_VERSION, MODE_DISTRIBUTED, MODE_LOCAL, MR_NAMESPACE, NODE_OPERATION_TYPE, OUTPUT_CLEAN_DIR, OUTPUT_COLLECTION, OUTPUT_CONTENT_ENCODING, OUTPUT_CONTENT_LANGUAGE, OUTPUT_CONTENT_NAMESPACE, OUTPUT_DATABASE_NAME, OUTPUT_DIRECTORY, OUTPUT_FAST_LOAD, OUTPUT_FOREST_HOST, OUTPUT_GRAPH, OUTPUT_HOST, OUTPUT_KEY_TYPE, OUTPUT_KEY_VARNAME, OUTPUT_NAMESPACE, OUTPUT_OVERRIDE_GRAPH, OUTPUT_PARTITION, OUTPUT_PASSWORD, OUTPUT_PERMISSION, OUTPUT_PORT, OUTPUT_PROPERTY_ALWAYS_CREATE, OUTPUT_QUALITY, OUTPUT_QUERY, OUTPUT_QUERY_LANGUAGE, OUTPUT_RESTRICT_HOSTS, OUTPUT_SSL_OPTIONS_CLASS, OUTPUT_SSL_PROTOCOL, OUTPUT_STREAMING, OUTPUT_TOLERATE_ERRORS, OUTPUT_URI_PREFIX, OUTPUT_URI_REPLACE, OUTPUT_URI_SUFFIX, OUTPUT_USE_SSL, OUTPUT_USERNAME, OUTPUT_VALUE_TYPE, OUTPUT_VALUE_VARNAME, OUTPUT_XML_REPAIR_LEVEL, PATH_NAMESPACE, PROPERTY_OPERATION_TYPE, QUERY_FILTER, RECORD_TO_FRAGMENT_RATIO, REDACTION_RULE_COLLECTION, SPLIT_END_VARNAME, SPLIT_QUERY, SPLIT_START_VARNAME, SUBDOCUMENT_EXPRESSION, TEMPORAL_COLLECTION, TXN_SIZE, TYPE_FILTER
Constructor and Description |
---|
InternalUtilities() |
Modifier and Type | Method and Description |
---|---|
static <VALUEIN> void |
assignResultValue(Class<? extends org.apache.hadoop.io.Writable> valueClass,
com.marklogic.xcc.ResultItem result,
VALUEIN value)
Assign value in Writable type from XCC result item.
|
static void |
checkQueryLanguage(String s) |
static int |
compareUnsignedLong(long x,
long y) |
static String |
getHost(TextArrayWritable hosts)
Return the host from the host array based on a random fashion
|
static com.marklogic.xcc.ContentSource |
getInputContentSource(org.apache.hadoop.conf.Configuration conf)
Get content source for input server.
|
static com.marklogic.xcc.ContentSource |
getInputContentSource(org.apache.hadoop.conf.Configuration conf,
String host)
Get input content source.
|
static com.marklogic.xcc.ContentSource |
getOutputContentSource(org.apache.hadoop.conf.Configuration conf,
String hostName)
Get output content source.
|
static String |
getUriWithOutputDir(DocumentURI key,
String outputDir)
If outputDir is available and valid, modify DocumentURI, and return uri
in string
|
static com.marklogic.xcc.types.XdmValue |
newValue(com.marklogic.xcc.types.ValueType valueType,
Object value)
Create new XdmValue from value type and Writables.
|
static void |
sleep(long millis)
Wake up every 1 second to check whether to abort
|
static String |
unparse(String s) |
static void |
verifyHosts(String hostList,
String portStr) |
public static com.marklogic.xcc.ContentSource getInputContentSource(org.apache.hadoop.conf.Configuration conf) throws URISyntaxException, com.marklogic.xcc.exceptions.XccConfigException, IOException
conf
- job configuration.URISyntaxException
com.marklogic.xcc.exceptions.XccConfigException
IOException
public static com.marklogic.xcc.ContentSource getInputContentSource(org.apache.hadoop.conf.Configuration conf, String host) throws com.marklogic.xcc.exceptions.XccConfigException, IOException
conf
- job configurationhost
- host to connect toIOException
com.marklogic.xcc.exceptions.XccConfigException
public static <VALUEIN> void assignResultValue(Class<? extends org.apache.hadoop.io.Writable> valueClass, com.marklogic.xcc.ResultItem result, VALUEIN value)
VALUEIN
- valueClass
- result
- value
- public static com.marklogic.xcc.ContentSource getOutputContentSource(org.apache.hadoop.conf.Configuration conf, String hostName) throws com.marklogic.xcc.exceptions.XccConfigException, IOException
conf
- job configurationhostName
- host nameIOException
com.marklogic.xcc.exceptions.XccConfigException
IOException
public static String getHost(TextArrayWritable hosts) throws IOException
hosts
- a WritableArray of host namesIOException
public static com.marklogic.xcc.types.XdmValue newValue(com.marklogic.xcc.types.ValueType valueType, Object value)
public static String getUriWithOutputDir(DocumentURI key, String outputDir)
key
- outputDir
- public static int compareUnsignedLong(long x, long y)
public static void checkQueryLanguage(String s)
public static void sleep(long millis) throws InterruptedException
millis
- InterruptedException
Copyright © 2020 MarkLogic Corporation. All Rights Reserved.
Complete online documentation for MarkLogic Server, XQuery and related components may be found at developer.marklogic.com