public class MappedPipelineFactory extends java.lang.Object implements WritePipelineFactory
Constructor and Description |
---|
MappedPipelineFactory() |
Modifier and Type | Method and Description |
---|---|
void |
deregisterPipeline(java.lang.String name) |
PartitionWritePipeline |
getPipeline(java.lang.String partitionName) |
void |
registerPipeline(java.lang.String name,
PartitionWritePipeline pipelineWriter) |
public PartitionWritePipeline getPipeline(java.lang.String partitionName)
getPipeline
in interface WritePipelineFactory
public void registerPipeline(java.lang.String name, PartitionWritePipeline pipelineWriter)
registerPipeline
in interface WritePipelineFactory
public void deregisterPipeline(java.lang.String name)
deregisterPipeline
in interface WritePipelineFactory