--amend .
This commit is contained in:
parent
71e84da3bd
commit
efb26b8618
2 changed files with 39 additions and 1 deletions
38
NOTES
Normal file
38
NOTES
Normal file
|
@ -0,0 +1,38 @@
|
|||
primitive types have default values, (e.g. boolean, int, ...) but primative wrapper classes do not and can be null (e.g. Boolean, Integer, ...)
|
||||
|
||||
create table wal {
|
||||
id timeuuid,
|
||||
follows timeuuid,
|
||||
read <Counting Quotient Filter, Set<{keyspace, col, schema generation, timestamp}>>
|
||||
write <Counting Quotient Filter, Set<{keyspace, col, schema generation, timestamp}>>
|
||||
primary key (id, follows)
|
||||
}
|
||||
begin:
|
||||
- insert into wal (timeuuid, parent timeuuid,
|
||||
|
||||
|
||||
|
||||
// NOTE: Update operations have no meaning when they only contain primary key components, so
|
||||
// given that `properties` is ordered with the keys first if we find that the last element
|
||||
// is either a partition key or clustering column then we know we should just skip this operation.
|
||||
ColumnType ct = ((HelenusProperty) properties.toArray()[properties.size() - 1]).getColumnType();
|
||||
if (ct != ColumnType.PARTITION_KEY && ct != ColumnType.CLUSTERING_COLUMN) {
|
||||
return;
|
||||
}
|
||||
|
||||
|
||||
|
||||
public Stream<E> sync() {
|
||||
ListenableFuture<Stream<E>> future = async();
|
||||
Futures.addCallback(future, new FutureCallback<String>() {
|
||||
@Override
|
||||
public void onSuccess(String contents) {
|
||||
//...process web site contents
|
||||
}
|
||||
|
||||
@Override
|
||||
public void onFailure(Throwable throwable) {
|
||||
log.error("Exception in task", throwable);
|
||||
}
|
||||
});
|
||||
}
|
2
pom.xml
2
pom.xml
|
@ -5,7 +5,7 @@
|
|||
<modelVersion>4.0.0</modelVersion>
|
||||
<groupId>net.helenus</groupId>
|
||||
<artifactId>helenus-core</artifactId>
|
||||
<version>2.0.7-SNAPSHOT</version>
|
||||
<version>2.0.8-SNAPSHOT</version>
|
||||
<packaging>jar</packaging>
|
||||
|
||||
<name>helenus</name>
|
||||
|
|
Loading…
Reference in a new issue