public class BroadcastOperatorSpec extends Object implements OperatorSpec
Modifier and Type | Class and Description |
---|---|
static class |
BroadcastOperatorSpec.Builder |
Constructor and Description |
---|
BroadcastOperatorSpec(String senderId,
Class<? extends Codec> dataCodecClass) |
Modifier and Type | Method and Description |
---|---|
Class<? extends Codec> |
getDataCodecClass() |
String |
getSenderId() |
static BroadcastOperatorSpec.Builder |
newBuilder() |
String |
toString() |
public BroadcastOperatorSpec(String senderId, Class<? extends Codec> dataCodecClass)
public String getSenderId()
public Class<? extends Codec> getDataCodecClass()
getDataCodecClass
in interface OperatorSpec
public static BroadcastOperatorSpec.Builder newBuilder()
Copyright © 2017 The Apache Software Foundation. All rights reserved.