@Test(expected=IllegalArgumentException.class) public void testGetRecordTable_WithSplits_NotRecordTable() throws IOException, InterruptedException { when(tableFactory.getTable(any(HTableDescriptor.class), any(byte[][].class))).thenReturn(nonRecordTable); LilyHBaseSchema.getRecordTable(tableFactory, RepoAndTableUtil.DEFAULT_REPOSITORY, NON_RECORD_TABLE_NAME, new byte[][]{}); }
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; }