@UriParams public class GoraConfiguration extends Object
Constructor and Description |
---|
GoraConfiguration() |
Modifier and Type | Method and Description |
---|---|
int |
getConcurrentConsumers() |
String |
getDataStoreClass() |
Object |
getEndKey() |
long |
getEndTime() |
com.google.common.base.Strings |
getFields() |
org.apache.hadoop.conf.Configuration |
getHadoopConfiguration() |
String |
getKeyClass() |
Object |
getKeyRangeFrom() |
Object |
getKeyRangeTo() |
long |
getLimit() |
String |
getName() |
Object |
getStartKey() |
long |
getStartTime() |
long |
getTimeRangeFrom() |
long |
getTimeRangeTo() |
long |
getTimestamp() |
String |
getValueClass() |
boolean |
isFlushOnEveryOperation() |
void |
setConcurrentConsumers(int concurrentConsumers)
Number of concurrent consumers
|
void |
setDataStoreClass(String dataStoreClass)
The type of the dataStore
|
void |
setEndKey(Object endKey)
The End Key
|
void |
setEndTime(long endTime)
The End Time
|
void |
setFields(com.google.common.base.Strings fields)
The Fields
|
void |
setFlushOnEveryOperation(boolean flushOnEveryOperation)
Flush on every operation
|
void |
setHadoopConfiguration(org.apache.hadoop.conf.Configuration hadoopConfiguration)
Hadoop Configuration
|
void |
setKeyClass(String keyClass)
The type class of the key
|
void |
setKeyRangeFrom(Object keyRangeFrom)
The Key Range From
|
void |
setKeyRangeTo(Object keyRangeTo)
The Key Range To
|
void |
setLimit(long limit)
The Limit
|
void |
setName(String name)
Instance name
|
void |
setStartKey(Object startKey)
The Start Key
|
void |
setStartTime(long startTime)
The Start Time
|
void |
setTimeRangeFrom(long timeRangeFrom)
The Time Range From
|
void |
setTimeRangeTo(long timeRangeTo)
The Time Range To
|
void |
setTimestamp(long timestamp)
The Timestamp
|
void |
setValueClass(String valueClass)
The type of the value
|
public String getKeyClass()
public void setKeyClass(String keyClass)
public String getValueClass()
public void setValueClass(String valueClass)
public String getDataStoreClass()
public void setDataStoreClass(String dataStoreClass)
public org.apache.hadoop.conf.Configuration getHadoopConfiguration()
public long getStartTime()
public void setStartTime(long startTime)
public long getEndTime()
public void setEndTime(long endTime)
public long getTimeRangeFrom()
public void setTimeRangeFrom(long timeRangeFrom)
public long getTimeRangeTo()
public void setTimeRangeTo(long timeRangeTo)
public long getLimit()
public void setLimit(long limit)
public long getTimestamp()
public void setTimestamp(long timestamp)
public Object getStartKey()
public void setStartKey(Object startKey)
public Object getEndKey()
public void setEndKey(Object endKey)
public Object getKeyRangeFrom()
public void setKeyRangeFrom(Object keyRangeFrom)
public Object getKeyRangeTo()
public void setKeyRangeTo(Object keyRangeTo)
public com.google.common.base.Strings getFields()
public void setFields(com.google.common.base.Strings fields)
public int getConcurrentConsumers()
public void setConcurrentConsumers(int concurrentConsumers)
public boolean isFlushOnEveryOperation()
public void setFlushOnEveryOperation(boolean flushOnEveryOperation)
public void setHadoopConfiguration(org.apache.hadoop.conf.Configuration hadoopConfiguration)
public String getName()
public void setName(String name)
Apache Camel