@Test public void testEntries() { for (JournalEntry entry : ENTRIES) { assertNotNull(JournalEntryAssociation.getMasterForEntry(entry)); } }
public static String getMasterForEntry(JournalEntry entry) { if (entry.hasAddMountPoint() || entry.hasAsyncPersistRequest() || entry.hasAddSyncPoint() || entry.hasActiveSyncTxId() || entry.hasCompleteFile() || entry.hasDeleteFile() || entry.hasDeleteMountPoint() || entry.hasInodeDirectory() || entry.hasInodeDirectoryIdGenerator() || entry.hasInodeFile() || entry.hasInodeLastModificationTime() || entry.hasNewBlock() || entry.hasPersistDirectory() || entry.hasRemoveSyncPoint() || entry.hasRename() || entry.hasSetAcl() || entry.hasSetAttribute() || entry.hasUpdateUfsMode() || entry.hasUpdateInode() || entry.hasUpdateInodeDirectory() || entry.hasUpdateInodeFile()) { return Constants.FILE_SYSTEM_MASTER_NAME; } if (entry.hasBlockContainerIdGenerator() || entry.hasDeleteBlock() || entry.hasBlockInfo()) { return Constants.BLOCK_MASTER_NAME; } if (entry.hasClusterInfo() || entry.hasPathProperties() || entry.hasRemovePathProperties()) { return Constants.META_MASTER_NAME; } if (entry.hasAttachDb() || entry.hasAddTable() || entry.hasRemoveTable() || entry.hasDetachDb() || entry.hasUpdateDatabaseInfo() || entry.hasAddTransformJobInfo() || entry.hasRemoveTransformJobInfo() || entry.hasCompleteTransformTable()) { return Constants.TABLE_MASTER_NAME; } throw new IllegalStateException("Unrecognized journal entry: " + entry); }
JournalEntryAssociation { public static String getMasterForEntry(JournalEntry entry) { if (entry.hasAddMountPoint() || entry.hasAsyncPersistRequest() || entry.hasAddSyncPoint() || entry.hasActiveSyncTxId() || entry.hasCompleteFile() || entry.hasDeleteFile() || entry.hasDeleteMountPoint() || entry.hasInodeDirectory() || entry.hasInodeDirectoryIdGenerator() || entry.hasInodeFile() || entry.hasInodeLastModificationTime() || entry.hasNewBlock() || entry.hasPersistDirectory() || entry.hasRemoveSyncPoint() || entry.hasRename() || entry.hasSetAcl() || entry.hasSetAttribute() || entry.hasUpdateUfsMode() || entry.hasUpdateInode() || entry.hasUpdateInodeDirectory() || entry.hasUpdateInodeFile()) { return Constants.FILE_SYSTEM_MASTER_NAME; } if (entry.hasBlockContainerIdGenerator() || entry.hasDeleteBlock() || entry.hasBlockInfo()) { return Constants.BLOCK_MASTER_NAME; } if (entry.hasClusterInfo() || entry.hasPathProperties() || entry.hasRemovePathProperties()) { return Constants.META_MASTER_NAME; } if (entry.hasAttachDb() || entry.hasAddTable() || entry.hasRemoveTable() || entry.hasDetachDb() || entry.hasUpdateDatabaseInfo() || entry.hasAddTransformJobInfo() || entry.hasRemoveTransformJobInfo() || entry.hasCompleteTransformTable()) { return Constants.TABLE_MASTER_NAME; } throw new IllegalStateException("Unrecognized journal entry: " + entry); } }
JournalEntryAssociation { public static String getMasterForEntry(JournalEntry entry) { if (entry.hasAddMountPoint() || entry.hasAsyncPersistRequest() || entry.hasAddSyncPoint() || entry.hasActiveSyncTxId() || entry.hasCompleteFile() || entry.hasDeleteFile() || entry.hasDeleteMountPoint() || entry.hasInodeDirectory() || entry.hasInodeDirectoryIdGenerator() || entry.hasInodeFile() || entry.hasInodeLastModificationTime() || entry.hasNewBlock() || entry.hasPersistDirectory() || entry.hasRemoveSyncPoint() || entry.hasRename() || entry.hasSetAcl() || entry.hasSetAttribute() || entry.hasUpdateUfsMode() || entry.hasUpdateInode() || entry.hasUpdateInodeDirectory() || entry.hasUpdateInodeFile()) { return Constants.FILE_SYSTEM_MASTER_NAME; } if (entry.hasBlockContainerIdGenerator() || entry.hasDeleteBlock() || entry.hasBlockInfo()) { return Constants.BLOCK_MASTER_NAME; } if (entry.hasClusterInfo() || entry.hasPathProperties() || entry.hasRemovePathProperties()) { return Constants.META_MASTER_NAME; } if (entry.hasAttachDb() || entry.hasAddTable() || entry.hasRemoveTable() || entry.hasDetachDb() || entry.hasUpdateDatabaseInfo() || entry.hasAddTransformJobInfo() || entry.hasRemoveTransformJobInfo() || entry.hasCompleteTransformTable()) { return Constants.TABLE_MASTER_NAME; } throw new IllegalStateException("Unrecognized journal entry: " + entry); } private  JournalEntryAssociation(); }
JournalEntryAssociation { public static String getMasterForEntry(JournalEntry entry) { if (entry.hasAddMountPoint() || entry.hasAsyncPersistRequest() || entry.hasAddSyncPoint() || entry.hasActiveSyncTxId() || entry.hasCompleteFile() || entry.hasDeleteFile() || entry.hasDeleteMountPoint() || entry.hasInodeDirectory() || entry.hasInodeDirectoryIdGenerator() || entry.hasInodeFile() || entry.hasInodeLastModificationTime() || entry.hasNewBlock() || entry.hasPersistDirectory() || entry.hasRemoveSyncPoint() || entry.hasRename() || entry.hasSetAcl() || entry.hasSetAttribute() || entry.hasUpdateUfsMode() || entry.hasUpdateInode() || entry.hasUpdateInodeDirectory() || entry.hasUpdateInodeFile()) { return Constants.FILE_SYSTEM_MASTER_NAME; } if (entry.hasBlockContainerIdGenerator() || entry.hasDeleteBlock() || entry.hasBlockInfo()) { return Constants.BLOCK_MASTER_NAME; } if (entry.hasClusterInfo() || entry.hasPathProperties() || entry.hasRemovePathProperties()) { return Constants.META_MASTER_NAME; } if (entry.hasAttachDb() || entry.hasAddTable() || entry.hasRemoveTable() || entry.hasDetachDb() || entry.hasUpdateDatabaseInfo() || entry.hasAddTransformJobInfo() || entry.hasRemoveTransformJobInfo() || entry.hasCompleteTransformTable()) { return Constants.TABLE_MASTER_NAME; } throw new IllegalStateException("Unrecognized journal entry: " + entry); } private  JournalEntryAssociation(); static String getMasterForEntry(JournalEntry entry); }
JournalEntryAssociation { public static String getMasterForEntry(JournalEntry entry) { if (entry.hasAddMountPoint() || entry.hasAsyncPersistRequest() || entry.hasAddSyncPoint() || entry.hasActiveSyncTxId() || entry.hasCompleteFile() || entry.hasDeleteFile() || entry.hasDeleteMountPoint() || entry.hasInodeDirectory() || entry.hasInodeDirectoryIdGenerator() || entry.hasInodeFile() || entry.hasInodeLastModificationTime() || entry.hasNewBlock() || entry.hasPersistDirectory() || entry.hasRemoveSyncPoint() || entry.hasRename() || entry.hasSetAcl() || entry.hasSetAttribute() || entry.hasUpdateUfsMode() || entry.hasUpdateInode() || entry.hasUpdateInodeDirectory() || entry.hasUpdateInodeFile()) { return Constants.FILE_SYSTEM_MASTER_NAME; } if (entry.hasBlockContainerIdGenerator() || entry.hasDeleteBlock() || entry.hasBlockInfo()) { return Constants.BLOCK_MASTER_NAME; } if (entry.hasClusterInfo() || entry.hasPathProperties() || entry.hasRemovePathProperties()) { return Constants.META_MASTER_NAME; } if (entry.hasAttachDb() || entry.hasAddTable() || entry.hasRemoveTable() || entry.hasDetachDb() || entry.hasUpdateDatabaseInfo() || entry.hasAddTransformJobInfo() || entry.hasRemoveTransformJobInfo() || entry.hasCompleteTransformTable()) { return Constants.TABLE_MASTER_NAME; } throw new IllegalStateException("Unrecognized journal entry: " + entry); } private  JournalEntryAssociation(); static String getMasterForEntry(JournalEntry entry);  }