@Test public void testInvalidFormat() throws Exception { Config config = ConfigFactory.parseMap(ImmutableMap.<String, String>of("destinationFormats", "flattenedOrc,nestedOrc")); ConvertibleHiveDataset cd = createTestConvertibleDataset(config); Assert.assertFalse(cd.getConversionConfigForFormat("invalidFormat").isPresent()); }
public Optional<ConversionConfig> getConversionConfigForFormat(String format) { return Optional.fromNullable(this.destConversionConfigs.get(format)); }
ConvertibleHiveDataset extends HiveDataset { public Optional<ConversionConfig> getConversionConfigForFormat(String format) { return Optional.fromNullable(this.destConversionConfigs.get(format)); } }
ConvertibleHiveDataset extends HiveDataset { public Optional<ConversionConfig> getConversionConfigForFormat(String format) { return Optional.fromNullable(this.destConversionConfigs.get(format)); } ConvertibleHiveDataset(FileSystem fs, HiveMetastoreClientPool clientPool, Table table, Properties jobProps, Config config); }
ConvertibleHiveDataset extends HiveDataset { public Optional<ConversionConfig> getConversionConfigForFormat(String format) { return Optional.fromNullable(this.destConversionConfigs.get(format)); } ConvertibleHiveDataset(FileSystem fs, HiveMetastoreClientPool clientPool, Table table, Properties jobProps, Config config); Optional<ConversionConfig> getConversionConfigForFormat(String format); }
ConvertibleHiveDataset extends HiveDataset { public Optional<ConversionConfig> getConversionConfigForFormat(String format) { return Optional.fromNullable(this.destConversionConfigs.get(format)); } ConvertibleHiveDataset(FileSystem fs, HiveMetastoreClientPool clientPool, Table table, Properties jobProps, Config config); Optional<ConversionConfig> getConversionConfigForFormat(String format); static final String DESTINATION_CONVERSION_FORMATS_KEY; }