HiveOutput implements BulkOutput, ProvidesAlias, ProvidesValidations { @Override public Set<MutationType> getSupportedBulkMutationTypes() { return Sets.newHashSet(MutationType.INSERT, MutationType.OVERWRITE); }  @Override void configure(Config config); @Override void applyBulkMutations(List<Tuple2<MutationType, Dataset<Row>>> planned); @Override Set<MutationType> getSupportedBulkMutationTypes(); Dataset<Row> alignColumns(Dataset<Row> input); @Override String getAlias(); @Override Validations getValidations(); final static String TABLE_CONFIG; final static String PARTITION_BY_CONFIG; final static String LOCATION_CONFIG; final static String OPTIONS_CONFIG; final static String ALIGN_COLUMNS_CONFIG; final static String SPARK_SQL_CASE_SENSITIVE_CONFIG; }
@Test public void getSupportedBulkMutationTypes() throws Exception { HiveOutput hiveOutput = new HiveOutput(); Set<MutationType> mutationTypes = hiveOutput.getSupportedBulkMutationTypes(); assertEquals("Invalid number of mutation types", 2, mutationTypes.size()); assertTrue("INSERT not supported", mutationTypes.contains(MutationType.INSERT)); assertTrue("OVERWRITE not supported", mutationTypes.contains(MutationType.OVERWRITE)); }