Java 类com.datastax.driver.core.ResultSetFuture 实例源码
项目:vos_instagram_bots
文件:UsersIndex.java
/**
* executeAsyncInsert
* executes Insert Query asynchronously
* @param yearmonthday
* @param airportcode
* @param seqid
* @param userid
* @param lastactiveyearmonthday
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncInsert (
Object yearmonthday,
Object airportcode,
Object seqid,
Object userid,
Object lastactiveyearmonthday) throws Exception {
return
this.getQuery(kInsertName).executeAsync(
yearmonthday,
airportcode,
seqid,
userid,
lastactiveyearmonthday);
}
项目:vos_instagram
文件:Posts.java
/**
* executeAsyncInsertWithoutLocation
* executes InsertWithoutLocation Query asynchronously
* @param postid
* @param posttime
* @param photoid
* @param caption
* @param userid
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncInsertWithoutLocation (
Object postid,
Object posttime,
Object photoid,
Object caption,
Object userid) throws Exception {
return
this.getQuery(kInsertWithoutLocationName).executeAsync(
postid,
posttime,
photoid,
caption,
userid);
}
项目:vos_instagram
文件:DailyUsersLogs.java
/**
* executeAsyncInsert
* executes Insert Query asynchronously
* @param yearmonthdayuserid
* @param logtime
* @param requestid
* @param controllername
* @param request
* @param responsestatuscode
* @param response
* @param runtimemilliseconds
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncInsert (
Object yearmonthdayuserid,
Object logtime,
Object requestid,
Object controllername,
Object request,
Object responsestatuscode,
Object response,
Object runtimemilliseconds) throws Exception {
return
this.getQuery(kInsertName).executeAsync(
yearmonthdayuserid,
logtime,
requestid,
controllername,
request,
responsestatuscode,
response,
runtimemilliseconds);
}
项目:vos_whatsapp
文件:UserChats.java
/**
* executeAsyncInsert
* executes Insert Query asynchronously
* @param userid
* @param messagetime
* @param senderuserid
* @param receiveruserid
* @param messageid
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncInsert (
Object userid,
Object messagetime,
Object senderuserid,
Object receiveruserid,
Object messageid) throws Exception {
return
this.getQuery(kInsertName).executeAsync(
userid,
messagetime,
senderuserid,
receiveruserid,
messageid);
}
项目:vos_instagram_jobs
文件:DailyUsersLogs.java
/**
* executeAsyncInsert
* executes Insert Query asynchronously
* @param yearmonthdayuserid
* @param logtime
* @param requestid
* @param controllername
* @param request
* @param responsestatuscode
* @param response
* @param runtimemilliseconds
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncInsert (
Object yearmonthdayuserid,
Object logtime,
Object requestid,
Object controllername,
Object request,
Object responsestatuscode,
Object response,
Object runtimemilliseconds) throws Exception {
return
this.getQuery(kInsertName).executeAsync(
yearmonthdayuserid,
logtime,
requestid,
controllername,
request,
responsestatuscode,
response,
runtimemilliseconds);
}
项目:vos_instagram_bots
文件:Cities.java
/**
* executeAsyncInsert
* executes Insert Query asynchronously
* @param airportcode
* @param latitude
* @param longitude
* @param continent
* @param continentcode
* @param country
* @param countrycode
* @param city
* @param populationinmillions
* @param addedyearmonthday
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncInsert (
Object airportcode,
Object latitude,
Object longitude,
Object continent,
Object continentcode,
Object country,
Object countrycode,
Object city,
Object populationinmillions,
Object addedyearmonthday) throws Exception {
return
this.getQuery(kInsertName).executeAsync(
airportcode,
latitude,
longitude,
continent,
continentcode,
country,
countrycode,
city,
populationinmillions,
addedyearmonthday);
}
项目:vos_vangav_analytics_writer
文件:MonthlyActionCounters.java
/**
* executeAsyncIncrement
* executes Increment Query asynchronously
* @param yearmonthaction
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncIncrement (
Object yearmonthaction) throws Exception {
return
this.getQuery(kIncrementName).executeAsync(
yearmonthaction);
}
项目:vos_instagram
文件:PostLikesTime.java
/**
* executeAsyncSelect
* executes Select Query asynchronously
* @param postid
* @param userid
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncSelect (
Object postid,
Object userid) throws Exception {
return
this.getQuery(kSelectName).executeAsync(
postid,
userid);
}
项目:vos_instagram
文件:PostLikesCount.java
/**
* executeAsyncIncrement
* executes Increment Query asynchronously
* @param postid
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncIncrement (
Object postid) throws Exception {
return
this.getQuery(kIncrementName).executeAsync(
postid);
}
项目:vos_vangav_analytics_writer
文件:AnnualActionCounters.java
/**
* executeAsyncSelect
* executes Select Query asynchronously
* @param yearaction
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncSelect (
Object yearaction) throws Exception {
return
this.getQuery(kSelectName).executeAsync(
yearaction);
}
项目:vos_instagram_bots
文件:PostsCount.java
/**
* executeAsyncSelect
* executes Select Query asynchronously
* @param yearmonthdayairportcode
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncSelect (
Object yearmonthdayairportcode) throws Exception {
return
this.getQuery(kSelectName).executeAsync(
yearmonthdayairportcode);
}
项目:vos_instagram_jobs
文件:PostLikesTime.java
/**
* executeAsyncDelete
* executes Delete Query asynchronously
* @param postid
* @param userid
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncDelete (
Object postid,
Object userid) throws Exception {
return
this.getQuery(kDeleteName).executeAsync(
postid,
userid);
}
项目:vos_instagram
文件:DeviceTokens.java
/**
* executeAsyncSelect
* executes Select Query asynchronously
* @param devicetoken
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncSelect (
Object devicetoken) throws Exception {
return
this.getQuery(kSelectName).executeAsync(
devicetoken);
}
项目:vos_instagram
文件:UsersIndex.java
/**
* executeAsyncSelectAtOrAfterLimit
* executes SelectAtOrAfterLimit Query asynchronously
* @param yearmonthday
* @param registrationtime
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncSelectAtOrAfterLimit (
Object yearmonthday,
Object registrationtime) throws Exception {
return
this.getQuery(kSelectAtOrAfterLimitName).executeAsync(
yearmonthday,
registrationtime);
}
项目:vos_instagram_jobs
文件:FollowerCount.java
/**
* executeAsyncDecrement
* executes Decrement Query asynchronously
* @param userid
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncDecrement (
Object userid) throws Exception {
return
this.getQuery(kDecrementName).executeAsync(
userid);
}
项目:vos_instagram
文件:RefreshTokens.java
/**
* executeAsyncSelect
* executes Select Query asynchronously
* @param userid
* @param devicetoken
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncSelect (
Object userid,
Object devicetoken) throws Exception {
return
this.getQuery(kSelectName).executeAsync(
userid,
devicetoken);
}
项目:vos_instagram_bots
文件:UsersIndex.java
/**
* executeAsyncSelectUser
* executes SelectUser Query asynchronously
* @param yearmonthday
* @param airportcode
* @param seqid
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncSelectUser (
Object yearmonthday,
Object airportcode,
Object seqid) throws Exception {
return
this.getQuery(kSelectUserName).executeAsync(
yearmonthday,
airportcode,
seqid);
}
项目:vos_instagram
文件:UserPosts.java
/**
* executeAsyncSelectRecentLimit
* executes SelectRecentLimit Query asynchronously
* @param userid
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncSelectRecentLimit (
Object userid) throws Exception {
return
this.getQuery(kSelectRecentLimitName).executeAsync(
userid);
}
项目:vos_instagram
文件:AnnualRegionalCounters.java
/**
* executeAsyncSelect
* executes Select Query asynchronously
* @param yearregion
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncSelect (
Object yearregion) throws Exception {
return
this.getQuery(kSelectName).executeAsync(
yearregion);
}
项目:vos_instagram_jobs
文件:UsersInfo.java
/**
* executeAsyncSetProfilePictureId
* executes SetProfilePictureId Query asynchronously
* @param profilepictureid
* @param userid
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncSetProfilePictureId (
Object profilepictureid,
Object userid) throws Exception {
return
this.getQuery(kSetProfilePictureIdName).executeAsync(
profilepictureid,
userid);
}
项目:vos_instagram
文件:UsersIndex.java
/**
* executeAsyncSelect
* executes Select Query asynchronously
* @param yearmonthday
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncSelect (
Object yearmonthday) throws Exception {
return
this.getQuery(kSelectName).executeAsync(
yearmonthday);
}
项目:iotplatform
文件:BaseRelationDao.java
@Override
public ListenableFuture<Boolean> deleteOutboundRelations(EntityId entity) {
BoundStatement stmt = getDeleteAllByEntityStmt().bind()
.setUUID(0, entity.getId())
.setString(1, entity.getEntityType().name());
ResultSetFuture future = executeAsyncWrite(stmt);
return getBooleanListenableFuture(future);
}
项目:vos_instagram
文件:PostComments.java
/**
* executeAsyncSelectAtOrBeforeTimeLimit
* executes SelectAtOrBeforeTimeLimit Query asynchronously
* @param postid
* @param commenttime
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncSelectAtOrBeforeTimeLimit (
Object postid,
Object commenttime) throws Exception {
return
this.getQuery(kSelectAtOrBeforeTimeLimitName).executeAsync(
postid,
commenttime);
}
项目:vos_instagram_jobs
文件:HourlyControllersErrorLogs.java
/**
* executeAsyncSelect
* executes Select Query asynchronously
* @param yearmonthdayhourcontroller
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncSelect (
Object yearmonthdayhourcontroller) throws Exception {
return
this.getQuery(kSelectName).executeAsync(
yearmonthdayhourcontroller);
}
项目:vos_whatsapp
文件:UserChats.java
/**
* executeAsyncSelectRecent
* executes SelectRecent Query asynchronously
* @param userid
* @param messagetime
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncSelectRecent (
Object userid,
Object messagetime) throws Exception {
return
this.getQuery(kSelectRecentName).executeAsync(
userid,
messagetime);
}
项目:vos_instagram
文件:PostsRankWorld.java
/**
* executeAsyncInsert
* executes Insert Query asynchronously
* @param yearweek
* @param rank
* @param postid
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncInsert (
Object yearweek,
Object rank,
Object postid) throws Exception {
return
this.getQuery(kInsertName).executeAsync(
yearweek,
rank,
postid);
}
项目:vos_instagram_jobs
文件:Posts.java
/**
* executeAsyncSelectPhotoId
* executes SelectPhotoId Query asynchronously
* @param postid
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncSelectPhotoId (
Object postid) throws Exception {
return
this.getQuery(kSelectPhotoIdName).executeAsync(
postid);
}
项目:vos_instagram
文件:DailyRegionalCounters.java
/**
* executeAsyncIncrementReceivedComments
* executes IncrementReceivedComments Query asynchronously
* @param yearmonthdayregion
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncIncrementReceivedComments (
Object yearmonthdayregion) throws Exception {
return
this.getQuery(kIncrementReceivedCommentsName).executeAsync(
yearmonthdayregion);
}
项目:vos_instagram
文件:AccessTokens.java
/**
* executeAsyncUpdate
* executes Update Query asynchronously
* @param accesstoken
* @param timestamp
* @param userid
* @param devicetoken
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncUpdate (
Object accesstoken,
Object timestamp,
Object userid,
Object devicetoken) throws Exception {
return
this.getQuery(kUpdateName).executeAsync(
accesstoken,
timestamp,
userid,
devicetoken);
}
项目:vos_instagram
文件:PostComments.java
/**
* executeAsyncInsert
* executes Insert Query asynchronously
* @param postid
* @param commenttime
* @param userid
* @param comment
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncInsert (
Object postid,
Object commenttime,
Object userid,
Object comment) throws Exception {
return
this.getQuery(kInsertName).executeAsync(
postid,
commenttime,
userid,
comment);
}
项目:vos_instagram
文件:UserFeedPosts.java
/**
* executeAsyncSelectRecentLimit
* executes SelectRecentLimit Query asynchronously
* @param userid
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncSelectRecentLimit (
Object userid) throws Exception {
return
this.getQuery(kSelectRecentLimitName).executeAsync(
userid);
}
项目:vos_instagram
文件:HourlyCurrentJobs.java
/**
* executeAsyncSelectEarliestLimit
* executes SelectEarliestLimit Query asynchronously
* @param yearmonthdayhour
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncSelectEarliestLimit (
Object yearmonthdayhour) throws Exception {
return
this.getQuery(kSelectEarliestLimitName).executeAsync(
yearmonthdayhour);
}
项目:vos_instagram_jobs
文件:UsersIndex.java
/**
* executeAsyncSelectAfterLimit
* executes SelectAfterLimit Query asynchronously
* @param yearmonthday
* @param registrationtime
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncSelectAfterLimit (
Object yearmonthday,
Object registrationtime) throws Exception {
return
this.getQuery(kSelectAfterLimitName).executeAsync(
yearmonthday,
registrationtime);
}
项目:vos_instagram
文件:Following.java
/**
* executeAsyncSelectAtOrBeforeTimeLimit
* executes SelectAtOrBeforeTimeLimit Query asynchronously
* @param userid
* @param followingtime
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncSelectAtOrBeforeTimeLimit (
Object userid,
Object followingtime) throws Exception {
return
this.getQuery(kSelectAtOrBeforeTimeLimitName).executeAsync(
userid,
followingtime);
}
项目:vos_instagram_jobs
文件:CurrentJobs.java
/**
* executeAsyncInsert
* executes Insert Query asynchronously
* @param jobid
* @param jobtime
* @param job
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncInsert (
Object jobid,
Object jobtime,
Object job) throws Exception {
return
this.getQuery(kInsertName).executeAsync(
jobid,
jobtime,
job);
}
项目:vos_instagram
文件:PostLikesTime.java
/**
* executeAsyncInsert
* executes Insert Query asynchronously
* @param postid
* @param userid
* @param liketime
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncInsert (
Object postid,
Object userid,
Object liketime) throws Exception {
return
this.getQuery(kInsertName).executeAsync(
postid,
userid,
liketime);
}
项目:vos_instagram_bots
文件:Cities.java
/**
* executeAsyncSelectAll
* executes SelectAll Query asynchronously
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncSelectAll (
) throws Exception {
return
this.getQuery(kSelectAllName).executeAsync();
}
项目:vos_instagram
文件:UsersRankGrid.java
/**
* executeAsyncSelectTopEqual
* executes SelectTopEqual Query asynchronously
* @param yearweekgridid
* @param rank
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncSelectTopEqual (
Object yearweekgridid,
Object rank) throws Exception {
return
this.getQuery(kSelectTopEqualName).executeAsync(
yearweekgridid,
rank);
}
项目:vos_instagram_jobs
文件:FollowingTime.java
/**
* executeAsyncSelect
* executes Select Query asynchronously
* @param userid
* @param followinguserid
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncSelect (
Object userid,
Object followinguserid) throws Exception {
return
this.getQuery(kSelectName).executeAsync(
userid,
followinguserid);
}
项目:vos_instagram
文件:UsersInfo.java
/**
* executeAsyncSelectName
* executes SelectName Query asynchronously
* @param userid
* @return ResultSetFuture
* @throws Exception
*/
public ResultSetFuture executeAsyncSelectName (
Object userid) throws Exception {
return
this.getQuery(kSelectNameName).executeAsync(
userid);
}