org.vertexium.accumulo

Class AccumuloGraphConfiguration

java.lang.Object

org.vertexium.GraphConfiguration

org.vertexium.accumulo.AccumuloGraphConfiguration

public class AccumuloGraphConfiguration
extends GraphConfiguration

Field Summary

Fields

Modifier and Type	Field and Description
static String	ACCUMULO_INSTANCE_NAME
static String	ACCUMULO_MAX_EXTENDED_DATA_VERSIONS
static String	ACCUMULO_MAX_VERSIONS
static String	ACCUMULO_PASSWORD
static String	ACCUMULO_USERNAME
static String	BATCHWRITER_CONFIG_PREFIX
static String	BATCHWRITER_MAX_LATENCY
static String	BATCHWRITER_MAX_MEMORY
static String	BATCHWRITER_MAX_WRITE_THREADS
static String	BATCHWRITER_TIMEOUT
static String	DATA_DIR
static String	DEFAULT_ACCUMULO_INSTANCE_NAME
static Integer	DEFAULT_ACCUMULO_MAX_VERSIONS
static String	DEFAULT_ACCUMULO_PASSWORD
static String	DEFAULT_ACCUMULO_USERNAME
static Long	DEFAULT_BATCHWRITER_MAX_LATENCY
static Long	DEFAULT_BATCHWRITER_MAX_MEMORY
static Integer	DEFAULT_BATCHWRITER_MAX_WRITE_THREADS
static Long	DEFAULT_BATCHWRITER_TIMEOUT
static String	DEFAULT_DATA_DIR
static String	DEFAULT_HDFS_CONTEXT_CLASSPATH
static String	DEFAULT_HDFS_ROOT_DIR
static String	DEFAULT_HDFS_USER
static boolean	DEFAULT_HISTORY_IN_SEPARATE_TABLE
static int	DEFAULT_MAX_STREAMING_PROPERTY_VALUE_TABLE_DATA_SIZE
static int	DEFAULT_NUMBER_OF_QUERY_THREADS
static String	DEFAULT_ZOOKEEPER_METADATA_SYNC_PATH
static String	DEFAULT_ZOOKEEPER_SERVERS
static String	HADOOP_CONF_DIR
static String[]	HADOOP_CONF_FILENAMES
static String	HDFS_CONFIG_PREFIX
static String	HDFS_CONTEXT_CLASSPATH
static String	HDFS_ROOT_DIR
static String	HDFS_USER
static String	HISTORY_IN_SEPARATE_TABLE
static String	MAX_STREAMING_PROPERTY_VALUE_TABLE_DATA_SIZE
static String	NAME_SUBSTITUTION_STRATEGY_PROP_PREFIX
static String	NUMBER_OF_QUERY_THREADS
static String	ZOOKEEPER_METADATA_SYNC_PATH
static String	ZOOKEEPER_SERVERS

Fields inherited from class org.vertexium.GraphConfiguration

AUTO_FLUSH, CREATE_TABLES, DEFAULT_AUTO_FLUSH, DEFAULT_CREATE_TABLES, DEFAULT_DEFAULT_FETCH_HINTS, DEFAULT_FETCH_HINTS, DEFAULT_IDGENERATOR, DEFAULT_SEARCH_INDEX, DEFAULT_SERIALIZER, DEFAULT_STRICT_TYPING, DEFAULT_TABLE_NAME_PREFIX, IDGENERATOR_PROP_PREFIX, SEARCH_INDEX_PROP_PREFIX, SERIALIZER, STRICT_TYPING, TABLE_NAME_PREFIX

Constructor Summary

Constructors

Constructor and Description
AccumuloGraphConfiguration(org.apache.hadoop.conf.Configuration configuration, String prefix)
AccumuloGraphConfiguration(Map<String,Object> config)

Method Summary

Modifier and Type	Method and Description
org.apache.accumulo.core.client.BatchWriterConfig	createBatchWriterConfig()
org.apache.accumulo.core.client.Connector	createConnector()
org.apache.hadoop.fs.FileSystem	createFileSystem()
NameSubstitutionStrategy	createSubstitutionStrategy(Graph graph)
String	getAccumuloInstanceName()
String	getAccumuloUsername()
org.apache.accumulo.core.client.security.tokens.AuthenticationToken	getAuthenticationToken()
org.apache.accumulo.core.client.ClientConfiguration	getClientConfiguration()
String	getDataDir()
Integer	getExtendedDataMaxVersions()
String	getHdfsContextClasspath()
long	getMaxStreamingPropertyValueTableDataSize()
Integer	getMaxVersions()
int	getNumberOfQueryThreads()
String	getZookeeperMetadataSyncPath()
String	getZookeeperServers()
boolean	isAutoFlush()
boolean	isHistoryInSeparateTable()

Methods inherited from class org.vertexium.GraphConfiguration

createIdGenerator, createSearchIndex, createSerializer, createSerializer, getBoolean, getConfig, getConfig, getConfigLong, getDouble, getInt, getInteger, getString, getTableNamePrefix, isCreateTables, isStrictTyping, set

Methods inherited from class java.lang.Object

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

Field Detail

HDFS_CONFIG_PREFIX

public static final String HDFS_CONFIG_PREFIX

See Also:

Constant Field Values

BATCHWRITER_CONFIG_PREFIX

public static final String BATCHWRITER_CONFIG_PREFIX

See Also:

Constant Field Values

ACCUMULO_INSTANCE_NAME

public static final String ACCUMULO_INSTANCE_NAME

See Also:

Constant Field Values

ACCUMULO_USERNAME

public static final String ACCUMULO_USERNAME

See Also:

Constant Field Values

ACCUMULO_PASSWORD

public static final String ACCUMULO_PASSWORD

See Also:

Constant Field Values

ZOOKEEPER_SERVERS

public static final String ZOOKEEPER_SERVERS

See Also:

Constant Field Values

ZOOKEEPER_METADATA_SYNC_PATH

public static final String ZOOKEEPER_METADATA_SYNC_PATH

See Also:

Constant Field Values

ACCUMULO_MAX_VERSIONS

public static final String ACCUMULO_MAX_VERSIONS

See Also:

Constant Field Values

ACCUMULO_MAX_EXTENDED_DATA_VERSIONS

public static final String ACCUMULO_MAX_EXTENDED_DATA_VERSIONS

See Also:

Constant Field Values

HISTORY_IN_SEPARATE_TABLE

public static final String HISTORY_IN_SEPARATE_TABLE

See Also:

Constant Field Values

NAME_SUBSTITUTION_STRATEGY_PROP_PREFIX

public static final String NAME_SUBSTITUTION_STRATEGY_PROP_PREFIX

See Also:

Constant Field Values

MAX_STREAMING_PROPERTY_VALUE_TABLE_DATA_SIZE

public static final String MAX_STREAMING_PROPERTY_VALUE_TABLE_DATA_SIZE

See Also:

Constant Field Values

HDFS_USER

public static final String HDFS_USER

See Also:

Constant Field Values

HDFS_ROOT_DIR

public static final String HDFS_ROOT_DIR

See Also:

Constant Field Values

DATA_DIR

public static final String DATA_DIR

See Also:

Constant Field Values

BATCHWRITER_MAX_MEMORY

public static final String BATCHWRITER_MAX_MEMORY

See Also:

Constant Field Values

BATCHWRITER_MAX_LATENCY

public static final String BATCHWRITER_MAX_LATENCY

See Also:

Constant Field Values

BATCHWRITER_TIMEOUT

public static final String BATCHWRITER_TIMEOUT

See Also:

Constant Field Values

BATCHWRITER_MAX_WRITE_THREADS

public static final String BATCHWRITER_MAX_WRITE_THREADS

See Also:

Constant Field Values

NUMBER_OF_QUERY_THREADS

public static final String NUMBER_OF_QUERY_THREADS

See Also:

Constant Field Values

HDFS_CONTEXT_CLASSPATH

public static final String HDFS_CONTEXT_CLASSPATH

See Also:

Constant Field Values

DEFAULT_ACCUMULO_PASSWORD

public static final String DEFAULT_ACCUMULO_PASSWORD

See Also:

Constant Field Values

DEFAULT_ACCUMULO_USERNAME

public static final String DEFAULT_ACCUMULO_USERNAME

See Also:

Constant Field Values

DEFAULT_ACCUMULO_INSTANCE_NAME

public static final String DEFAULT_ACCUMULO_INSTANCE_NAME

See Also:

Constant Field Values

DEFAULT_ZOOKEEPER_SERVERS

public static final String DEFAULT_ZOOKEEPER_SERVERS

See Also:

Constant Field Values

DEFAULT_ZOOKEEPER_METADATA_SYNC_PATH

public static final String DEFAULT_ZOOKEEPER_METADATA_SYNC_PATH

See Also:

Constant Field Values

DEFAULT_MAX_STREAMING_PROPERTY_VALUE_TABLE_DATA_SIZE

public static final int DEFAULT_MAX_STREAMING_PROPERTY_VALUE_TABLE_DATA_SIZE

See Also:

Constant Field Values

DEFAULT_HDFS_USER

public static final String DEFAULT_HDFS_USER

See Also:

Constant Field Values

DEFAULT_HDFS_ROOT_DIR

public static final String DEFAULT_HDFS_ROOT_DIR

See Also:

Constant Field Values

HADOOP_CONF_DIR

public static final String HADOOP_CONF_DIR

See Also:

Constant Field Values

DEFAULT_DATA_DIR

public static final String DEFAULT_DATA_DIR

See Also:

Constant Field Values

DEFAULT_BATCHWRITER_MAX_MEMORY

public static final Long DEFAULT_BATCHWRITER_MAX_MEMORY

DEFAULT_BATCHWRITER_MAX_LATENCY

public static final Long DEFAULT_BATCHWRITER_MAX_LATENCY

DEFAULT_BATCHWRITER_TIMEOUT

public static final Long DEFAULT_BATCHWRITER_TIMEOUT

DEFAULT_BATCHWRITER_MAX_WRITE_THREADS

public static final Integer DEFAULT_BATCHWRITER_MAX_WRITE_THREADS

DEFAULT_ACCUMULO_MAX_VERSIONS

public static final Integer DEFAULT_ACCUMULO_MAX_VERSIONS

DEFAULT_HISTORY_IN_SEPARATE_TABLE

public static final boolean DEFAULT_HISTORY_IN_SEPARATE_TABLE

See Also:

Constant Field Values

DEFAULT_NUMBER_OF_QUERY_THREADS

public static final int DEFAULT_NUMBER_OF_QUERY_THREADS

See Also:

Constant Field Values

DEFAULT_HDFS_CONTEXT_CLASSPATH

public static final String DEFAULT_HDFS_CONTEXT_CLASSPATH

HADOOP_CONF_FILENAMES

public static final String[] HADOOP_CONF_FILENAMES

Constructor Detail

AccumuloGraphConfiguration

public AccumuloGraphConfiguration(Map<String,Object> config)

AccumuloGraphConfiguration

public AccumuloGraphConfiguration(org.apache.hadoop.conf.Configuration configuration,
                                  String prefix)

Method Detail

createConnector

public org.apache.accumulo.core.client.Connector createConnector()
                                                          throws org.apache.accumulo.core.client.AccumuloSecurityException,
                                                                 org.apache.accumulo.core.client.AccumuloException

Throws:

org.apache.accumulo.core.client.AccumuloSecurityException

org.apache.accumulo.core.client.AccumuloException

getClientConfiguration

public org.apache.accumulo.core.client.ClientConfiguration getClientConfiguration()

createFileSystem

public org.apache.hadoop.fs.FileSystem createFileSystem()
                                                 throws URISyntaxException,
                                                        IOException,
                                                        InterruptedException

Throws:

URISyntaxException

IOException

InterruptedException

getAuthenticationToken

public org.apache.accumulo.core.client.security.tokens.AuthenticationToken getAuthenticationToken()

getAccumuloUsername

public String getAccumuloUsername()

getAccumuloInstanceName

public String getAccumuloInstanceName()

getZookeeperServers

public String getZookeeperServers()

isAutoFlush

public boolean isAutoFlush()

getMaxStreamingPropertyValueTableDataSize

public long getMaxStreamingPropertyValueTableDataSize()

getDataDir

public String getDataDir()

createSubstitutionStrategy

public NameSubstitutionStrategy createSubstitutionStrategy(Graph graph)

createBatchWriterConfig

public org.apache.accumulo.core.client.BatchWriterConfig createBatchWriterConfig()

getMaxVersions

public Integer getMaxVersions()

getExtendedDataMaxVersions

public Integer getExtendedDataMaxVersions()

getNumberOfQueryThreads

public int getNumberOfQueryThreads()

getHdfsContextClasspath

public String getHdfsContextClasspath()

getZookeeperMetadataSyncPath

public String getZookeeperMetadataSyncPath()

isHistoryInSeparateTable

public boolean isHistoryInSeparateTable()