Package io.crate

Examples of io.crate.PartitionName

537
538
539
540
541
542
543
544
545
546
547
                new Object[]{
                        1, "1970-01-01", new MapBuilder<String, Object>().put("name", "Zaphod").map(),
                        2, "2014-05-21", new MapBuilder<String, Object>().put("name", "Arthur").map()
                });
        assertThat(analysis.partitions(), contains(
                new PartitionName("nested_parted", Arrays.asList(new BytesRef("0"), new BytesRef("Zaphod"))).stringValue(),
                new PartitionName("nested_parted", Arrays.asList(new BytesRef("1400630400000"), new BytesRef("Arthur"))).stringValue()

        ));
        assertThat(analysis.sourceMaps().size(), is(2));
    }
View Full Code Here
134
135
136
137
138
139
140
141
142
143
144
        assertThat((Long)response.rows()[0][0], is(3L));
    }

    @Test
    public void testCreateTableWithOrphanedPartitions() throws Exception {
        String partitionName = new PartitionName("test", Arrays.asList(new BytesRef("foo"))).stringValue();
        client().admin().indices().prepareCreate(partitionName)
                .addMapping(Constants.DEFAULT_MAPPING_TYPE, TEST_PARTITIONED_MAPPING)
                .setSettings(TEST_SETTINGS)
                .execute().actionGet();
        ensureGreen();
View Full Code Here
169
170
171
172
173
174
175
176
177
178
179
        assertThat(client().admin().indices().exists(new IndicesExistsRequest(partitionName)).actionGet().isExists(), is(false));
    }

    @Test
    public void testCreateTableWithOrphanedAlias() throws Exception {
        String partitionName = new PartitionName("test", Arrays.asList(new BytesRef("foo"))).stringValue();
        client().admin().indices().prepareCreate(partitionName)
                .addMapping(Constants.DEFAULT_MAPPING_TYPE, TEST_PARTITIONED_MAPPING)
                .setSettings(TEST_SETTINGS)
                .addAlias(new Alias("test"))
                .execute().actionGet();
View Full Code Here
241
242
243
244
245
246
247
248
249
250
251
        execute("insert into numbers (num, odd, prime) values (?, ?, ?)",
                new Object[]{6, true, false});
        execute("refresh table numbers");

        MappingMetaData partitionMetaData = clusterService().state().metaData().indices()
                .get(new PartitionName("numbers", Arrays.asList(new BytesRef("true"))).stringValue())
                .getMappings().get(Constants.DEFAULT_MAPPING_TYPE);
        assertThat(String.valueOf(partitionMetaData.getSourceAsMap().get("dynamic")), is(ColumnPolicy.STRICT.value()));

        expectedException.expect(SQLActionException.class);
        expectedException.expectMessage("Column 'perfect' unknown");
View Full Code Here
277
278
279
280
281
282
283
284
285
286
287
        execute("insert into numbers (num, odd, prime) values (?, ?, ?)",
                new Object[]{6, true, false});
        execute("refresh table numbers");

        MappingMetaData partitionMetaData = clusterService().state().metaData().indices()
                .get(new PartitionName("numbers", Arrays.asList(new BytesRef("true"))).stringValue())
                .getMappings().get(Constants.DEFAULT_MAPPING_TYPE);
        assertThat(String.valueOf(partitionMetaData.getSourceAsMap().get("dynamic")), is(ColumnPolicy.STRICT.value()));

        expectedException.expect(SQLActionException.class);
        expectedException.expectMessage("Column 'perfect' unknown");
View Full Code Here
313
314
315
316
317
318
319
320
321
322
323
        execute("insert into numbers (num, odd, prime) values (?, ?, ?)",
                new Object[]{6, true, false});
        execute("refresh table numbers");

        MappingMetaData partitionMetaData = clusterService().state().metaData().indices()
                .get(new PartitionName("numbers", Arrays.asList(new BytesRef("true"))).stringValue())
                .getMappings().get(Constants.DEFAULT_MAPPING_TYPE);
        assertThat(String.valueOf(partitionMetaData.getSourceAsMap().get("dynamic")), is("true"));

        execute("insert into numbers (num, odd, prime, perfect) values (?, ?, ?, ?)",
                new Object[]{28, true, false, true});
View Full Code Here
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
        execute("insert into dynamic_table (id, score) values (1, 10)");
        execute("refresh table dynamic_table");
        execute("alter table dynamic_table set (column_policy = 'strict')");
        waitNoPendingTasksOnAll();
        MappingMetaData partitionMetaData = clusterService().state().metaData().indices()
                .get(new PartitionName("dynamic_table", Arrays.asList(new BytesRef("10.0"))).stringValue())
                .getMappings().get(Constants.DEFAULT_MAPPING_TYPE);
        assertThat(String.valueOf(partitionMetaData.getSourceAsMap().get("dynamic")), is(ColumnPolicy.STRICT.value()));
        execute("alter table dynamic_table reset (column_policy)");
        waitNoPendingTasksOnAll();
        partitionMetaData = clusterService().state().metaData().indices()
                .get(new PartitionName("dynamic_table", Arrays.asList(new BytesRef("10.0"))).stringValue())
                .getMappings().get(Constants.DEFAULT_MAPPING_TYPE);
        assertThat(String.valueOf(partitionMetaData.getSourceAsMap().get("dynamic")), is(String.valueOf(ColumnPolicy.DYNAMIC.mappingValue())));
    }
View Full Code Here
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
                new Object[]{6, 3, "hello"});
        execute("refresh table dynamic_table");
        ensureGreen();

        MappingMetaData partitionMetaData = clusterService().state().metaData().indices()
                .get(new PartitionName("dynamic_table", Arrays.asList(new BytesRef("10.0"))).stringValue())
                .getMappings().get(Constants.DEFAULT_MAPPING_TYPE);
        assertThat(String.valueOf(partitionMetaData.getSourceAsMap().get("dynamic")), is(String.valueOf(ColumnPolicy.DYNAMIC.mappingValue())));

        partitionMetaData = clusterService().state().metaData().indices()
                .get(new PartitionName("dynamic_table", Arrays.asList(new BytesRef("5.0"))).stringValue())
                .getMappings().get(Constants.DEFAULT_MAPPING_TYPE);
        assertThat(String.valueOf(partitionMetaData.getSourceAsMap().get("dynamic")), is(String.valueOf(ColumnPolicy.DYNAMIC.mappingValue())));

        partitionMetaData = clusterService().state().metaData().indices()
                .get(new PartitionName("dynamic_table", Arrays.asList(new BytesRef("3.0"))).stringValue())
                .getMappings().get(Constants.DEFAULT_MAPPING_TYPE);
        assertThat(String.valueOf(partitionMetaData.getSourceAsMap().get("dynamic")), is(String.valueOf(ColumnPolicy.DYNAMIC.mappingValue())));
    }
View Full Code Here
92
93
94
95
96
97
98
99
100
101
    }

    @Test
    public void testRefreshPartition() throws Exception {
        PartitionName partition = new PartitionName("parted", Arrays.asList(new BytesRef("1395874800000")));
        RefreshTableAnalysis analysis = (RefreshTableAnalysis)analyze("refresh table parted PARTITION (date=1395874800000)");
        assertThat(analysis.table().ident().name(), is("parted"));
        assertThat(analysis.partitionName().stringValue(), is(partition.stringValue()));
    }
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
        assertThat(analysis.partitionName().stringValue(), is(partition.stringValue()));
    }

    @Test
    public void testRefreshPartitionsParameter() throws Exception {
        PartitionName partition = new PartitionName("parted", Arrays.asList(new BytesRef("1395874800000")));
        RefreshTableAnalysis analysis = (RefreshTableAnalysis) analyze(
                "refresh table parted PARTITION (date=?)", new Object[] {"1395874800000"});
        assertThat(analysis.table().ident().name(), is("parted"));
        assertThat(analysis.partitionName().stringValue(), is(partition.stringValue()));
    }
View Full Code Here
TOP

Related Classes of io.crate.PartitionName

  • io.crate.analyze.AlterTableAddColumnAnalyzer
  • io.crate.analyze.AlterTableAnalyzer
  • io.crate.analyze.CopyAnalyzerTest
  • io.crate.analyze.CreateAlterPartitionedTableAnalyzerTest
  • io.crate.analyze.DeleteAnalyzerTest
  • io.crate.analyze.InsertFromValuesAnalysis
  • io.crate.analyze.InsertFromValuesAnalyzerTest
  • io.crate.analyze.PartitionPropertiesAnalyzer
  • io.crate.analyze.PartitionPropertiesAnalyzerTest
  • io.crate.analyze.RefreshAnalyzerTest
    • Copyright © 2018 www.massapicom. 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.