Modifier and Type | Method and Description |
---|---|
static AbstractType<?> |
CliClient.getTypeByFunction(java.lang.String functionName)
Get AbstractType by function name
|
AbstractType<?> |
CliClient.Function.getValidator() |
Modifier and Type | Field and Description |
---|---|
AbstractType<?> |
CFMetaData.comparator |
Modifier and Type | Method and Description |
---|---|
AbstractType<?> |
CFMetaData.getColumnDefinitionComparator(ColumnDefinition def) |
AbstractType<?> |
Schema.getComparator(java.lang.String ksName,
java.lang.String cfName)
Get column comparator for ColumnFamily but it's keyspace/name
|
AbstractType<?> |
CFMetaData.getComponentComparator(java.lang.Integer componentIndex,
ColumnDefinition.Type type) |
AbstractType<?> |
CFMetaData.getDefaultValidator() |
AbstractType<?> |
CFMetaData.getKeyValidator() |
AbstractType<?> |
ColumnDefinition.getValidator() |
AbstractType<?> |
CFMetaData.getValueValidatorFromColumnName(java.nio.ByteBuffer columnName)
Like getColumnDefinitionFromColumnName, the argument must be an internal column/cell name.
|
Modifier and Type | Method and Description |
---|---|
void |
CFMetaData.addColumnMetadataFromAliases(java.util.List<java.nio.ByteBuffer> aliases,
AbstractType<?> comparator,
ColumnDefinition.Type type) |
void |
ColumnDefinition.apply(ColumnDefinition def,
AbstractType<?> comparator) |
static ColumnDefinition |
ColumnDefinition.clusteringKeyDef(java.nio.ByteBuffer name,
AbstractType<?> validator,
java.lang.Integer componentIndex) |
static ColumnDefinition |
ColumnDefinition.compactValueDef(java.nio.ByteBuffer name,
AbstractType<?> validator) |
CFMetaData |
CFMetaData.defaultValidator(AbstractType<?> prop) |
void |
ColumnDefinition.deleteFromSchema(RowMutation rm,
java.lang.String cfName,
AbstractType<?> comparator,
long timestamp)
Drop specified column from the schema using given row.
|
static java.lang.String |
CFMetaData.getDefaultIndexName(java.lang.String cfName,
AbstractType<?> comparator,
java.nio.ByteBuffer columnName) |
CFMetaData |
CFMetaData.keyValidator(AbstractType<?> prop) |
static CFMetaData |
CFMetaData.newIndexMetadata(CFMetaData parent,
ColumnDefinition info,
AbstractType<?> columnComparator) |
static ColumnDefinition |
ColumnDefinition.partitionKeyDef(java.nio.ByteBuffer name,
AbstractType<?> validator,
java.lang.Integer componentIndex) |
static ColumnDefinition |
ColumnDefinition.regularDef(java.nio.ByteBuffer name,
AbstractType<?> validator,
java.lang.Integer componentIndex) |
void |
ColumnDefinition.setValidator(AbstractType<?> validator) |
static ColumnDefinition |
ColumnDefinition.staticDef(java.nio.ByteBuffer name,
AbstractType<?> validator,
java.lang.Integer componentIndex) |
void |
ColumnDefinition.toSchema(RowMutation rm,
java.lang.String cfName,
AbstractType<?> comparator,
long timestamp) |
Constructor and Description |
---|
CFMetaData(java.lang.String keyspace,
java.lang.String name,
ColumnFamilyType type,
AbstractType<?> comp) |
CFMetaData(java.lang.String keyspace,
java.lang.String name,
ColumnFamilyType type,
AbstractType<?> comp,
AbstractType<?> subcc) |
CFMetaData(java.lang.String keyspace,
java.lang.String name,
ColumnFamilyType type,
AbstractType<?> comp,
AbstractType<?> subcc) |
ColumnDefinition(java.nio.ByteBuffer name,
AbstractType<?> validator,
IndexType indexType,
java.util.Map<java.lang.String,java.lang.String> indexOptions,
java.lang.String indexName,
java.lang.Integer componentIndex,
ColumnDefinition.Type type) |
ColumnDefinition(java.nio.ByteBuffer name,
AbstractType<?> validator,
java.lang.Integer componentIndex,
ColumnDefinition.Type type) |
Modifier and Type | Method and Description |
---|---|
AbstractType<?> |
CFPropDefs.getComparator() |
AbstractType<?> |
SelectStatement.getComparator(java.lang.String keyspace) |
AbstractType<?> |
UpdateStatement.getComparator(java.lang.String keyspace) |
AbstractType<?> |
UpdateStatement.getKeyType(java.lang.String keyspace) |
AbstractType<?> |
CFPropDefs.getValidator() |
Modifier and Type | Method and Description |
---|---|
java.nio.ByteBuffer |
Term.getByteBuffer(AbstractType<?> validator,
java.util.List<java.nio.ByteBuffer> variables)
Returns the typed value, serialized to a ByteBuffer according to a
comparator/validator.
|
Modifier and Type | Field and Description |
---|---|
static AbstractType<?> |
CFDefinition.definitionType |
AbstractType<?> |
ColumnSpecification.type |
Modifier and Type | Method and Description |
---|---|
AbstractType<?> |
CQL3Type.getType() |
AbstractType<?> |
CQL3Type.Native.getType() |
AbstractType<?> |
CQL3Type.Custom.getType() |
AbstractType<?> |
CQL3Type.Collection.getType() |
Modifier and Type | Method and Description |
---|---|
<T> java.util.List<T> |
UntypedResultSet.Row.getList(java.lang.String column,
AbstractType<T> type) |
<K,V> java.util.Map<K,V> |
UntypedResultSet.Row.getMap(java.lang.String column,
AbstractType<K> keyType,
AbstractType<V> valueType) |
<K,V> java.util.Map<K,V> |
UntypedResultSet.Row.getMap(java.lang.String column,
AbstractType<K> keyType,
AbstractType<V> valueType) |
<T> java.util.Set<T> |
UntypedResultSet.Row.getSet(java.lang.String column,
AbstractType<T> type) |
Constructor and Description |
---|
ColumnIdentifier(java.nio.ByteBuffer key,
AbstractType type) |
ColumnSpecification(java.lang.String ksName,
java.lang.String cfName,
ColumnIdentifier name,
AbstractType<?> type) |
CQL3Type.Custom(AbstractType<?> type) |
Modifier and Type | Field and Description |
---|---|
AbstractType<?> |
AbstractFunction.returnType |
Modifier and Type | Field and Description |
---|---|
java.util.List<AbstractType<?>> |
AbstractFunction.argsType |
Modifier and Type | Method and Description |
---|---|
static AbstractType<?> |
Functions.getReturnType(java.lang.String functionName,
java.lang.String ksName,
java.lang.String cfName) |
AbstractType<?> |
AbstractFunction.returnType() |
AbstractType<?> |
Function.returnType() |
Modifier and Type | Method and Description |
---|---|
java.util.List<AbstractType<?>> |
AbstractFunction.argsType() |
java.util.List<AbstractType<?>> |
Function.argsType() |
Modifier and Type | Method and Description |
---|---|
static Function |
BytesConversionFcts.makeFromBlobFunction(AbstractType<?> toType) |
static Function |
BytesConversionFcts.makeToBlobFunction(AbstractType<?> fromType) |
Constructor and Description |
---|
AbstractFunction(java.lang.String name,
AbstractType<?> returnType,
AbstractType<?>... argsType) |
AbstractFunction(java.lang.String name,
AbstractType<?> returnType,
AbstractType<?>... argsType) |
Modifier and Type | Field and Description |
---|---|
AbstractType<?> |
CreateTableStatement.comparator |
Modifier and Type | Field and Description |
---|---|
AbstractType |
Memtable.initialComparator |
Modifier and Type | Method and Description |
---|---|
AbstractType<?> |
AtomicSortedColumns.getComparator() |
AbstractType<?> |
ColumnFamily.getComparator() |
AbstractType<?> |
ColumnFamilyStore.getComparator() |
AbstractType<?> |
TreeMapBackedSortedColumns.getComparator() |
static AbstractType<?> |
SuperColumns.getComparatorFor(CFMetaData metadata,
boolean subColumn) |
static AbstractType<?> |
SuperColumns.getComparatorFor(CFMetaData metadata,
java.nio.ByteBuffer superColumn) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
Column.getString(AbstractType<?> comparator) |
java.lang.String |
CounterColumn.getString(AbstractType<?> comparator) |
java.lang.String |
ExpiringColumn.getString(AbstractType<?> comparator) |
Constructor and Description |
---|
DataRange.Paging(AbstractBounds<RowPosition> range,
SliceQueryFilter filter,
java.nio.ByteBuffer columnStart,
java.nio.ByteBuffer columnFinish,
AbstractType<?> comparator) |
Modifier and Type | Method and Description |
---|---|
AbstractType<?> |
LazilyCompactedRow.getComparator() |
Modifier and Type | Method and Description |
---|---|
ColumnCounter |
IDiskAtomFilter.columnCounter(AbstractType<?> comparator,
long now) |
ColumnCounter |
NamesQueryFilter.columnCounter(AbstractType<?> comparator,
long now) |
ColumnCounter |
SliceQueryFilter.columnCounter(AbstractType<?> comparator,
long now) |
NamesQueryFilter |
NamesQueryFilter.Serializer.deserialize(java.io.DataInput in,
int version,
AbstractType comparator) |
IDiskAtomFilter |
IDiskAtomFilter.Serializer.deserialize(java.io.DataInput in,
int version,
AbstractType<?> comparator) |
java.util.Comparator<Column> |
IDiskAtomFilter.getColumnComparator(AbstractType<?> comparator) |
java.util.Comparator<Column> |
NamesQueryFilter.getColumnComparator(AbstractType<?> comparator) |
java.util.Comparator<Column> |
SliceQueryFilter.getColumnComparator(AbstractType<?> comparator) |
boolean |
ColumnSlice.isAlwaysEmpty(AbstractType<?> comparator,
boolean reversed) |
SliceQueryFilter |
SliceQueryFilter.withUpdatedStart(java.nio.ByteBuffer newStart,
AbstractType<?> comparator) |
Modifier and Type | Field and Description |
---|---|
static AbstractType<?> |
SecondaryIndex.keyComparator |
Modifier and Type | Method and Description |
---|---|
protected abstract AbstractType |
AbstractSimplePerColumnSecondaryIndex.getExpressionComparator() |
static AbstractType<?> |
SecondaryIndex.getIndexComparator(CFMetaData baseMetadata,
ColumnDefinition cdef)
Returns the index comparator for index backed by CFS, or null.
|
Modifier and Type | Method and Description |
---|---|
protected AbstractType |
CompositesIndex.getExpressionComparator() |
Modifier and Type | Method and Description |
---|---|
protected AbstractType |
KeysIndex.getExpressionComparator() |
Modifier and Type | Class and Description |
---|---|
class |
AbstractCommutativeType |
class |
AbstractCompositeType
A class avoiding class duplication between CompositeType and
DynamicCompositeType.
|
class |
AsciiType |
class |
BooleanType |
class |
BytesType |
class |
CollectionType<T>
The abstract validator that is the base for maps, sets and lists.
|
class |
ColumnToCollectionType |
class |
CompositeType |
class |
CounterColumnType |
class |
DateType |
class |
DecimalType |
class |
DoubleType |
class |
DynamicCompositeType |
class |
EmptyType
A type that only accept empty data.
|
class |
FloatType |
class |
InetAddressType |
class |
Int32Type |
class |
IntegerType |
class |
LexicalUUIDType |
class |
ListType<T> |
class |
LocalByPartionerType<T extends Token>
for sorting columns representing row keys in the row ordering as determined by a partitioner.
|
class |
LongType |
class |
MapType<K,V> |
class |
ReversedType<T> |
class |
SetType<T> |
class |
TimestampType
Type for date-time values.
|
class |
TimeUUIDType |
class |
UTF8Type |
class |
UUIDType
Compares UUIDs using the following criteria:
- if count of supplied bytes is less than 16, compare counts - compare UUID version fields - nil UUID is always lesser - compare timestamps if both are time-based - compare lexically, unsigned msb-to-lsb comparison |
Modifier and Type | Field and Description |
---|---|
AbstractType<T> |
ReversedType.baseType |
AbstractType<?> |
AbstractCompositeType.CompositeComponent.comparator |
AbstractType<T> |
ListType.elements |
AbstractType<T> |
SetType.elements |
AbstractType<K> |
MapType.keys |
AbstractType<V> |
MapType.values |
Modifier and Type | Field and Description |
---|---|
java.util.List<AbstractType<?>> |
CompositeType.types |
Modifier and Type | Method and Description |
---|---|
AbstractType<?> |
AbstractCompositeType.ParsedComparator.getAbstractType() |
protected abstract AbstractType<?> |
AbstractCompositeType.getAndAppendComparator(int i,
java.nio.ByteBuffer bb,
java.lang.StringBuilder sb)
Adds type information from @param bb to @param sb.
|
protected AbstractType<?> |
CompositeType.getAndAppendComparator(int i,
java.nio.ByteBuffer bb,
java.lang.StringBuilder sb) |
protected AbstractType<?> |
DynamicCompositeType.getAndAppendComparator(int i,
java.nio.ByteBuffer bb,
java.lang.StringBuilder sb) |
protected abstract AbstractType<?> |
AbstractCompositeType.getComparator(int i,
java.nio.ByteBuffer bb) |
protected AbstractType<?> |
CompositeType.getComparator(int i,
java.nio.ByteBuffer bb) |
protected AbstractType<?> |
DynamicCompositeType.getComparator(int i,
java.nio.ByteBuffer bb) |
protected abstract AbstractType<?> |
AbstractCompositeType.getComparator(int i,
java.nio.ByteBuffer bb1,
java.nio.ByteBuffer bb2)
Adds DynamicCompositeType type information from @param bb1 to @param bb2.
|
protected AbstractType<?> |
CompositeType.getComparator(int i,
java.nio.ByteBuffer bb1,
java.nio.ByteBuffer bb2) |
protected AbstractType<?> |
DynamicCompositeType.getComparator(int i,
java.nio.ByteBuffer bb1,
java.nio.ByteBuffer bb2) |
abstract AbstractType<?> |
CollectionType.nameComparator() |
AbstractType<java.util.UUID> |
ListType.nameComparator() |
AbstractType<K> |
MapType.nameComparator() |
AbstractType<T> |
SetType.nameComparator() |
AbstractType<?> |
TypeParser.parse()
Parse an AbstractType from current position of this parser.
|
static AbstractType<?> |
TypeParser.parse(java.lang.CharSequence compareWith) |
static AbstractType<?> |
TypeParser.parse(java.lang.String str)
Parse a string containing an type definition.
|
static AbstractType<?> |
AbstractType.parseDefaultParameters(AbstractType<?> baseType,
TypeParser parser) |
protected abstract AbstractType<?> |
AbstractCompositeType.validateComparator(int i,
java.nio.ByteBuffer bb)
Like getComparator, but validates that @param i does not exceed the defined range
|
protected AbstractType<?> |
CompositeType.validateComparator(int i,
java.nio.ByteBuffer bb) |
protected AbstractType<?> |
DynamicCompositeType.validateComparator(int i,
java.nio.ByteBuffer bb) |
abstract AbstractType<?> |
CollectionType.valueComparator() |
AbstractType<T> |
ListType.valueComparator() |
AbstractType<V> |
MapType.valueComparator() |
AbstractType<?> |
SetType.valueComparator() |
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.Byte,AbstractType<?>> |
TypeParser.getAliasParameters() |
java.util.List<AbstractType<?>> |
AbstractType.getComponents()
Return a list of the "subcomponents" this type has.
|
java.util.List<AbstractType<?>> |
CompositeType.getComponents() |
java.util.List<AbstractType<?>> |
TypeParser.getTypeParameters() |
Modifier and Type | Method and Description |
---|---|
static CompositeType |
CompositeType.getInstance(AbstractType... types) |
static <K,V> MapType<K,V> |
MapType.getInstance(AbstractType<K> keys,
AbstractType<V> values) |
static <K,V> MapType<K,V> |
MapType.getInstance(AbstractType<K> keys,
AbstractType<V> values) |
static <T> ListType<T> |
ListType.getInstance(AbstractType<T> elements) |
static <T> ReversedType<T> |
ReversedType.getInstance(AbstractType<T> baseType) |
static <T> SetType<T> |
SetType.getInstance(AbstractType<T> elements) |
static java.lang.String |
TypeParser.getShortName(AbstractType<?> type) |
boolean |
AbstractType.isCompatibleWith(AbstractType<?> previous)
Returns true if this comparator is compatible with the provided
previous comparator, that is if previous can safely be replaced by this.
|
boolean |
BytesType.isCompatibleWith(AbstractType<?> previous) |
boolean |
ColumnToCollectionType.isCompatibleWith(AbstractType<?> previous) |
boolean |
CompositeType.isCompatibleWith(AbstractType<?> previous) |
boolean |
DateType.isCompatibleWith(AbstractType<?> previous) |
boolean |
DynamicCompositeType.isCompatibleWith(AbstractType<?> previous) |
boolean |
TimestampType.isCompatibleWith(AbstractType<?> previous) |
boolean |
UTF8Type.isCompatibleWith(AbstractType<?> previous) |
boolean |
AbstractType.isValueCompatibleWith(AbstractType<?> previous)
Returns true if values of the previous AbstracType can be read by the this
AbsractType.
|
boolean |
BytesType.isValueCompatibleWith(AbstractType<?> previous) |
boolean |
CompositeType.isValueCompatibleWith(AbstractType<?> previous) |
static AbstractType<?> |
AbstractType.parseDefaultParameters(AbstractType<?> baseType,
TypeParser parser) |
Modifier and Type | Method and Description |
---|---|
static CompositeType |
CompositeType.getInstance(java.util.List<AbstractType<?>> types) |
static DynamicCompositeType |
DynamicCompositeType.getInstance(java.util.Map<java.lang.Byte,AbstractType<?>> aliases) |
static java.lang.String |
TypeParser.stringifyAliasesParameters(java.util.Map<java.lang.Byte,AbstractType<?>> aliases)
Helper function to ease the writing of AbstractType.toString() methods.
|
static java.lang.String |
TypeParser.stringifyTypeParameters(java.util.List<AbstractType<?>> types)
Helper function to ease the writing of AbstractType.toString() methods.
|
Constructor and Description |
---|
AbstractCompositeType.CompositeComponent(AbstractType<?> comparator,
java.nio.ByteBuffer value) |
SetType(AbstractType<T> elements) |
Modifier and Type | Method and Description |
---|---|
AbstractType<?> |
AbstractByteOrderedPartitioner.getTokenValidator() |
AbstractType<?> |
IPartitioner.getTokenValidator() |
AbstractType<?> |
LocalPartitioner.getTokenValidator() |
AbstractType<?> |
Murmur3Partitioner.getTokenValidator() |
AbstractType<?> |
OrderPreservingPartitioner.getTokenValidator() |
AbstractType<?> |
RandomPartitioner.getTokenValidator() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
AbstractBounds.getString(AbstractType<?> keyValidator) |
Constructor and Description |
---|
LocalPartitioner(AbstractType<?> comparator) |
LocalToken(AbstractType<?> comparator,
java.nio.ByteBuffer token) |
Modifier and Type | Method and Description |
---|---|
protected AbstractType |
AbstractCassandraStorage.parseType(java.lang.String type)
parse the string to a cassandra data type
|
Modifier and Type | Method and Description |
---|---|
protected java.util.Map<AbstractCassandraStorage.MarshallerType,AbstractType> |
AbstractCassandraStorage.getDefaultMarshallers(CfDef cfDef)
construct a map to store the mashaller type to cassandra data type mapping
|
protected java.util.Map<java.nio.ByteBuffer,AbstractType> |
AbstractCassandraStorage.getValidatorMap(CfDef cfDef)
get the validators
|
Modifier and Type | Method and Description |
---|---|
protected java.lang.Object |
AbstractCassandraStorage.cassandraToObj(AbstractType validator,
java.nio.ByteBuffer value) |
protected org.apache.pig.data.Tuple |
AbstractCassandraStorage.columnToTuple(Column col,
AbstractCassandraStorage.CfInfo cfInfo,
AbstractType comparator)
convert a column to a tuple
|
protected byte |
AbstractCassandraStorage.getPigType(AbstractType type)
get pig type for the cassandra data type
|
Modifier and Type | Method and Description |
---|---|
static SSTableMetadata.Collector |
SSTableMetadata.createCollector(AbstractType<?> columnNameComparator) |
static SSTableMetadata.Collector |
SSTableMetadata.createCollector(java.util.Collection<SSTableReader> sstables,
AbstractType<?> columnNameComparator,
int level) |
static java.util.Comparator<IndexHelper.IndexInfo> |
IndexHelper.getComparator(AbstractType<?> nameComparator,
boolean reversed) |
static int |
IndexHelper.indexFor(java.nio.ByteBuffer name,
java.util.List<IndexHelper.IndexInfo> indexList,
AbstractType<?> comparator,
boolean reversed,
int lastIndex)
The index of the IndexInfo in which a scan starting with @name should begin.
|
static java.util.List<java.nio.ByteBuffer> |
ColumnNameHelper.maxComponents(java.util.List<java.nio.ByteBuffer> maxSeen,
java.nio.ByteBuffer candidate,
AbstractType<?> comparator)
finds the max column name(s)
if comparator is of CompositeType, candidate will be split into its components, and each
component is compared to the component on the same place in maxSeen, and then returning the list
with the max columns.
|
static java.util.List<java.nio.ByteBuffer> |
ColumnNameHelper.mergeMax(java.util.List<java.nio.ByteBuffer> maxColumnNames,
java.util.List<java.nio.ByteBuffer> candidates,
AbstractType<?> columnNameComparator)
if columnNameComparator is CompositeType the columns are compared by components using the subcomparator
on the same position.
|
static java.util.List<java.nio.ByteBuffer> |
ColumnNameHelper.mergeMin(java.util.List<java.nio.ByteBuffer> minColumnNames,
java.util.List<java.nio.ByteBuffer> candidates,
AbstractType<?> columnNameComparator)
if columnNameComparator is CompositeType the columns are compared by components using the subcomparator
on the same position.
|
static java.util.List<java.nio.ByteBuffer> |
ColumnNameHelper.minComponents(java.util.List<java.nio.ByteBuffer> minSeen,
java.nio.ByteBuffer candidate,
AbstractType<?> comparator)
finds the min column name(s)
if comparator is of CompositeType, candidate will be split into its components, and each
component is compared to the component on the same place in minSeen, and then returning the list
with the min columns.
|
Constructor and Description |
---|
SSTableSimpleUnsortedWriter(java.io.File directory,
IPartitioner partitioner,
java.lang.String keyspace,
java.lang.String columnFamily,
AbstractType<?> comparator,
AbstractType<?> subComparator,
int bufferSizeInMB) |
SSTableSimpleUnsortedWriter(java.io.File directory,
IPartitioner partitioner,
java.lang.String keyspace,
java.lang.String columnFamily,
AbstractType<?> comparator,
AbstractType<?> subComparator,
int bufferSizeInMB) |
SSTableSimpleUnsortedWriter(java.io.File directory,
IPartitioner partitioner,
java.lang.String keyspace,
java.lang.String columnFamily,
AbstractType<?> comparator,
AbstractType<?> subComparator,
int bufferSizeInMB,
CompressionParameters compressParameters)
Create a new buffering writer.
|
SSTableSimpleUnsortedWriter(java.io.File directory,
IPartitioner partitioner,
java.lang.String keyspace,
java.lang.String columnFamily,
AbstractType<?> comparator,
AbstractType<?> subComparator,
int bufferSizeInMB,
CompressionParameters compressParameters)
Create a new buffering writer.
|
SSTableSimpleWriter(java.io.File directory,
IPartitioner partitioner,
java.lang.String keyspace,
java.lang.String columnFamily,
AbstractType<?> comparator,
AbstractType<?> subComparator)
Create a new writer.
|
SSTableSimpleWriter(java.io.File directory,
IPartitioner partitioner,
java.lang.String keyspace,
java.lang.String columnFamily,
AbstractType<?> comparator,
AbstractType<?> subComparator)
Create a new writer.
|
Modifier and Type | Method and Description |
---|---|
static AbstractType |
DataType.toType(Pair<DataType,java.lang.Object> entry) |
Modifier and Type | Method and Description |
---|---|
static Pair<DataType,java.lang.Object> |
DataType.fromType(AbstractType type) |
Copyright © 2014 The Apache Software Foundation