@Test public void getSchemaTest() { Assert.assertNotNull(this.extractorMock.getSchema()); }
@Override public PurgeableHivePartitionDatasetSchema getSchema() { return new PurgeableHivePartitionDatasetSchema(); }
HivePurgerExtractor implements Extractor<PurgeableHivePartitionDatasetSchema, PurgeableHivePartitionDataset> { @Override public PurgeableHivePartitionDatasetSchema getSchema() { return new PurgeableHivePartitionDatasetSchema(); } }
HivePurgerExtractor implements Extractor<PurgeableHivePartitionDatasetSchema, PurgeableHivePartitionDataset> { @Override public PurgeableHivePartitionDatasetSchema getSchema() { return new PurgeableHivePartitionDatasetSchema(); } HivePurgerExtractor(WorkUnitState state); }
HivePurgerExtractor implements Extractor<PurgeableHivePartitionDatasetSchema, PurgeableHivePartitionDataset> { @Override public PurgeableHivePartitionDatasetSchema getSchema() { return new PurgeableHivePartitionDatasetSchema(); } HivePurgerExtractor(WorkUnitState state); @Override PurgeableHivePartitionDatasetSchema getSchema(); @Override PurgeableHivePartitionDataset readRecord(PurgeableHivePartitionDataset record); @Override long getExpectedRecordCount(); @Override long getHighWatermark(); @Override void close(); @VisibleForTesting void setRecord(PurgeableHivePartitionDataset record); }
HivePurgerExtractor implements Extractor<PurgeableHivePartitionDatasetSchema, PurgeableHivePartitionDataset> { @Override public PurgeableHivePartitionDatasetSchema getSchema() { return new PurgeableHivePartitionDatasetSchema(); } HivePurgerExtractor(WorkUnitState state); @Override PurgeableHivePartitionDatasetSchema getSchema(); @Override PurgeableHivePartitionDataset readRecord(PurgeableHivePartitionDataset record); @Override long getExpectedRecordCount(); @Override long getHighWatermark(); @Override void close(); @VisibleForTesting void setRecord(PurgeableHivePartitionDataset record);  }