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);
}