|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.cassandra.hadoop.ConfigHelper
public class ConfigHelper
Constructor Summary | |
---|---|
ConfigHelper()
|
Method Summary | |
---|---|
static java.lang.String |
getColumnFamily(org.apache.hadoop.conf.Configuration conf)
|
static java.lang.String |
getInitialAddress(org.apache.hadoop.conf.Configuration conf)
|
static int |
getInputSplitSize(org.apache.hadoop.conf.Configuration conf)
|
static java.lang.String |
getKeyspace(org.apache.hadoop.conf.Configuration conf)
|
static int |
getRangeBatchSize(org.apache.hadoop.conf.Configuration conf)
The number of rows to request with each get range slices request. |
static SlicePredicate |
getSlicePredicate(org.apache.hadoop.conf.Configuration conf)
|
static int |
getThriftPort(org.apache.hadoop.conf.Configuration conf)
|
static void |
setColumnFamily(org.apache.hadoop.conf.Configuration conf,
java.lang.String keyspace,
java.lang.String columnFamily)
Set the keyspace and column family for this job. |
static void |
setInputSplitSize(org.apache.hadoop.conf.Configuration conf,
int splitsize)
Set the size of the input split. |
static void |
setRangeBatchSize(org.apache.hadoop.conf.Configuration conf,
int batchsize)
The number of rows to request with each get range slices request. |
static void |
setSlicePredicate(org.apache.hadoop.conf.Configuration conf,
SlicePredicate predicate)
Set the predicate that determines what columns will be selected from each row. |
static void |
setThriftContact(org.apache.hadoop.conf.Configuration conf,
java.lang.String address,
int port)
The address and port of a Cassandra node that Hadoop can contact over Thrift to learn more about the Cassandra cluster. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ConfigHelper()
Method Detail |
---|
public static void setColumnFamily(org.apache.hadoop.conf.Configuration conf, java.lang.String keyspace, java.lang.String columnFamily)
conf
- Job configuration you are about to runkeyspace
- columnFamily
- public static void setThriftContact(org.apache.hadoop.conf.Configuration conf, java.lang.String address, int port)
conf
- address
- port
- public static void setRangeBatchSize(org.apache.hadoop.conf.Configuration conf, int batchsize)
conf
- Job configuration you are about to runbatchsize
- Number of rows to request each timepublic static int getRangeBatchSize(org.apache.hadoop.conf.Configuration conf)
conf
- Job configuration you are about to run
public static void setInputSplitSize(org.apache.hadoop.conf.Configuration conf, int splitsize)
conf
- Job configuration you are about to runsplitsize
- Size of the input splitpublic static int getInputSplitSize(org.apache.hadoop.conf.Configuration conf)
public static void setSlicePredicate(org.apache.hadoop.conf.Configuration conf, SlicePredicate predicate)
conf
- Job configuration you are about to runpredicate
- public static SlicePredicate getSlicePredicate(org.apache.hadoop.conf.Configuration conf)
public static java.lang.String getKeyspace(org.apache.hadoop.conf.Configuration conf)
public static java.lang.String getColumnFamily(org.apache.hadoop.conf.Configuration conf)
public static int getThriftPort(org.apache.hadoop.conf.Configuration conf)
public static java.lang.String getInitialAddress(org.apache.hadoop.conf.Configuration conf)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |