@Test public void testNullParams() { try { UnorderedPartitionedKVEdgeConfigurer.newBuilder(null, "VALUE", "PARTITIONER", null); fail("Expecting a null parameter list to fail"); } catch (NullPointerException npe) { assertTrue(npe.getMessage().contains("cannot be null")); } try { UnorderedPartitionedKVEdgeConfigurer.newBuilder("KEY", null, "PARTITIONER", null); fail("Expecting a null parameter list to fail"); } catch (NullPointerException npe) { assertTrue(npe.getMessage().contains("cannot be null")); } try { UnorderedPartitionedKVEdgeConfigurer.newBuilder("KEY", "VALUE", null, null); fail("Expecting a null parameter list to fail"); } catch (NullPointerException npe) { assertTrue(npe.getMessage().contains("cannot be null")); } }
public static Builder newBuilder(String keyClassName, String valueClassName, String partitionerClassName, Configuration partitionerConf) { return new Builder(keyClassName, valueClassName, partitionerClassName, partitionerConf); }
UnorderedPartitionedKVEdgeConfigurer extends HadoopKeyValuesBasedBaseConf { public static Builder newBuilder(String keyClassName, String valueClassName, String partitionerClassName, Configuration partitionerConf) { return new Builder(keyClassName, valueClassName, partitionerClassName, partitionerConf); } }
UnorderedPartitionedKVEdgeConfigurer extends HadoopKeyValuesBasedBaseConf { public static Builder newBuilder(String keyClassName, String valueClassName, String partitionerClassName, Configuration partitionerConf) { return new Builder(keyClassName, valueClassName, partitionerClassName, partitionerConf); } private  UnorderedPartitionedKVEdgeConfigurer(
      OnFileUnorderedPartitionedKVOutputConfiguration outputConfiguration,
      ShuffledUnorderedKVInputConfiguration inputConfiguration); }
UnorderedPartitionedKVEdgeConfigurer extends HadoopKeyValuesBasedBaseConf { public static Builder newBuilder(String keyClassName, String valueClassName, String partitionerClassName, Configuration partitionerConf) { return new Builder(keyClassName, valueClassName, partitionerClassName, partitionerConf); } private  UnorderedPartitionedKVEdgeConfigurer(
      OnFileUnorderedPartitionedKVOutputConfiguration outputConfiguration,
      ShuffledUnorderedKVInputConfiguration inputConfiguration); static Builder newBuilder(String keyClassName, String valueClassName,
                                   String partitionerClassName, Configuration partitionerConf); @Override byte[] getOutputPayload(); @Override String getOutputClassName(); @Override byte[] getInputPayload(); @Override String getInputClassName(); EdgeProperty createDefaultEdgeProperty(); EdgeProperty createDefaultCustomEdgeProperty(EdgeManagerDescriptor edgeManagerDescriptor); }
UnorderedPartitionedKVEdgeConfigurer extends HadoopKeyValuesBasedBaseConf { public static Builder newBuilder(String keyClassName, String valueClassName, String partitionerClassName, Configuration partitionerConf) { return new Builder(keyClassName, valueClassName, partitionerClassName, partitionerConf); } private  UnorderedPartitionedKVEdgeConfigurer(
      OnFileUnorderedPartitionedKVOutputConfiguration outputConfiguration,
      ShuffledUnorderedKVInputConfiguration inputConfiguration); static Builder newBuilder(String keyClassName, String valueClassName,
                                   String partitionerClassName, Configuration partitionerConf); @Override byte[] getOutputPayload(); @Override String getOutputClassName(); @Override byte[] getInputPayload(); @Override String getInputClassName(); EdgeProperty createDefaultEdgeProperty(); EdgeProperty createDefaultCustomEdgeProperty(EdgeManagerDescriptor edgeManagerDescriptor);  }