Examples of Count


Examples of mungbean.protocol.command.Count

            }
        }

        public void databaseTests() {
            DBCollection<Map<String, Object>> collection = context.openCollection("foo");
            long initialCount = collection.query(new Count(), new Query());
            collection.save(doc);

            List<Map<String, Object>> results = collection.query(idQuery);
            specify(results.size(), does.equal(1));
            specify(results.get(0).get("foo"), does.equal("bar"));
            collection.query(new Distinct<List<Object>>("foo"), new Query()).contains("bar");
            specify(collection.query(new Count(), new Query()), does.equal(initialCount + 1));
            runGroup(collection);
            specify(collection.query(new Count(), idQuery), does.equal(1));
            collection.delete(idQuery);
            specify(collection.query(idQuery).size(), does.equal(0));
            specify(context.dbAdmin().getCollectionNames(), containsExactly("foo"));
            specify(collection.query(new Count(), new Query()), does.equal(initialCount));
        }
View Full Code Here

Examples of org.apache.hadoop.fs.shell.Count

        } else if ("-du".equals(cmd)) {
          du(argv[i]);
        } else if ("-dus".equals(cmd)) {
          dus(argv[i]);
        } else if (Count.matches(cmd)) {
          new Count(argv, i, getConf()).runAll();
        } else if ("-ls".equals(cmd)) {
          exitCode = ls(argv[i], false);
        } else if ("-lsr".equals(cmd)) {
          exitCode = ls(argv[i], true);
        } else if ("-touchz".equals(cmd)) {
View Full Code Here

Examples of org.apache.hadoop.fs.shell.Count

          exitCode = doall(cmd, argv, i);
        } else {
          dus(".");
        }        
      } else if (Count.matches(cmd)) {
        exitCode = new Count(argv, i, getConf()).runAll();
      } else if ("-mkdir".equals(cmd)) {
        exitCode = doall(cmd, argv, i);
      } else if ("-touchz".equals(cmd)) {
        exitCode = doall(cmd, argv, i);
      } else if ("-test".equals(cmd)) {
View Full Code Here

Examples of org.apache.hadoop.fs.shell.Count

        } else if ("-du".equals(cmd)) {
          du(argv[i]);
        } else if ("-dus".equals(cmd)) {
          dus(argv[i]);
        } else if (Count.matches(cmd)) {
          new Count(argv, i, getConf()).runAll();
        } else if ("-ls".equals(cmd)) {
          exitCode = ls(argv[i], false);
        } else if ("-lsr".equals(cmd)) {
          exitCode = ls(argv[i], true);
        } else if ("-touchz".equals(cmd)) {
View Full Code Here

Examples of org.apache.hadoop.fs.shell.Count

          exitCode = doall(cmd, argv, i);
        } else {
          dus(".");
        }        
      } else if (Count.matches(cmd)) {
        exitCode = new Count(argv, i, getConf()).runAll();
      } else if ("-mkdir".equals(cmd)) {
        exitCode = doall(cmd, argv, i);
      } else if ("-touchz".equals(cmd)) {
        exitCode = doall(cmd, argv, i);
      } else if ("-test".equals(cmd)) {
View Full Code Here

Examples of org.apache.hadoop.fs.shell.Count

        } else if ("-du".equals(cmd)) {
          du(argv[i]);
        } else if ("-dus".equals(cmd)) {
          dus(argv[i]);
        } else if (Count.matches(cmd)) {
          new Count(argv, i, getConf()).runAll();
        } else if ("-ls".equals(cmd)) {
          exitCode = ls(argv[i], EnumSet.noneOf(LsOption.class));
        } else if ("-lsr".equals(cmd)) {
          exitCode = ls(argv[i], EnumSet.of(LsOption.Recursive));
        } else if ("-lsrx".equals(cmd)) {
View Full Code Here

Examples of org.apache.hadoop.fs.shell.Count

          exitCode = doall(cmd, argv, i);
        } else {
          dus(".");
        }
      } else if (Count.matches(cmd)) {
        exitCode = new Count(argv, i, getConf()).runAll();
      } else if ("-mkdir".equals(cmd)) {
        exitCode = doall(cmd, argv, i);
      } else if ("-undelete".equals(cmd)) {
        exitCode = doall(cmd, argv, i);
      } else if ("-touchz".equals(cmd)) {
View Full Code Here

Examples of org.apache.hadoop.fs.shell.Count

      localfs.mkdirs(localpath);

      final String localstr = localpath.toString();
      System.out.println("localstr=" + localstr);
      runCount(localstr, 1, 0, conf);
      assertEquals(0, new Count(new String[]{root, localstr}, 0, conf).runAll());
    } finally {
      try {
        dfs.close();
      } catch (Exception e) {
      }
View Full Code Here

Examples of org.apache.hadoop.fs.shell.Count

    PrintStream oldOut = System.out;
    System.setOut(out);
    Scanner in = null;
    String results = null;
    try {
      new Count(new String[]{path}, 0, conf).runAll();
      results = bytes.toString();
      in = new Scanner(results);
      assertEquals(dirs, in.nextLong());
      assertEquals(files, in.nextLong());
    } finally {
View Full Code Here

Examples of org.apache.hadoop.fs.shell.Count

        } else if ("-du".equals(cmd)) {
          du(argv[i]);
        } else if ("-dus".equals(cmd)) {
          dus(argv[i]);
        } else if (Count.matches(cmd)) {
          new Count(argv, i, getConf()).runAll();
        } else if ("-ls".equals(cmd)) {
          exitCode = ls(argv[i], false);
        } else if ("-lsr".equals(cmd)) {
          exitCode = ls(argv[i], true);
        } else if ("-touchz".equals(cmd)) {
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.