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