@Test public void testGetRecordTable() throws IOException, InterruptedException { when(tableFactory.getTable(any(HTableDescriptor.class))).thenReturn(recordTable); HTableInterface recordTable = LilyHBaseSchema.getRecordTable(tableFactory, RepoAndTableUtil.DEFAULT_REPOSITORY, RECORD_TABLE_NAME); assertNotNull(recordTable); }
public static HTableInterface getRecordTable(HBaseTableFactory tableFactory, String repositoryName, String tableName) throws IOException, InterruptedException { HTableInterface recordTable = tableFactory.getTable(createRecordTableDescriptor(repositoryName, tableName)); verifyIsRecordTable(recordTable.getTableDescriptor()); return recordTable; }
LilyHBaseSchema { public static HTableInterface getRecordTable(HBaseTableFactory tableFactory, String repositoryName, String tableName) throws IOException, InterruptedException { HTableInterface recordTable = tableFactory.getTable(createRecordTableDescriptor(repositoryName, tableName)); verifyIsRecordTable(recordTable.getTableDescriptor()); return recordTable; } }
LilyHBaseSchema { public static HTableInterface getRecordTable(HBaseTableFactory tableFactory, String repositoryName, String tableName) throws IOException, InterruptedException { HTableInterface recordTable = tableFactory.getTable(createRecordTableDescriptor(repositoryName, tableName)); verifyIsRecordTable(recordTable.getTableDescriptor()); return recordTable; } private  LilyHBaseSchema(); }
LilyHBaseSchema { public static HTableInterface getRecordTable(HBaseTableFactory tableFactory, String repositoryName, String tableName) throws IOException, InterruptedException { HTableInterface recordTable = tableFactory.getTable(createRecordTableDescriptor(repositoryName, tableName)); verifyIsRecordTable(recordTable.getTableDescriptor()); return recordTable; } private  LilyHBaseSchema(); static boolean isRecordTableDescriptor(HTableDescriptor htableDescriptor); static HTableInterface getRecordTable(HBaseTableFactory tableFactory, String repositoryName, String tableName); static HTableInterface getRecordTable(HBaseTableFactory tableFactory, String repositoryName, String tableName, byte[][] splitKeys); static HTableInterface getRecordTable(HBaseTableFactory tableFactory, String repositoryName, String tableName, boolean clientMode); static HTableInterface getTypeTable(HBaseTableFactory tableFactory); static HTableInterface getBlobIncubatorTable(HBaseTableFactory tableFactory, boolean clientMode); }
LilyHBaseSchema { public static HTableInterface getRecordTable(HBaseTableFactory tableFactory, String repositoryName, String tableName) throws IOException, InterruptedException { HTableInterface recordTable = tableFactory.getTable(createRecordTableDescriptor(repositoryName, tableName)); verifyIsRecordTable(recordTable.getTableDescriptor()); return recordTable; } private  LilyHBaseSchema(); static boolean isRecordTableDescriptor(HTableDescriptor htableDescriptor); static HTableInterface getRecordTable(HBaseTableFactory tableFactory, String repositoryName, String tableName); static HTableInterface getRecordTable(HBaseTableFactory tableFactory, String repositoryName, String tableName, byte[][] splitKeys); static HTableInterface getRecordTable(HBaseTableFactory tableFactory, String repositoryName, String tableName, boolean clientMode); static HTableInterface getTypeTable(HBaseTableFactory tableFactory); static HTableInterface getBlobIncubatorTable(HBaseTableFactory tableFactory, boolean clientMode); static final byte[] TABLE_TYPE_PROPERTY; static final byte[] TABLE_TYPE_RECORD; }