Values extends PTransform<PCollection<? extends KV<?, V>>, PCollection<V>> { private Values() {} private  Values(); static Values<V> create(); @Override PCollection<V> expand(PCollection<? extends KV<?, V>> in);  }
@Test @Category(NeedsRunner.class) public void testValues() { PCollection<KV<String, Integer>> input = p.apply( Create.of(Arrays.asList(TABLE)) .withCoder(KvCoder.of(StringUtf8Coder.of(), BigEndianIntegerCoder.of()))); PCollection<Integer> output = input.apply(Values.create()); PAssert.that(output).containsInAnyOrder(1, 2, 3, 4, 4); p.run(); }