Package org.apache.accumulo.server.master.state

Examples of org.apache.accumulo.server.master.state.TabletState.ordinal()

1404
1405
1406
1407
1408
1409
1410
1411
1412
1413
1414
                  break;
                case ASSIGNED:
                  break;
              }
            }
            counts[state.ordinal()]++;
          }
         
          flushChanges(destinations, assignments, assigned, assignedToDeadServers, unassigned);
         
          // provide stats after flushing changes to avoid race conditions w/ delete table
View Full Code Here
1414
1415
1416
1417
1418
1419
1420
1421
1422
1423
1424
          // provide stats after flushing changes to avoid race conditions w/ delete table
          stats.end();
         
          // Report changes
          for (TabletState state : TabletState.values()) {
            int i = state.ordinal();
            if (counts[i] > 0 && counts[i] != oldCounts[i]) {
              nextEvent.event("[%s]: %d tablets are %s", store.name(), counts[i], state.name());
            }
          }
          log.debug(String.format("[%s]: scan time %.2f seconds", store.name(), stats.getScanTime() / 1000.));
View Full Code Here
1406
1407
1408
1409
1410
1411
1412
1413
1414
1415
1416
                  break;
                case ASSIGNED:
                  break;
              }
            }
            counts[state.ordinal()]++;
          }
         
          flushChanges(destinations, assignments, assigned, assignedToDeadServers, unassigned);
         
          // provide stats after flushing changes to avoid race conditions w/ delete table
View Full Code Here
1416
1417
1418
1419
1420
1421
1422
1423
1424
1425
1426
          // provide stats after flushing changes to avoid race conditions w/ delete table
          stats.end();
         
          // Report changes
          for (TabletState state : TabletState.values()) {
            int i = state.ordinal();
            if (counts[i] > 0 && counts[i] != oldCounts[i]) {
              nextEvent.event("[%s]: %d tablets are %s", store.name(), counts[i], state.name());
            }
          }
          log.debug(String.format("[%s]: scan time %.2f seconds", store.name(), stats.getScanTime() / 1000.));
View Full Code Here
1142
1143
1144
1145
1146
1147
1148
1149
1150
1151
1152
                } else {
                  log.warn("Could not connect to server " + server);
                }
              }
            }
            counts[state.ordinal()]++;
          }
          stats.end();
         
          // Report changes
          for (TabletState state : TabletState.values()) {
View Full Code Here
1148
1149
1150
1151
1152
1153
1154
1155
1156
1157
1158
          }
          stats.end();
         
          // Report changes
          for (TabletState state : TabletState.values()) {
            int i = state.ordinal();
            if (counts[i] > 0 && counts[i] != oldCounts[i]) {
              nextEvent.somethingInterestingHappened("[%s]: %d tablets are %s", store.name(), counts[i], state.name());
            }
          }
          log.debug(String.format("[%s]: scan time %.2f seconds", store.name(), stats.getScanTime() / 1000.));
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.