public class ConfigurationUtil extends Object
Modifier and Type | Field and Description |
---|---|
static String |
DB_HOST
The link for the documentdb endpoint
|
static String |
DB_KEY
The masterkey used for the documentdb account.
|
static String |
DB_NAME
The database Id used in the Map Reduce job.
|
static String |
INPUT_COLLECTION_NAMES
Comma separated input collections Ids used in the map reduce job.
|
static String |
OUTPUT_COLLECTION_NAMES
Comma separated outp collections Ids used in the map reduce job.
|
static String |
OUTPUT_RANGE_INDEXED
Comma separated Property paths to range index in the output collections.
|
static String |
QUERY
the documentdb query pushed down to the input collections when reading.
|
static String |
UPSERT
An upsert option, true by default.
|
Constructor and Description |
---|
ConfigurationUtil() |
Modifier and Type | Method and Description |
---|---|
static void |
copyDocumentDBProperties(Properties from,
Map<String,String> to)
Copies the configuration properties for the connector to a map.
|
static String |
getDBEndpoint(org.apache.hadoop.conf.Configuration conf)
Gets the DocumentDB.endpoint from the Configuration object.
|
static String |
getDBKey(org.apache.hadoop.conf.Configuration conf)
Gets the DocumentDB.key from the Configuration object.
|
static String |
getDBName(org.apache.hadoop.conf.Configuration conf)
Gets the DocumentDB.db from the Configuration object.
|
static String[] |
getInputCollectionNames(org.apache.hadoop.conf.Configuration conf)
Gets the DocumentDB.inputCollections from the Configuration object.
|
static String[] |
getOutputCollectionNames(org.apache.hadoop.conf.Configuration conf)
Gets the DocumentDB.outputCollections from the Configuration object.
|
static String |
getQuery(org.apache.hadoop.conf.Configuration conf)
Gets the DocumentDB.query from the Configuration object.
|
static String[] |
getRangeIndex(org.apache.hadoop.conf.Configuration conf)
Gets the DocumentDB.rangeIndex from the Configuration object.
|
static boolean |
getUpsert(org.apache.hadoop.conf.Configuration conf)
Gets the DocumentDB.upsert from the Configuration object.
|
public static final String DB_NAME
public static final String INPUT_COLLECTION_NAMES
public static final String OUTPUT_COLLECTION_NAMES
public static final String DB_HOST
public static final String DB_KEY
public static final String QUERY
public static final String OUTPUT_RANGE_INDEXED
public static final String UPSERT
public static final String getDBName(org.apache.hadoop.conf.Configuration conf)
conf
- job configuration objectpublic static final String[] getInputCollectionNames(org.apache.hadoop.conf.Configuration conf)
conf
- job configuration objectpublic static final String[] getOutputCollectionNames(org.apache.hadoop.conf.Configuration conf)
conf
- job configuration objectpublic static final String getDBEndpoint(org.apache.hadoop.conf.Configuration conf)
conf
- job configuration objectpublic static final String getDBKey(org.apache.hadoop.conf.Configuration conf)
conf
- job configuration object.public static final String getQuery(org.apache.hadoop.conf.Configuration conf)
conf
- job configuration objectpublic static final String[] getRangeIndex(org.apache.hadoop.conf.Configuration conf)
conf
- job configuration objectpublic static final boolean getUpsert(org.apache.hadoop.conf.Configuration conf)
conf
- job configuration objectpublic static void copyDocumentDBProperties(Properties from, Map<String,String> to)
from
- Properties object to copy from.to
- Target map to copy properties to.Copyright © 2015. All rights reserved.