com.netflix.nicobar.cassandra

Class BasicCassandraRepositoryConfig

java.lang.Object

com.netflix.nicobar.cassandra.BasicCassandraRepositoryConfig

All Implemented Interfaces:

CassandraArchiveRepositoryConfig

public class BasicCassandraRepositoryConfig
extends java.lang.Object
implements CassandraArchiveRepositoryConfig

Configuration provider for the CassandraArchiveRepository

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BasicCassandraRepositoryConfig.Builder

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_FETCH_BATCH_SIZE Default number of archives to fetch per round-trip
static int	DEFAULT_SHARD_COUNT default number of shards to separate the archives into
static ScriptModuleSpecSerializer	DEFAULT_SPEC_SERIALIZER Default module spec serializer

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BasicCassandraRepositoryConfig(java.lang.String repositoryId, CassandraGateway gateway, int shardCount, int fetchBatchSize, java.nio.file.Path archiveOutputDirectory, ScriptModuleSpecSerializer moduleSpecSerializer)

Method Summary

Methods

Modifier and Type	Method and Description
int	getArchiveFetchBatchSize()
java.nio.file.Path	getArchiveOutputDirectory()
CassandraGateway	getCassandraGateway()
ScriptModuleSpecSerializer	getModuleSpecSerializer()
java.lang.String	getRepositoryId()
int	getShardCount()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_SHARD_COUNT

public static final int DEFAULT_SHARD_COUNT

default number of shards to separate the archives into

See Also:

Constant Field Values

DEFAULT_FETCH_BATCH_SIZE

public static final int DEFAULT_FETCH_BATCH_SIZE

Default number of archives to fetch per round-trip

See Also:

Constant Field Values

DEFAULT_SPEC_SERIALIZER

public static final ScriptModuleSpecSerializer DEFAULT_SPEC_SERIALIZER

Default module spec serializer

Constructor Detail

BasicCassandraRepositoryConfig

protected BasicCassandraRepositoryConfig(java.lang.String repositoryId,
                              CassandraGateway gateway,
                              int shardCount,
                              int fetchBatchSize,
                              java.nio.file.Path archiveOutputDirectory,
                              ScriptModuleSpecSerializer moduleSpecSerializer)

Method Detail

getCassandraGateway

public CassandraGateway getCassandraGateway()

Specified by:

getCassandraGateway in interface CassandraArchiveRepositoryConfig

Returns:

a gateway to perform common operations on the datastore.

getShardCount

public int getShardCount()

Specified by:

getShardCount in interface CassandraArchiveRepositoryConfig

Returns:

number of shards to put the archives in

getArchiveFetchBatchSize

public int getArchiveFetchBatchSize()

Specified by:

getArchiveFetchBatchSize in interface CassandraArchiveRepositoryConfig

Returns:

how many archives to fetch at a time

getArchiveOutputDirectory

public java.nio.file.Path getArchiveOutputDirectory()

Specified by:

getArchiveOutputDirectory in interface CassandraArchiveRepositoryConfig

Returns:

the output directory for archives

getModuleSpecSerializer

public ScriptModuleSpecSerializer getModuleSpecSerializer()

Specified by:

getModuleSpecSerializer in interface CassandraArchiveRepositoryConfig

Returns:

serializer for the ScriptModuleSpec for use when inserting or fetching data.

getRepositoryId

public java.lang.String getRepositoryId()

Specified by:

getRepositoryId in interface CassandraArchiveRepositoryConfig

Returns:

Descriptive string which uniquely identifies the repository. Used for display and reporting.