public class RecordWriterBuilder extends Object
RecordWriter
instance.Constructor and Description |
---|
RecordWriterBuilder() |
Modifier and Type | Method and Description |
---|---|
RecordWriter |
build(ResultPartitionWriter writer) |
RecordWriterBuilder |
setChannelSelector(ChannelSelector selector) |
RecordWriterBuilder |
setTaskName(String taskName) |
RecordWriterBuilder |
setTimeout(long timeout) |
public RecordWriterBuilder setChannelSelector(ChannelSelector selector)
public RecordWriterBuilder setTimeout(long timeout)
public RecordWriterBuilder setTaskName(String taskName)
public RecordWriter build(ResultPartitionWriter writer)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.