in cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/CassandraDataLayer.java [1134:1173]
private static void aliasLastModifiedTimestamp(List<SchemaFeature> requestedFeatures, String alias)
{
SchemaFeature featureAlias = new SchemaFeature()
{
@Override
public String optionName()
{
return SchemaFeatureSet.LAST_MODIFIED_TIMESTAMP.optionName();
}
@Override
public String fieldName()
{
return alias;
}
@Override
public DataType fieldDataType()
{
return SchemaFeatureSet.LAST_MODIFIED_TIMESTAMP.fieldDataType();
}
@Override
public RowBuilder decorate(RowBuilder builder)
{
return new LastModifiedTimestampDecorator(builder, alias);
}
@Override
public boolean fieldNullable()
{
return SchemaFeatureSet.LAST_MODIFIED_TIMESTAMP.fieldNullable();
}
};
int index = requestedFeatures.indexOf(SchemaFeatureSet.LAST_MODIFIED_TIMESTAMP);
if (index >= 0)
{
requestedFeatures.set(index, featureAlias);
}
}