Package org.apache.beam.sdk.io.kafka

Class KafkaReadWithRedistributeOverride

java.lang.Object

org.apache.beam.sdk.io.kafka.KafkaReadWithRedistributeOverride

public final class KafkaReadWithRedistributeOverride
extends Object

Method Summary

Modifier and Type	Method	Description
static org.apache.beam.sdk.runners.PTransformMatcher	matcher()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

matcher

public static org.apache.beam.sdk.runners.PTransformMatcher matcher()