Examples of QueryState

Examples of org.apache.cassandra.service.QueryState

286
287
288
289
290
291
292
293
294
295
296
        {
            try
            {
                assert request.connection() instanceof ServerConnection;
                ServerConnection connection = (ServerConnection)request.connection();
                QueryState qstate = connection.validateNewMessage(request.type, connection.getVersion(), request.getStreamId());

                logger.debug("Received: {}, v={}", request, connection.getVersion());

                Response response = request.execute(qstate);
                response.setStreamId(request.getStreamId());
View Full Code Here

Examples of org.apache.cassandra.service.QueryState

404
405
406
407
408
409
410
411
412
413
414
            try
            {
                assert request.connection() instanceof ServerConnection;
                connection = (ServerConnection)request.connection();
                QueryState qstate = connection.validateNewMessage(request.type, connection.getVersion(), request.getStreamId());

                logger.debug("Received: {}, v={}", request, connection.getVersion());

                response = request.execute(qstate);
                response.setStreamId(request.getStreamId());
View Full Code Here

Examples of org.apache.cassandra.service.QueryState

116
117
118
119
120
121
122
123
124
125
126
    public static UntypedResultSet process(String query, ConsistencyLevel cl) throws RequestExecutionException
    {
        try
        {
            QueryState state = new QueryState(new ClientState(true));
            ResultMessage result = process(query, cl, state);
            if (result instanceof ResultMessage.Rows)
                return new UntypedResultSet(((ResultMessage.Rows)result).result);
            else
                return null;
View Full Code Here

Examples of org.apache.cassandra.service.QueryState

134
135
136
137
138
139
140
141
142
143
144
    public static UntypedResultSet processInternal(String query)
    {
        try
        {
            ClientState state = new ClientState(true);
            QueryState qState = new QueryState(state);
            state.setKeyspace(Table.SYSTEM_KS);
            CQLStatement statement = getStatement(query, state).statement;
            statement.validate(state);
            ResultMessage result = statement.executeInternal(qState);
            if (result instanceof ResultMessage.Rows)
View Full Code Here

Examples of org.apache.cassandra.service.QueryState

199
200
201
202
203
204
205
206
207
208
209
    public static UntypedResultSet processInternal(String query)
    {
        try
        {
            ClientState state = ClientState.forInternalCalls();
            QueryState qState = new QueryState(state);
            state.setKeyspace(Keyspace.SYSTEM_KS);
            CQLStatement statement = getStatement(query, state).statement;
            statement.validate(state);
            ResultMessage result = statement.executeInternal(qState);
            if (result instanceof ResultMessage.Rows)
View Full Code Here

Examples of org.apache.drill.exec.proto.UserBitShared.QueryResult.QueryState

126
127
128
129
130
131
132
133
134
      updateCache();
    }
  }

  public void updateCache(){
    QueryState queryState = foreman.getQueryState();
    boolean fullStatus = queryState == QueryState.COMPLETED || queryState == QueryState.FAILED;
    profileCache.put(queryId, getAsProfile(fullStatus));
  }
View Full Code Here

Examples of org.apache.tajo.TajoProtos.QueryState

133
134
135
136
137
138
139
140
141
142
143
    stateMachine = stateMachineFactory.make(this);
  }

  public float getProgress() {
    QueryState state = getStateMachine().getCurrentState();
    if (state == QueryState.QUERY_SUCCEEDED) {
      return 1.0f;
    } else {
      int idx = 0;
      List<SubQuery> tempSubQueries = new ArrayList<SubQuery>();
View Full Code Here

Examples of org.apache.tajo.TajoProtos.QueryState

444
445
446
447
448
449
450
451
452
453
454
  @Override
  public void handle(QueryEvent event) {
    LOG.info("Processing " + event.getQueryId() + " of type " + event.getType());
    try {
      writeLock.lock();
      QueryState oldState = getState();
      try {
        getStateMachine().doTransition(event.getType(), event);
      } catch (InvalidStateTransitonException e) {
        LOG.error("Can't handle this event at current state", e);
        eventHandler.handle(new QueryEvent(this.id,
View Full Code Here

Examples of org.apache.tajo.TajoProtos.QueryState

214
215
216
217
218
219
220
221
222
223
224
    stateMachine = stateMachineFactory.make(this);
  }

  public float getProgress() {
    QueryState state = getStateMachine().getCurrentState();
    if (state == QueryState.QUERY_SUCCEEDED) {
      return 1.0f;
    } else {
      int idx = 0;
      List<SubQuery> tempSubQueries = new ArrayList<SubQuery>();
View Full Code Here

Examples of org.apache.tajo.TajoProtos.QueryState

679
680
681
682
683
684
685
686
687
688
689
  @Override
  public void handle(QueryEvent event) {
    LOG.info("Processing " + event.getQueryId() + " of type " + event.getType());
    try {
      writeLock.lock();
      QueryState oldState = getState();
      try {
        getStateMachine().doTransition(event.getType(), event);
      } catch (InvalidStateTransitonException e) {
        LOG.error("Can't handle this event at current state", e);
        eventHandler.handle(new QueryEvent(this.id, QueryEventType.INTERNAL_ERROR));
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.