org.apache.pinot.tools.segment.processor

Class SegmentProcessorFrameworkSpec

java.lang.Object

org.apache.pinot.tools.segment.processor.SegmentProcessorFrameworkSpec

public class SegmentProcessorFrameworkSpec
extends Object

Container for all spec related to Segment Processor Framework required for running via pinot-admin

Constructor Summary

Constructors

Constructor and Description
SegmentProcessorFrameworkSpec()

Method Summary

Modifier and Type	Method and Description
CollectorConfig	getCollectorConfig()
String	getInputSegmentsDir()
String	getOutputSegmentsDir()
List<PartitionerConfig>	getPartitionerConfigs()
RecordFilterConfig	getRecordFilterConfig()
RecordTransformerConfig	getRecordTransformerConfig()
String	getSchemaFile()
SegmentConfig	getSegmentConfig()
String	getTableConfigFile()
void	setCollectorConfig(CollectorConfig collectorConfig)
void	setInputSegmentsDir(String inputSegmentsDir)
void	setOutputSegmentsDir(String outputSegmentsDir)
void	setPartitionerConfigs(List<PartitionerConfig> partitionerConfigs)
void	setRecordFilterConfig(RecordFilterConfig recordFilterConfig)
void	setRecordTransformerConfig(RecordTransformerConfig recordTransformerConfig)
void	setSchemaFile(String schemaFile)
void	setSegmentConfig(SegmentConfig segmentConfig)
void	setTableConfigFile(String tableConfigFile)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SegmentProcessorFrameworkSpec

public SegmentProcessorFrameworkSpec()

Method Detail

getInputSegmentsDir

public String getInputSegmentsDir()

setInputSegmentsDir

public void setInputSegmentsDir(String inputSegmentsDir)

getOutputSegmentsDir

public String getOutputSegmentsDir()

setOutputSegmentsDir

public void setOutputSegmentsDir(String outputSegmentsDir)

getTableConfigFile

public String getTableConfigFile()

setTableConfigFile

public void setTableConfigFile(String tableConfigFile)

getSchemaFile

public String getSchemaFile()

setSchemaFile

public void setSchemaFile(String schemaFile)

getRecordTransformerConfig

public RecordTransformerConfig getRecordTransformerConfig()

setRecordTransformerConfig

public void setRecordTransformerConfig(RecordTransformerConfig recordTransformerConfig)

getRecordFilterConfig

public RecordFilterConfig getRecordFilterConfig()

setRecordFilterConfig

public void setRecordFilterConfig(RecordFilterConfig recordFilterConfig)

getPartitionerConfigs

public List<PartitionerConfig> getPartitionerConfigs()

setPartitionerConfigs

public void setPartitionerConfigs(List<PartitionerConfig> partitionerConfigs)

getCollectorConfig

public CollectorConfig getCollectorConfig()

setCollectorConfig

public void setCollectorConfig(CollectorConfig collectorConfig)

getSegmentConfig

public SegmentConfig getSegmentConfig()

setSegmentConfig

public void setSegmentConfig(SegmentConfig segmentConfig)