List of splitQuery() Examples

Examples of splitQuery()

com.caucho.server.dispatch.InvocationDecoder.splitQuery()
Splits out the query string, and normalizes the URI, assuming nothing needs unescaping.
com.youtube.vitess.vtgate.VtGate.splitQuery()
Split a query into primary key range query parts. Rows corresponding to the sub queries will add up to original queries' rows. Sub queries are by default built to run against 'rdonly' instances. Batch jobs or MapReduce jobs that needs to scan all rows can use these queries to parallelize full table scans.
org.apache.metamodel.jdbc.QuerySplitter.splitQuery()
Splits the query into several queries that will together yield the same result set @return a list of queries that can be executed to yield the samecollective result as this QuerySplitter's query

Examples of com.caucho.server.dispatch.InvocationDecoder.splitQuery()

    InvocationDecoder decoder = new InvocationDecoder();


    String rawURI = url;


    try {
      decoder.splitQuery(includeInvocation, rawURI);
      decoder.splitQuery(forwardInvocation, rawURI);
      decoder.splitQuery(errorInvocation, rawURI);
      decoder.splitQuery(dispatchInvocation, rawURI);


      buildIncludeInvocation(includeInvocation);

View Full Code Here

Examples of com.caucho.server.dispatch.InvocationDecoder.splitQuery()


    String rawURI = url;


    try {
      decoder.splitQuery(includeInvocation, rawURI);
      decoder.splitQuery(forwardInvocation, rawURI);
      decoder.splitQuery(errorInvocation, rawURI);
      decoder.splitQuery(dispatchInvocation, rawURI);


      buildIncludeInvocation(includeInvocation);
      buildForwardInvocation(forwardInvocation);

View Full Code Here

Examples of com.caucho.server.dispatch.InvocationDecoder.splitQuery()

    String rawURI = url;


    try {
      decoder.splitQuery(includeInvocation, rawURI);
      decoder.splitQuery(forwardInvocation, rawURI);
      decoder.splitQuery(errorInvocation, rawURI);
      decoder.splitQuery(dispatchInvocation, rawURI);


      buildIncludeInvocation(includeInvocation);
      buildForwardInvocation(forwardInvocation);
      buildErrorInvocation(errorInvocation);

View Full Code Here

Examples of com.caucho.server.dispatch.InvocationDecoder.splitQuery()


    try {
      decoder.splitQuery(includeInvocation, rawURI);
      decoder.splitQuery(forwardInvocation, rawURI);
      decoder.splitQuery(errorInvocation, rawURI);
      decoder.splitQuery(dispatchInvocation, rawURI);


      buildIncludeInvocation(includeInvocation);
      buildForwardInvocation(forwardInvocation);
      buildErrorInvocation(errorInvocation);
      buildDispatchInvocation(dispatchInvocation);

View Full Code Here

Examples of com.youtube.vitess.vtgate.VtGate.splitQuery()

      if (!columns.contains(KeyspaceId.COL_NAME)) {
        columns.add(KeyspaceId.COL_NAME);
      }
      String sql = "select " + StringUtils.join(columns, ',') + " from " + conf.getInputTable();
      Map<Query, Long> queries =
          vtgate.splitQuery(conf.getKeyspace(), sql, conf.getSplitsPerShard());
      List<InputSplit> splits = new LinkedList<>();
      for (Query query : queries.keySet()) {
        Long size = queries.get(query);
        InputSplit split = new VitessInputSplit(query, size);
        splits.add(split);

View Full Code Here

Examples of com.youtube.vitess.vtgate.VtGate.splitQuery()

      Util.insertRowsInShard(testEnv, shardName, 20);
    }
    Util.waitForTablet("rdonly", 40, 3, testEnv);
    VtGate vtgate = VtGate.connect("localhost:" + testEnv.port, 0);
    Map<Query, Long> queries =
        vtgate.splitQuery("test_keyspace", "select id,keyspace_id from vtgate_test", 1);
    vtgate.close();


    // Verify 2 splits, one per shard
    assertEquals(2, queries.size());
    Set<String> shardsInSplits = new HashSet<>();

View Full Code Here

Examples of com.youtube.vitess.vtgate.VtGate.splitQuery()

            "select id, keyspace_id from vtgate_test where id >= 19",
            "select id, keyspace_id from vtgate_test where id >= 19");
    Util.waitForTablet("rdonly", rowCount, 3, testEnv);
    VtGate vtgate = VtGate.connect("localhost:" + testEnv.port, 0);
    int splitsPerShard = 3;
    Map<Query, Long> queries = vtgate.splitQuery("test_keyspace",
        "select id,keyspace_id from vtgate_test", splitsPerShard);
    vtgate.close();


    // Verify 6 splits, 3 per shard
    assertEquals(2 * splitsPerShard, queries.size());

View Full Code Here

Examples of com.youtube.vitess.vtgate.VtGate.splitQuery()


  @Test
  public void testSplitQueryInvalidTable() throws Exception {
    VtGate vtgate = VtGate.connect("localhost:" + testEnv.port, 0);
    try {
      vtgate.splitQuery("test_keyspace", "select id from invalid_table", 1);
      fail("failed to raise connection exception");
    } catch (ConnectionException e) {
      assertTrue(e.getMessage().contains("query validation error: can't find table in schema"));
    } finally {
      vtgate.close();

View Full Code Here

Examples of org.apache.metamodel.jdbc.QuerySplitter.splitQuery()


        QuerySplitter qs = new QuerySplitter(dc, q);
        qs.setMaxRows(100000);
        assertEquals(14072278, qs.getRowCount());


        List<Query> splitQueries = qs.splitQuery();
        assertEquals(146, splitQueries.size());
        assertEquals(
                "SELECT p.\"title\", p.\"price\", c.\"city\" FROM public.\"products\" p, public.\"customers\" c WHERE p.\"price\" > 27 AND c.\"age\" > 55 AND (c.\"customerid\" < 143 OR c.\"customerid\" IS NULL) AND (p.\"category\" < 8 OR p.\"category\" IS NULL)",
                splitQueries.get(0).toString());
        assertEquals(

View Full Code Here

Examples of org.apache.metamodel.jdbc.QuerySplitter.splitQuery()


        QuerySplitter qs = new QuerySplitter(dc, q);
        qs.setMaxRows(100000);
        assertEquals(14072278, qs.getRowCount());


        List<Query> splitQueries = qs.splitQuery();
        assertEquals(146, splitQueries.size());
        assertEquals(
                "SELECT p.\"title\", p.\"price\", c.\"city\" FROM public.\"products\" p, public.\"customers\" c WHERE p.\"price\" > 27 AND c.\"age\" > 55 AND (c.\"customerid\" < 143 OR c.\"customerid\" IS NULL) AND (p.\"category\" < 8 OR p.\"category\" IS NULL)",
                splitQueries.get(0).toString());
        assertEquals(

View Full Code Here

0 1 2

TOP

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.