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