Package org.apache.blur.thrift.generated

Examples of org.apache.blur.thrift.generated.Schema

44
45
46
47
48
49
50
51
52
53
54
55
56
    List<String> familiesToDisplay = new ArrayList<String>();
    for (int i = 2; i < args.length; i++) {
      familiesToDisplay.add(args[i]);
    }

    Schema schema = client.schema(tablename);
    out.println("table  : " + schema.getTable());
    Map<String, Map<String, ColumnDefinition>> families = schema.getFamilies();
    Set<String> familyNames = new TreeSet<String>(families.keySet());
    for (String cf : familyNames) {
      if (!familiesToDisplay.isEmpty() && !familiesToDisplay.contains(cf)) {
        continue;
      }
View Full Code Here
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
  @Test
  public void testForEmptySchema() throws BlurException, TException, IOException, InterruptedException {
    String tableName = "testForEmptySchema";
    createTable(tableName);
    Blur.Iface client = getClient();
    Schema schema = client.schema(tableName);
    Map<String, Map<String, ColumnDefinition>> families = schema.getFamilies();
    assertTrue(families.isEmpty());

    TableContext tableContext = TableContext.create(client.describe(tableName));
    FieldManager fieldManager = tableContext.getFieldManager();

    assertTrue(fieldManager.addColumnDefinition("test-family", "test-column", null, false, "string", false, null));

    TableContext.clear();
    Schema newschema = client.schema(tableName);
    Map<String, Map<String, ColumnDefinition>> newfamilies = newschema.getFamilies();
    assertTrue(!newfamilies.isEmpty());
    int newsize = newfamilies.size();
    assertEquals(1, newsize);
  }
View Full Code Here
310
311
312
313
314
315
316
317
    blurQueryRecord.setQuery(queryRecord);
    BlurResults resultsRecord = client.query(tableName, blurQueryRecord);
    assertRecordResults(resultsRecord);
    assertEquals(numberOfDocs * pass, resultsRecord.getTotalResults());

    Schema schema = client.schema(tableName);
    assertFalse(schema.getFamilies().isEmpty());
  }
View Full Code Here
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
    checkTable(table);
    try {
      TableContext tableContext = getTableContext(table);
      FieldManager fieldManager = tableContext.getFieldManager();
      fieldManager.loadFromStorage();
      Schema schema = new Schema().setTable(table);
      schema.setFamilies(new HashMap<String, Map<String, ColumnDefinition>>());
      Set<String> fieldNames = fieldManager.getFieldNames();
      INNER: for (String fieldName : fieldNames) {
        FieldTypeDefinition fieldTypeDefinition = fieldManager.getFieldTypeDefinition(fieldName);
        if (fieldTypeDefinition == null) {
          continue INNER;
        }
        String columnName = fieldTypeDefinition.getColumnName();
        String columnFamily = fieldTypeDefinition.getFamily();
        String subColumnName = fieldTypeDefinition.getSubColumnName();
        Map<String, ColumnDefinition> map = schema.getFamilies().get(columnFamily);
        if (map == null) {
          map = new HashMap<String, ColumnDefinition>();
          schema.putToFamilies(columnFamily, map);
        }
        if (subColumnName == null) {
          map.put(columnName, getColumnDefinition(fieldTypeDefinition));
        } else {
          map.put(columnName + "." + subColumnName, getColumnDefinition(fieldTypeDefinition));
View Full Code Here
54
55
56
57
58
59
60
61
62
63
64
  }

  @Override
  public void run() {
    try {
      Schema schema = null;
      schema = blurConnection.schema(tableName);
      if (schema == null || descriptor == null) {
        throw new NullReturnedException("No Schema or Descriptor Defined!");
      }
View Full Code Here
TOP

Related Classes of org.apache.blur.thrift.generated.Schema

  • org.apache.blur.agent.collectors.blur.table.SchemaCollector
  • org.apache.blur.console.util.TableUtil
  • org.apache.blur.jdbc.BlurDatabaseMetaData
  • org.apache.blur.manager.IndexManager
  • org.apache.blur.manager.IndexManagerTest
  • org.apache.blur.shell.SchemaTableCommand
  • org.apache.blur.thirdparty.thrift_0_9_0.protocol.TTupleProtocol
  • org.apache.blur.thrift.BlurClusterTest
  • org.apache.blur.thrift.BlurControllerServer
  • org.apache.blur.thrift.TableAdmin
    • 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.